diff --git a/lib/travis/amqp/publisher.rb b/lib/travis/amqp/publisher.rb index 3eb2c2dd..ab6c1c80 100644 --- a/lib/travis/amqp/publisher.rb +++ b/lib/travis/amqp/publisher.rb @@ -25,6 +25,8 @@ def publish(data, options = {}) data = MultiJson.encode(data) exchange.publish(data, deep_merge(default_data, options)) debug "Published AMQP message to #{routing_key}." + rescue Exception => e + Amqp.logger.warn "ERROR: AMQP publish for #{routing_key} exception: #{e.message}" end protected