org.apache.storm.kafka

Class ExponentialBackoffMsgRetryManagerTest

java.lang.Object

org.apache.storm.kafka.ExponentialBackoffMsgRetryManagerTest

public class ExponentialBackoffMsgRetryManagerTest
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
ExponentialBackoffMsgRetryManagerTest()

Method Summary

Modifier and Type	Method and Description
void	testAckThenFail()
void	testClearInvalidMessages()
void	testExponentialBackoff()
void	testFailRetryRetry()
void	testFailThenAck()
void	testImmediateRetry()
void	testMaxBackoff()
void	testMaxRetry()
void	testQueriesAfterRetriedAlready()
void	testRetryOrder()
void	testRetryWithoutFail()
void	testSingleDelay()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ExponentialBackoffMsgRetryManagerTest

public ExponentialBackoffMsgRetryManagerTest()

Method Detail

testImmediateRetry

public void testImmediateRetry()
                        throws java.lang.Exception

Throws:

java.lang.Exception

testSingleDelay

public void testSingleDelay()
                     throws java.lang.Exception

Throws:

java.lang.Exception

testExponentialBackoff

public void testExponentialBackoff()
                            throws java.lang.Exception

Throws:

java.lang.Exception

testRetryOrder

public void testRetryOrder()
                    throws java.lang.Exception

Throws:

java.lang.Exception

testQueriesAfterRetriedAlready

public void testQueriesAfterRetriedAlready()
                                    throws java.lang.Exception

Throws:

java.lang.Exception

testRetryWithoutFail

public void testRetryWithoutFail()
                          throws java.lang.Exception

Throws:

java.lang.Exception

testFailRetryRetry

public void testFailRetryRetry()
                        throws java.lang.Exception

Throws:

java.lang.Exception

testMaxBackoff

public void testMaxBackoff()
                    throws java.lang.Exception

Throws:

java.lang.Exception

testFailThenAck

public void testFailThenAck()
                     throws java.lang.Exception

Throws:

java.lang.Exception

testAckThenFail

public void testAckThenFail()
                     throws java.lang.Exception

Throws:

java.lang.Exception

testClearInvalidMessages

public void testClearInvalidMessages()
                              throws java.lang.Exception

Throws:

java.lang.Exception

testMaxRetry

public void testMaxRetry()
                  throws java.lang.Exception

Throws:

java.lang.Exception