public abstract class TestReplicationStateBasic extends Object
Modifier and Type | Field and Description |
---|---|
protected static String |
ID_ONE |
protected static String |
ID_TWO |
protected static String |
KEY_ONE |
protected static String |
KEY_TWO |
protected String |
OUR_ID |
protected String |
OUR_KEY |
protected ReplicationPeers |
rp |
protected ReplicationQueues |
rq1 |
protected ReplicationQueues |
rq2 |
protected ReplicationQueues |
rq3 |
protected ReplicationQueuesClient |
rqc |
protected String |
server1 |
protected String |
server2 |
protected String |
server3 |
protected static int |
ZK_MAX_COUNT |
protected static int |
ZK_SLEEP_INTERVAL |
protected static int |
zkTimeoutCount |
Constructor and Description |
---|
TestReplicationStateBasic() |
Modifier and Type | Method and Description |
---|---|
protected void |
assertConnectedPeerStatus(boolean status,
String peerId) |
protected void |
assertNumberOfPeers(int total) |
protected void |
populateQueues() |
void |
setUp() |
void |
testReplicationPeers() |
void |
testReplicationQueues() |
void |
testReplicationQueuesClient() |
protected ReplicationQueues rq1
protected ReplicationQueues rq2
protected ReplicationQueues rq3
protected ReplicationQueuesClient rqc
protected String server1
protected String server2
protected String server3
protected ReplicationPeers rp
protected static final String ID_ONE
protected static final String ID_TWO
protected static String KEY_ONE
protected static String KEY_TWO
protected String OUR_ID
protected String OUR_KEY
protected static int zkTimeoutCount
protected static final int ZK_MAX_COUNT
protected static final int ZK_SLEEP_INTERVAL
public void setUp()
public void testReplicationQueuesClient() throws ReplicationException, KeeperException
ReplicationException
KeeperException
public void testReplicationQueues() throws ReplicationException
ReplicationException
protected void assertConnectedPeerStatus(boolean status, String peerId) throws Exception
Exception
protected void assertNumberOfPeers(int total)
protected void populateQueues() throws ReplicationException
ReplicationException