add amqp support