Split out segregated interface for dispatch from DBResultConsumer, shift private dispatch in MysqlConnection to use message/processor.
Pulling unnecessary calls to DBResultConsumer.setSenderCount()
Pulled default method implementations into DBResultConsumer to clean up sub-classes.
Remove questionable lock recovery feature.
Narrow WorkerGroup calls that use DBResultConsumer to tighter interface, GroupDispatch
Merge WorkerRequest and GroupDispatch at the WorkerGroup level.
Missed delegate call on recover site.
Reduce coupling in WorkerRequest instances by moving executes on WorkerStatement inside Worker.
Break some small coupling to Worker
Shift GroupDispatch to getter, rather than action
Move HA failure injection to FailingMasterMasterConnection, so SingleDirectStatement has no subclasses.
Move SingleDirectStatement into Worker.
Merge MasterMasterWorker, SingleDirectWorker, and MasterMasterConnection into Worker.
Pull WorkerFactory out of PersistentSite, merge Worker failure test related sub-classes.
Removed unused methods, variables, and reduce visibility of some items.
If there is a problem processing a source row, fail a redist immediately, rather than bubbling the failure back to the netty stack.
Convert Worker.statementExecute over to using MysqlCommandResultsProcessor rather than CompletionHandle.
Move statementExecute into WorkerRequest base class, making worker processing for statements almost line up with CommandChannel.
Pull SingleDirectConnection into Worker and start collapsing inner state.