HistoricalTest failure: Code added a task but did not wait for it to complete before proceeding. Adding a wait should solve the problem.


ReplicationTestCase.java
Added executeTask().
Used simpler InternalConnection.process*() APIs.

HistoricalTest.java:
Used ReplicationTestCase.executeTask().
Inlined local variables.
Extracted method getEntryValue().
Changed signature of publishModify().

GenerationIdTest.java:
Used ReplicationTestCase.executeTask().
Renamed assertNoMessageReceivedBadGenId() to assertNoMessageReceived().

ReplicationServerTest.java
Used ReplicationTestCase.executeTask().


TestCaseUtils.java:
Used simpler InternalConnection.process*() APIs.

UpgradeTestCase.java
Renamed isOutputContainsExpectedMessage() to assertContainsMessage().

*Test.java:
Used assertj.
Let the exceptions go up.