add support for AMQP reconnect