replaced amqplib + custom extension with amqp from Celery project