adding amqp functional