refactory to use connection_pooling for rabbitmq