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