Added error handling for the amqp lib

Added error forwarding form the lib.