testutils

Class SessionStrategyTestHelper

java.lang.Object

testutils.SessionStrategyTestHelper

public class SessionStrategyTestHelper
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SessionStrategyTestHelper.ClientContext
static class	SessionStrategyTestHelper.EnquireLinkRequestContext
static interface	SessionStrategyTestHelper.EnquireLinkTaskAware
static interface	SessionStrategyTestHelper.Negatable
static interface	SessionStrategyTestHelper.SessionAware
static class	SessionStrategyTestHelper.SessionContext
static interface	SessionStrategyTestHelper.TestContext
static interface	SessionStrategyTestHelper.Verification

Method Summary

Modifier and Type	Method and Description
static SessionStrategyTestHelper.Verification	active()
static <T> Function<SessionStrategyTestHelper.TestContext,T>	by(Function<SessionStrategyTestHelper.TestContext,T> provider)
static SessionStrategyTestHelper.Negatable	cleaned()
static Function<SessionStrategyTestHelper.TestContext,com.cloudhopper.smpp.SmppClient>	client(int clientIndex)
SessionStrategyTestHelper	client(int clientIdx, SessionStrategyTestHelper.Verification... verifications)
static Function<SessionStrategyTestHelper.TestContext,com.cloudhopper.smpp.SmppClient>	client(com.cloudhopper.smpp.SmppClient client)
SessionStrategyTestHelper	client(com.cloudhopper.smpp.SmppClient client, SessionStrategyTestHelper.Verification... verifications)
static Callable<Boolean>	clientConnected(com.cloudhopper.smpp.SmppClient client)
static SessionStrategyTestHelper.Verification	closed()
static SessionStrategyTestHelper.Verification	connectionAttempts(int attempts, Function<SessionStrategyTestHelper.TestContext,com.cloudhopper.smpp.SmppClient> clientProvider)
static SessionStrategyTestHelper.Verification	createdTasks(int numCreated)
static SessionStrategyTestHelper.Verification	createdTimers(int numCreated)
static Callable<Boolean>	enquireLinkFailureReceived(com.cloudhopper.smpp.SmppSession session)
static Callable<Boolean>	enquireLinkReceived(com.cloudhopper.smpp.SmppSession session, int num)
SessionStrategyTestHelper	enquireLinks(SessionStrategyTestHelper.Verification... verifications)
SessionStrategyTestHelper	enquireLinkTask(int requestIdx, SessionStrategyTestHelper.Verification... verifications)
static Callable<Boolean>	enquireLinkTimeout(com.cloudhopper.smpp.SmppSession session)
static Callable<Boolean>	expirationOfLastRequest(int delay)
static SessionStrategyTestHelper.Verification	isNull()
static SessionStrategyTestHelper.Verification	not(SessionStrategyTestHelper.Negatable verification)
static SessionStrategyTestHelper.Verification	opened()
static SessionStrategyTestHelper.Verification	opened(int numberOpened)
static SessionStrategyTestHelper.Verification	opened(int numberOpened, SessionStrategyTestHelper.Verification... additionalVerifications)
static Callable<Boolean>	reconnectionFailed(com.cloudhopper.smpp.SmppClient client, int attempts)
static int	requests(int num)
static SessionStrategyTestHelper.Verification	sent(int numSent, Function<SessionStrategyTestHelper.TestContext,com.cloudhopper.smpp.SmppSession> sessionProvider)
static Function<SessionStrategyTestHelper.TestContext,com.cloudhopper.smpp.SmppSession>	session(int sessionIndex)
SessionStrategyTestHelper	session(int sessionIdx, SessionStrategyTestHelper.Verification... verifications)
static Function<SessionStrategyTestHelper.TestContext,com.cloudhopper.smpp.SmppSession>	session(com.cloudhopper.smpp.SmppSession session)
SessionStrategyTestHelper	session(com.cloudhopper.smpp.SmppSession session, SessionStrategyTestHelper.Verification... verifications)
SessionStrategyTestHelper	sessions(SessionStrategyTestHelper.Verification... verifications)
static SessionStrategyTestHelper.Verification	stopped()
static ScheduledExecutorService	track(ScheduledExecutorService tracked, List<ScheduledFuture<?>> trackedTasks, int timerIdx)
static ScheduledFuture<?>	track(ScheduledFuture<?> tracked, int taskIdx)
static com.cloudhopper.smpp.SmppClient	track(com.cloudhopper.smpp.SmppClient tracked, List<com.cloudhopper.smpp.SmppSession> trackedSessions, int clientIdx)
static com.cloudhopper.smpp.SmppSession	track(com.cloudhopper.smpp.SmppSession tracked, int sessionIdx)
static SessionStrategyTestHelper	verifyThat(Supplier<SessionStrategyTestHelper.TestContext> test)
static void	waitUntil(Callable<Boolean> until)

