In Files

Parent

Included Modules

MQ::Header

Public Class Methods

new(mq, header_obj) click to toggle source
# File lib/mq/header.rb, line 5
def initialize(mq, header_obj)
  @mq = mq
  @header = header_obj
end

Public Instance Methods

ack() click to toggle source

Acknowledges the receipt of this message with the server.

# File lib/mq/header.rb, line 11
def ack
  @mq.callback{
    @mq.send Protocol::Basic::Ack.new(:delivery_tag => properties[:delivery_tag])
  }
end
inspect() click to toggle source
# File lib/mq/header.rb, line 29
def inspect
  @header.inspect
end
method_missing(meth, *args, &blk) click to toggle source
# File lib/mq/header.rb, line 25
def method_missing meth, *args, &blk
  @header.send meth, *args, &blk
end
reject(opts = {}) click to toggle source

Reject this message (XXX currently unimplemented in rabbitmq)

  • :requeue => true | false (default false)

# File lib/mq/header.rb, line 19
def reject opts = {}
  @mq.callback{
    @mq.send Protocol::Basic::Reject.new(opts.merge(:delivery_tag => properties[:delivery_tag]))
  }
end

[Validate]

Generated with the Darkfish Rdoc Generator 2.