org.spf4j.failsafe

Class RetryPolicyTest

java.lang.Object

org.spf4j.failsafe.RetryPolicyTest

public class RetryPolicyTest
extends Object

Author:

Zoltan Farkas

Field Summary

Fields

Modifier and Type	Field and Description
static String	PREDICATE_CLASS

Constructor Summary

Constructors

Constructor and Description
RetryPolicyTest()

Method Summary

Modifier and Type	Method and Description
void	assertASyncRetry(Server server, org.spf4j.failsafe.AsyncRetryExecutor<Response,ServerCall> rp, Response response1)
void	assertSyncRetry(Server server, org.spf4j.failsafe.AsyncRetryExecutor<Response,ServerCall> rp, Response response1)
org.spf4j.failsafe.AsyncRetryExecutor<Response,ServerCall>	buildRetryExecutor()
static void	init()
static void	shutdown()
void	testComplexRetryASync()
void	testComplexRetrySync()
void	testDefaulPolicy()
void	testDefaulPolicyAsync()
void	testDefaulPolicyInterruption()
void	testDefaulPolicyInterruptionAsync()
void	testNoRetryPolicy()
void	testNoRetryPolicy2()
void	testNoRetryPolicyAsync()
void	testSpecificExceptionRetryPolicy()

Methods inherited from class java.lang.Object

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

Field Detail

PREDICATE_CLASS

public static final String PREDICATE_CLASS

Constructor Detail

RetryPolicyTest

public RetryPolicyTest()

Method Detail

init

public static void init()

shutdown

public static void shutdown()
                     throws InterruptedException

Throws:

InterruptedException

testNoRetryPolicy

public void testNoRetryPolicy()
                       throws IOException,
                              InterruptedException,
                              TimeoutException

Throws:

IOException

InterruptedException

TimeoutException

testNoRetryPolicyAsync

public void testNoRetryPolicyAsync()
                            throws IOException,
                                   InterruptedException,
                                   TimeoutException

Throws:

IOException

InterruptedException

TimeoutException

testDefaulPolicy

public void testDefaulPolicy()
                      throws IOException,
                             InterruptedException,
                             TimeoutException

Throws:

IOException

InterruptedException

TimeoutException

testDefaulPolicyAsync

public void testDefaulPolicyAsync()
                           throws IOException,
                                  InterruptedException,
                                  TimeoutException

Throws:

IOException

InterruptedException

TimeoutException

testDefaulPolicyInterruption

public void testDefaulPolicyInterruption()
                                  throws IOException,
                                         InterruptedException,
                                         TimeoutException

Throws:

IOException

InterruptedException

TimeoutException

testDefaulPolicyInterruptionAsync

public void testDefaulPolicyInterruptionAsync()
                                       throws IOException,
                                              InterruptedException,
                                              TimeoutException,
                                              ExecutionException

Throws:

IOException

InterruptedException

TimeoutException

ExecutionException

testNoRetryPolicy2

public void testNoRetryPolicy2()
                        throws InterruptedException,
                               TimeoutException

Throws:

InterruptedException

TimeoutException

testComplexRetrySync

public void testComplexRetrySync()
                          throws InterruptedException,
                                 TimeoutException,
                                 IOException,
                                 ExecutionException

Throws:

InterruptedException

TimeoutException

IOException

ExecutionException

testComplexRetryASync

public void testComplexRetryASync()
                           throws InterruptedException,
                                  TimeoutException,
                                  IOException,
                                  ExecutionException

Throws:

InterruptedException

TimeoutException

IOException

ExecutionException

buildRetryExecutor

public final org.spf4j.failsafe.AsyncRetryExecutor<Response,ServerCall> buildRetryExecutor()

assertSyncRetry

public final void assertSyncRetry(Server server,
                                  org.spf4j.failsafe.AsyncRetryExecutor<Response,ServerCall> rp,
                                  Response response1)
                           throws InterruptedException,
                                  TimeoutException,
                                  ExecutionException,
                                  IOException

Throws:

InterruptedException

TimeoutException

ExecutionException

IOException

assertASyncRetry

public final void assertASyncRetry(Server server,
                                   org.spf4j.failsafe.AsyncRetryExecutor<Response,ServerCall> rp,
                                   Response response1)
                            throws InterruptedException,
                                   TimeoutException,
                                   ExecutionException,
                                   IOException

Throws:

InterruptedException

TimeoutException

ExecutionException

IOException

testSpecificExceptionRetryPolicy

public void testSpecificExceptionRetryPolicy()
                                      throws TimeoutException,
                                             InterruptedException

Throws:

TimeoutException

InterruptedException