Re-implement short circuiting via side channel sending of batches

[lbradstreet]

Keep the rest of the messaging code the same, but stick the batches themselves in a hashmap, and just send the id of the batches to the subscriber.

[lbradstreet]

Done!