class Queight::Metadata
Provides interface like AMQP::Header
Public Class Methods
new(channel, delivery_info, properties)
click to toggle source
# File lib/queight/metadata.rb, line 4 def initialize(channel, delivery_info, properties) @channel = channel @delivery_info = delivery_info @properties = properties end
Public Instance Methods
ack()
click to toggle source
# File lib/queight/metadata.rb, line 10 def ack @channel.acknowledge(@delivery_info.delivery_tag) end
redelivered?()
click to toggle source
# File lib/queight/metadata.rb, line 19 def redelivered? @delivery_info.redelivered? end
reject(options = {})
click to toggle source
# File lib/queight/metadata.rb, line 14 def reject(options = {}) requeue = options.fetch(:requeue, false) @channel.reject(@delivery_info.delivery_tag, requeue) end