lib/rosetta_queue/adapters/base.rb in bmabey-rosetta_queue-0.2.0 vs lib/rosetta_queue/adapters/base.rb in bmabey-rosetta_queue-0.3.3

- old
+ new

@@ -1,27 +1,27 @@ 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