Method: Beetle::Message#initialize

Defined in:
lib/beetle/message.rb

#initialize(queue, header, body, opts = {}) ⇒ Message

Returns a new instance of Message.



65
66
67
68
69
70
71
 
# File 'lib/beetle/message.rb', line 65

def initialize(queue, header, body, opts = {})
  @queue  = queue
  @header = header
  @data   = body
  setup(opts)
  decode
end