class MessageDriver::Adapters::BunnyAdapter::Message

Attributes

delivery_info[R]

Public Class Methods

new(ctx, delivery_info, properties, payload, destination) click to toggle source
Calls superclass method MessageDriver::Message::Base::new
# 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

Public Instance Methods

delivery_tag() click to toggle source
# File lib/message_driver/adapters/bunny_adapter.rb, line 32
def delivery_tag
  delivery_info.delivery_tag
end
redelivered?() click to toggle source
# File lib/message_driver/adapters/bunny_adapter.rb, line 36
def redelivered?
  delivery_info.redelivered?
end