try {
final RemoteCounter remoteCounter = context.lookupStateful(DDBasedClusteredSFSB.class, RemoteCounter.class);
// invoke on the bean a few times
final int NUM_TIMES = 25;
for (int i = 0; i < NUM_TIMES; i++) {
final CounterResult result = remoteCounter.increment();
logger.info("Counter incremented to " + result.getCount() + " on node " + result.getNodeName());
}
final CounterResult result = remoteCounter.getCount();
Assert.assertNotNull("Result from remote stateful counter was null", result);
Assert.assertEquals("Unexpected count from remote counter", NUM_TIMES, result.getCount());
// shutdown the node on which the previous invocation happened
final int totalCountBeforeShuttingDownANode = result.getCount();
final String previousInvocationNodeName = result.getNodeName();
// the value is configured in arquillian.xml of the project
if (previousInvocationNodeName.equals("node-udp-0")) {
this.deployer.undeploy(DEPLOYMENT_1);
this.container.stop(CONTAINER_1);
container1Stopped = true;
} else {
this.deployer.undeploy(DEPLOYMENT_2);
this.container.stop(CONTAINER_2);
container2Stopped = true;
}
// invoke again
CounterResult resultAfterShuttingDownANode = remoteCounter.increment();
Assert.assertNotNull("Result from remote stateful counter, after shutting down a node was null", resultAfterShuttingDownANode);
Assert.assertEquals("Unexpected count from remote counter, after shutting down a node", totalCountBeforeShuttingDownANode + 1, resultAfterShuttingDownANode.getCount());
Assert.assertFalse("Result was received from an unexpected node, after shutting down a node", previousInvocationNodeName.equals(resultAfterShuttingDownANode.getNodeName()));
// repeat invocations
final int countBeforeDecrementing = resultAfterShuttingDownANode.getCount();
final String aliveNode = resultAfterShuttingDownANode.getNodeName();
for (int i = NUM_TIMES; i > 0; i--) {
resultAfterShuttingDownANode = remoteCounter.decrement();
Assert.assertNotNull("Result from remote stateful counter, after shutting down a node was null", resultAfterShuttingDownANode);
Assert.assertEquals("Result was received from an unexpected node, after shutting down a node", aliveNode, resultAfterShuttingDownANode.getNodeName());
logger.info("Counter decremented to " + resultAfterShuttingDownANode.getCount() + " on node " + resultAfterShuttingDownANode.getNodeName());
}
final CounterResult finalResult = remoteCounter.getCount();
Assert.assertNotNull("Result from remote stateful counter, after shutting down a node was null", finalResult);
final int finalCount = finalResult.getCount();
final String finalNodeName = finalResult.getNodeName();
Assert.assertEquals("Result was received from an unexpected node, after shutting down a node", aliveNode, finalNodeName);
Assert.assertEquals("Unexpected count from remote counter, after shutting down a node", countBeforeDecrementing - NUM_TIMES, finalCount);
} finally {
// reset the selector
if (previousSelector != null) {