Basic implementation of amqp broker