fixed broken amqp interfaces