AMQP message broker implementation in Go