class ActiveMessaging::Filter

Public Instance Methods

logger() click to toggle source

give filters easy access to the logger

# File lib/activemessaging/filter.rb, line 9
def logger()
  @@logger = ActiveMessaging.logger unless defined?(@@logger)
  @@logger
end
process(message, routing) click to toggle source

if you raise a StopProcessingException, it will cause this to be the last filter to be processed, and will prevent any further processing

# File lib/activemessaging/filter.rb, line 24
def process(message, routing)
  raise NotImplementedError.new("Implement the process method in your own filter class that extends ActiveMessaging::Filter")
end