Fix some warnings.
Clarify and refine log message for ZookeeperSession.
Elasticity
Minor refactor where some inner classes were moved out into their own files. Also better data-hiding in the InstanceWrapper.
Updated spring schema reference. Corrected several issues this caused. Also created a way to override the cluster check in the main integration tests but defaulted it to the current behavior.
Some test utility refactoring in preparation for elasticity tests.
Another small refactor for test utility simplification.
Stopping a session now immediately removes it from callbacks. Prior to this the stopping of a session would result in callbacks on the session that was being stopped. That behavior is odd. The FIRST thing that should happen when a session is stopped is that it will not longer receive callbacks or be able to participate in the ClusterInfo management. This changes make this the case.
Full self-contained WordCount integration test.
Remove the fixed index kryo-registration as the default Kryo-serializer configuration.
[cosmetic] remove a couple extraneous new-lines.
[fix] A bug where 2 start() calls were made on the BlockingQueueAdator resulting in a thread leak.
Add a hashCode and equals to Pair
The SenderFactory wasn't being shut down. Also, clean up the main Dempsy class a bit
A more robust LocalClusterSessionFactory.
A bunch of refactoring, plus working and tested elasticity.
[cosmetic] Largely cosmetic changes. Added a constructor to BlockingQueueAdaptor that takes the DempsyExecutor but it still doesn't do anything with it. This is for a later upgrade.
Add the ability to reset the LocalClusterSessionFactory equivalent to having shut down the zookeeper server. Use it to keep tests consistent.
Add the ability to provide blocking based backpressure to several transports. Also added naming to the DefaultDempsyExecutor threads and more tests specific to blocking in the tcp transport.
Shorten the TcpTransportTest by not running every combination for every test.