RabbitMQ client connection pool implementation sample code