Fixing up some un-ruby-like behaviour. Adding async and consistent_data to the message_publish. This helps combad possible deadlocks.
Adding some tests to the aggregatro related to the message_publish's consistent_data parameter.
Reviewing and removing todos.