Contents

module MessageQueue
  class Message
    attr_reader :attributes, :message_id, :type, :payload, :timestamp, :routing_key

    def initialize(attributes = {})
      @attributes = attributes
      @message_id = attributes[:message_id]
      @type = attributes[:type]
      @payload = attributes[:payload]
      @timestamp = attributes[:timestamp]
      @routing_key = attributes[:routing_key]
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
message_queue-0.1.1	lib/message_queue/message.rb
message_queue-0.1.0	lib/message_queue/message.rb