Methods inherited from class java.lang.Object

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

Method Detail

sessions

public SessionStrategyTestHelper sessions(SessionStrategyTestHelper.Verification... verifications)

enquireLinks

public SessionStrategyTestHelper enquireLinks(SessionStrategyTestHelper.Verification... verifications)

session

public SessionStrategyTestHelper session(int sessionIdx,
                                         SessionStrategyTestHelper.Verification... verifications)

session

public SessionStrategyTestHelper session(com.cloudhopper.smpp.SmppSession session,
                                         SessionStrategyTestHelper.Verification... verifications)

client

public SessionStrategyTestHelper client(int clientIdx,
                                        SessionStrategyTestHelper.Verification... verifications)

client

public SessionStrategyTestHelper client(com.cloudhopper.smpp.SmppClient client,
                                        SessionStrategyTestHelper.Verification... verifications)

enquireLinkTask

public SessionStrategyTestHelper enquireLinkTask(int requestIdx,
                                                 SessionStrategyTestHelper.Verification... verifications)

verifyThat

public static SessionStrategyTestHelper verifyThat(Supplier<SessionStrategyTestHelper.TestContext> test)

opened

public static SessionStrategyTestHelper.Verification opened(int numberOpened)

opened

public static SessionStrategyTestHelper.Verification opened(int numberOpened,
                                                            SessionStrategyTestHelper.Verification... additionalVerifications)

sent

public static SessionStrategyTestHelper.Verification sent(int numSent,
                                                          Function<SessionStrategyTestHelper.TestContext,com.cloudhopper.smpp.SmppSession> sessionProvider)

requests

public static int requests(int num)

connectionAttempts

public static SessionStrategyTestHelper.Verification connectionAttempts(int attempts,
                                                                        Function<SessionStrategyTestHelper.TestContext,com.cloudhopper.smpp.SmppClient> clientProvider)

by

public static <T> Function<SessionStrategyTestHelper.TestContext,T> by(Function<SessionStrategyTestHelper.TestContext,T> provider)

session

public static Function<SessionStrategyTestHelper.TestContext,com.cloudhopper.smpp.SmppSession> session(int sessionIndex)

session

public static Function<SessionStrategyTestHelper.TestContext,com.cloudhopper.smpp.SmppSession> session(com.cloudhopper.smpp.SmppSession session)

client

public static Function<SessionStrategyTestHelper.TestContext,com.cloudhopper.smpp.SmppClient> client(int clientIndex)

client

public static Function<SessionStrategyTestHelper.TestContext,com.cloudhopper.smpp.SmppClient> client(com.cloudhopper.smpp.SmppClient client)

createdTimers

public static SessionStrategyTestHelper.Verification createdTimers(int numCreated)

createdTasks

public static SessionStrategyTestHelper.Verification createdTasks(int numCreated)

cleaned

public static SessionStrategyTestHelper.Negatable cleaned()

opened

public static SessionStrategyTestHelper.Verification opened()

closed

public static SessionStrategyTestHelper.Verification closed()

not

public static SessionStrategyTestHelper.Verification not(SessionStrategyTestHelper.Negatable verification)

stopped

public static SessionStrategyTestHelper.Verification stopped()

active

public static SessionStrategyTestHelper.Verification active()

isNull

public static SessionStrategyTestHelper.Verification isNull()

waitUntil

public static void waitUntil(Callable<Boolean> until)

enquireLinkReceived

public static Callable<Boolean> enquireLinkReceived(com.cloudhopper.smpp.SmppSession session,
                                                    int num)

enquireLinkTimeout

public static Callable<Boolean> enquireLinkTimeout(com.cloudhopper.smpp.SmppSession session)

enquireLinkFailureReceived

public static Callable<Boolean> enquireLinkFailureReceived(com.cloudhopper.smpp.SmppSession session)

clientConnected

public static Callable<Boolean> clientConnected(com.cloudhopper.smpp.SmppClient client)

reconnectionFailed

public static Callable<Boolean> reconnectionFailed(com.cloudhopper.smpp.SmppClient client,
                                                   int attempts)

expirationOfLastRequest

public static Callable<Boolean> expirationOfLastRequest(int delay)

track

public static ScheduledExecutorService track(ScheduledExecutorService tracked,
                                             List<ScheduledFuture<?>> trackedTasks,
                                             int timerIdx)

track

public static com.cloudhopper.smpp.SmppClient track(com.cloudhopper.smpp.SmppClient tracked,
                                                    List<com.cloudhopper.smpp.SmppSession> trackedSessions,
                                                    int clientIdx)

track

public static ScheduledFuture<?> track(ScheduledFuture<?> tracked,
                                       int taskIdx)

track

public static com.cloudhopper.smpp.SmppSession track(com.cloudhopper.smpp.SmppSession tracked,
                                                     int sessionIdx)