Change PublishEventListener:: to
Directly reject amqp message on read/consume error