Contents

module RosettaQueue
  module Gateway

    class BaseAdapter
  
      protected

        def options_for(message_handler)
          (message_handler.options_hash) || {}
        end

        def destination_for(message_handler)
          raise DestinationNotFound.new("Missing destination!") unless message_handler.destination
          @dest ||= Destinations.lookup(message_handler.destination.to_sym)
        end
        
        def filter_receiving(msg)
          Filters.process_receiving(msg)
        end

        def filter_sending(msg)
          Filters.process_sending(msg)
        end
  
    end
  end
end

Version data entries

6 entries across 6 versions & 2 rubygems

Version	Path
bmabey-rosetta_queue-0.2.0	lib/rosetta_queue/adapters/base.rb
cwyckoff-rosetta_queue-0.1.4	lib/rosetta_queue/adapters/base.rb
cwyckoff-rosetta_queue-0.2.1	lib/rosetta_queue/adapters/base.rb
cwyckoff-rosetta_queue-0.2.2	lib/rosetta_queue/adapters/base.rb
cwyckoff-rosetta_queue-0.3.0	lib/rosetta_queue/adapters/base.rb
cwyckoff-rosetta_queue-0.3.3	lib/rosetta_queue/adapters/base.rb