Class: Lapine::Consumer::Message

Inherits:
Hash
  • Object
show all
Defined in:
lib/lapine/consumer/message.rb

Instance Method Summary collapse

Constructor Details

#initialize(payload, metadata, logger) ⇒ Message

Returns a new instance of Message.


4
5
6
7
8
9
 
# File 'lib/lapine/consumer/message.rb', line 4

def initialize(payload, metadata, logger)
  super(nil)
  self['payload'] = payload
  self['metadata'] = metadata
  self['logger'] = logger
end

Instance Method Details

#decoded_payload ⇒ Object 


15
16
17
 
# File 'lib/lapine/consumer/message.rb', line 15

def decoded_payload
  self['decoded_payload']
end

#logger ⇒ Object 


23
24
25
 
# File 'lib/lapine/consumer/message.rb', line 23

def logger
  self['logger']
end

#metadata ⇒ Object 


19
20
21
 
# File 'lib/lapine/consumer/message.rb', line 19

def metadata
  self['metadata']
end

#payload ⇒ Object 


11
12
13
 
# File 'lib/lapine/consumer/message.rb', line 11

def payload
  self['payload']
end

#routing_key ⇒ Object 


27
28
29
 
# File 'lib/lapine/consumer/message.rb', line 27

def routing_key
  metadata.routing_key
end