PubSub event bus over amqp