pika_mq_consumer
