Contents

module RosettaQueue
  module MessageHandler
    
    module ClassMethods

      attr_reader :destination, :options_hash

      def options(options = {})
        @options_hash = options
      end

      def publishes_to(destination)
        @destination = destination
      end

      def subscribes_to(destination)
        @destination = destination
      end
    end
    
    def self.included(receiver)
      receiver.extend(ClassMethods)

      def destination
        self.class.destination  
      end
      
      def options_hash
        self.class.options_hash
      end
    end
  end
end

Version data entries

7 entries across 7 versions & 2 rubygems

Version	Path
bmabey-rosetta_queue-0.1.3	lib/rosetta_queue/message_handler.rb
bmabey-rosetta_queue-0.2.0	lib/rosetta_queue/message_handler.rb
cwyckoff-rosetta_queue-0.1.4	lib/rosetta_queue/message_handler.rb
cwyckoff-rosetta_queue-0.2.0	lib/rosetta_queue/message_handler.rb
cwyckoff-rosetta_queue-0.2.1	lib/rosetta_queue/message_handler.rb
cwyckoff-rosetta_queue-0.2.2	lib/rosetta_queue/message_handler.rb
cwyckoff-rosetta_queue-0.3.0	lib/rosetta_queue/message_handler.rb