module ActiveSupport::Notifications::Fanout::Subscribers

def self.wrap_all(pattern, subscriber)
  unless pattern
    AllMessages.new(subscriber)
  else
    subscriber
  end
end