add amqp support.