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