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 on message handler #{message_handler.inspect}.") 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

3 entries across 3 versions & 1 rubygems

Version	Path
rosetta_queue-0.5.2	lib/rosetta_queue/adapters/base.rb
rosetta_queue-0.5.0	lib/rosetta_queue/adapters/base.rb
rosetta_queue-0.4.0	lib/rosetta_queue/adapters/base.rb