From 1aa96db59431e40bbe402fd2f883ae43484e3e7f Mon Sep 17 00:00:00 2001 From: Sam Date: Wed, 3 Apr 2013 16:15:40 +1100 Subject: [PATCH] there is a theoretical issue here --- vendor/gems/message_bus/lib/message_bus.rb | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/vendor/gems/message_bus/lib/message_bus.rb b/vendor/gems/message_bus/lib/message_bus.rb index 1ba6260be..df1ec9cea 100644 --- a/vendor/gems/message_bus/lib/message_bus.rb +++ b/vendor/gems/message_bus/lib/message_bus.rb @@ -237,7 +237,11 @@ module MessageBus::Implementation locals = locals[msg.channel] if locals multi_each(globals,locals, global_globals, local_globals) do |c| - c.call msg + begin + c.call msg + rescue => e + MessageBus.logger.warn "failed to deliver message, skipping #{msg.inspect}\n ex: #{e} backtrace: #{e.backtrace}" + end end rescue => e