com.allanbank.mongodb.client.state

Class ClusterPingerTest

java.lang.Object

com.allanbank.mongodb.client.state.ClusterPingerTest

public class ClusterPingerTest
extends Object

ClusterPingerTest provides tests for the ClusterPinger class.

Copyright ©:

2012-2014, Allanbank Consulting, Inc., All Rights Reserved

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	ClusterPingerTest.CloseAnswer<C> A specialized IAnswer to close the pinger.
class	ClusterPingerTest.CloseCallbackReply A specialized callback reply to close the pinger when a value is set.

Field Summary

Fields

Modifier and Type	Field and Description
protected ClusterPinger	myPinger The pinger being tested.

Constructor Summary

Constructors

Constructor and Description
ClusterPingerTest()

Method Summary

Methods

Modifier and Type	Method and Description
protected <C> org.easymock.IAnswer<C>	a(C reply) Creates a new CloseAnswer.
protected org.easymock.IAnswer<Connection>	a(Throwable reply) Creates a new CloseAnswer.
protected ReplyCallback	cbAndClose(DocumentBuilder... builders) Creates a new CallbackReply.
protected ReplyCallback	cbAndClose(Reply reply) Creates a new CallbackReply.
protected ReplyCallback	cbAndClose(Throwable error) Creates a new CallbackReply.
protected ReplyCallback	cbAndCloseError() Creates a new CallbackReply.
void	tearDown() Cleans up the pinger.
void	testInitialSweep() Test method for ClusterPinger.initialSweep(Cluster).
void	testInitialSweepCannotGiveBackConnection() Test method for ClusterPinger.initialSweep(Cluster).
void	testInitialSweepFails() Test method for ClusterPinger.initialSweep(Cluster).
void	testInitialSweepReplicaSet() Test method for ClusterPinger.initialSweep(Cluster).
void	testInitialSweepThrowsIOException() Test method for ClusterPinger.initialSweep(Cluster).
void	testInitialSweepThrowsMongoDdException() Test method for ClusterPinger.initialSweep(Cluster).
void	testInitialSweepWhenInterrupted() Test method for ClusterPinger.initialSweep(Cluster).
void	testRun() Test method for ClusterPinger.run().
void	testRunBadPingReply() Test method for ClusterPinger.run().
void	testRunCannotGiveConnectionBack() Test method for ClusterPinger.run().
void	testRunInThread() Test method for ClusterPinger.run().
void	testRunNoTags() Test method for ClusterPinger.run().
void	testRunPingFails() Test method for ClusterPinger.run().
void	testRunSweepTwice() Test method for ClusterPinger.run().
void	testRunSweepTwiceIdleConnection() Test method for ClusterPinger.run().
void	testRunSweepTwiceNotGiveBackConnection() Test method for ClusterPinger.run().
void	testRunThrowsIOException() Test method for ClusterPinger.run().
void	testRunThrowsMongoDbException() Test method for ClusterPinger.run().
void	testRunWhenInterrupted() Test method for ClusterPinger.run().
protected org.easymock.IAnswer<String>	throwA(Throwable reply) Creates a new CloseAnswer.

Methods inherited from class java.lang.Object

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

Field Detail

myPinger

protected ClusterPinger myPinger

The pinger being tested.

Constructor Detail

ClusterPingerTest

public ClusterPingerTest()

Method Detail

tearDown

public void tearDown()

Cleans up the pinger.

testInitialSweep

public void testInitialSweep()
                      throws IOException

Test method for ClusterPinger.initialSweep(Cluster).

Throws:

IOException - On a failure setting up the mocks.

testInitialSweepCannotGiveBackConnection

public void testInitialSweepCannotGiveBackConnection()
                                              throws IOException

Test method for ClusterPinger.initialSweep(Cluster).

Throws:

IOException - On a failure setting up the mocks.

testInitialSweepFails

public void testInitialSweepFails()
                           throws IOException

Test method for ClusterPinger.initialSweep(Cluster).

Throws:

IOException - On a failure setting up the mocks.

testInitialSweepReplicaSet

public void testInitialSweepReplicaSet()
                                throws IOException

Test method for ClusterPinger.initialSweep(Cluster).

Throws:

IOException - On a failure setting up the mocks.

testInitialSweepThrowsIOException

public void testInitialSweepThrowsIOException()
                                       throws IOException

Test method for ClusterPinger.initialSweep(Cluster).

Throws:

IOException - On a failure setting up the mocks.

testInitialSweepThrowsMongoDdException

public void testInitialSweepThrowsMongoDdException()
                                            throws IOException

Test method for ClusterPinger.initialSweep(Cluster).

Throws:

IOException - On a failure setting up the mocks.

testInitialSweepWhenInterrupted

public void testInitialSweepWhenInterrupted()
                                     throws IOException,
                                            InterruptedException

Test method for ClusterPinger.initialSweep(Cluster).

Throws:

IOException - On a failure setting up the mocks.

InterruptedException - On a failure to sleep in the test.

testRun

public void testRun()
             throws IOException

Test method for ClusterPinger.run().

Throws:

IOException - On a failure setting up the mocks.

testRunBadPingReply

public void testRunBadPingReply()
                         throws IOException

Test method for ClusterPinger.run().

Throws:

IOException - On a failure setting up the mocks.

testRunCannotGiveConnectionBack

public void testRunCannotGiveConnectionBack()
                                     throws IOException,
                                            InterruptedException

Test method for ClusterPinger.run().

Throws:

IOException - On a failure setting up the mocks.

InterruptedException - On a failure to sleep.

testRunInThread

public void testRunInThread()
                     throws IOException,
                            InterruptedException

Test method for ClusterPinger.run().

Throws:

IOException - On a failure setting up the mocks.

InterruptedException - On a failure to sleep.

testRunNoTags

public void testRunNoTags()
                   throws IOException

Test method for ClusterPinger.run().

Throws:

IOException - On a failure setting up the mocks.

testRunPingFails

public void testRunPingFails()
                      throws IOException

Test method for ClusterPinger.run().

Throws:

IOException - On a failure setting up the mocks.

testRunSweepTwice

public void testRunSweepTwice()
                       throws IOException,
                              InterruptedException

Test method for ClusterPinger.run().

Throws:

IOException - On a failure setting up the mocks.

InterruptedException - On a failure to sleep.

testRunSweepTwiceIdleConnection

public void testRunSweepTwiceIdleConnection()
                                     throws IOException,
                                            InterruptedException

Test method for ClusterPinger.run().

Throws:

IOException - On a failure setting up the mocks.

InterruptedException - On a failure to sleep.

testRunSweepTwiceNotGiveBackConnection

public void testRunSweepTwiceNotGiveBackConnection()
                                            throws IOException,
                                                   InterruptedException

Test method for ClusterPinger.run().

Throws:

IOException - On a failure setting up the mocks.

InterruptedException - On a failure to sleep.

testRunThrowsIOException

public void testRunThrowsIOException()
                              throws IOException

Test method for ClusterPinger.run().

Throws:

IOException - On a failure setting up the mocks.

testRunThrowsMongoDbException

public void testRunThrowsMongoDbException()
                                   throws IOException

Test method for ClusterPinger.run().

Throws:

IOException - On a failure setting up the mocks.

testRunWhenInterrupted

public void testRunWhenInterrupted()
                            throws IOException,
                                   InterruptedException

Test method for ClusterPinger.run().

Throws:

IOException - On a failure setting up the mocks.

InterruptedException - On a failure to sleep.

a

protected <C> org.easymock.IAnswer<C> a(C reply)

Creates a new CloseAnswer.

Parameters:

reply - The reply to return.

Returns:

The CloseAnswer.

a

protected org.easymock.IAnswer<Connection> a(Throwable reply)

Creates a new CloseAnswer.

Parameters:

reply - The reply to throw.

Returns:

The CloseAnswer.

cbAndClose

protected ReplyCallback cbAndClose(DocumentBuilder... builders)

Creates a new CallbackReply.

Parameters:

builders - The reply to provide to the callback.

Returns:

The CallbackReply.

cbAndClose

protected ReplyCallback cbAndClose(Reply reply)

Creates a new CallbackReply.

Parameters:

reply - The reply to provide to the callback.

Returns:

The CallbackReply.

cbAndClose

protected ReplyCallback cbAndClose(Throwable error)

Creates a new CallbackReply.

Parameters:

error - The error to provide to the callback.

Returns:

The CallbackReply.

cbAndCloseError

protected ReplyCallback cbAndCloseError()

Creates a new CallbackReply.

Returns:

The CallbackReply.

throwA

protected org.easymock.IAnswer<String> throwA(Throwable reply)

Creates a new CloseAnswer.

Parameters:

reply - The reply to throw.

Returns:

The CloseAnswer.