there is a theoretical issue here

Author: SamSaffron

vendor/gems/message_bus/lib/message_bus.rb

@@ -237,7 +237,11 @@ def ensure_subscriber_thread
             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