Class: MessageDriver::Adapters::BunnyAdapter::Message

Inherits:
Message::Base
  • Object
show all
Defined in:
lib/message_driver/adapters/bunny_adapter.rb

Instance Attribute Summary collapse

Attributes inherited from Message::Base

#body, #ctx, #destination, #headers, #properties, #raw_body

Instance Method Summary collapse

Methods inherited from Message::Base

#ack, #nack

Constructor Details

#initialize(ctx, delivery_info, properties, payload, destination) ⇒ Message

Returns a new instance of Message.



23
24
25
26
27
28
29
30
 
# File 'lib/message_driver/adapters/bunny_adapter.rb', line 23

def initialize(ctx, delivery_info, properties, payload, destination)
  raw_body = payload
  raw_headers = properties[:headers]
  raw_headers = {} if raw_headers.nil?
  b, h, p = destination.middleware.on_consume(payload, raw_headers, properties)
  super(ctx, destination, b, h, p, raw_body)
  @delivery_info = delivery_info
end

Instance Attribute Details

#delivery_info ⇒ Object (readonly)

Returns the value of attribute delivery_info.



21
22
23
 
# File 'lib/message_driver/adapters/bunny_adapter.rb', line 21

def delivery_info
  @delivery_info
end

Instance Method Details

#delivery_tag ⇒ Object 



32
33
34
 
# File 'lib/message_driver/adapters/bunny_adapter.rb', line 32

def delivery_tag
  delivery_info.delivery_tag
end

#redelivered? ⇒ Boolean

Returns:

  • (Boolean) 


36
37
38
 
# File 'lib/message_driver/adapters/bunny_adapter.rb', line 36

def redelivered?
  delivery_info.redelivered?
end