more messagebus debugging
This commit is contained in:
parent
c64588a68d
commit
37b29ac3e0
1 changed files with 1 additions and 1 deletions
|
|
@ -45,7 +45,7 @@ module Messagebus
|
||||||
begin
|
begin
|
||||||
status = @client.flush
|
status = @client.flush
|
||||||
rescue Exception => e
|
rescue Exception => e
|
||||||
raise "message bus failure: #{e.message} #{@things.map{|x| x[:fromEmail]}.inspect}"
|
raise "message bus failures: #{e.message} #{@things.map{|x| x[:fromEmail]}.inspect}, #{message['from']}"
|
||||||
end
|
end
|
||||||
if status[:failureCount] && status[:failureCount] > 0
|
if status[:failureCount] && status[:failureCount] > 0
|
||||||
raise "Messagebus failure. failureCount=#{failureCount}, message=#{message.inspect}"
|
raise "Messagebus failure. failureCount=#{failureCount}, message=#{message.inspect}"
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue