AMQP implementations for the Synapse CQRS framework