integrate with amqp server.