A reactive messaging library based on the AMQP protocol - View it on GitHub