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
# File lib/mq/header.rb, line 25 def method_missing meth, *args, &blk @header.send meth, *args, &blk end
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
Generated with the Darkfish Rdoc Generator 2.