Currently AMQPEventBusConsumer will throw an exception if amqp is not available. It should retry before to mark failed the service