Contents

class Bunny
	class Header
	
		include AMQP
	
		attr_reader :client
	
	  def initialize(client, header_obj)
	    @client = client
	    @header = header_obj
	  end

	  # Acknowledges the receipt of this message with the server.
	  def ack
	    client.send(Protocol::Basic::Ack.new(:delivery_tag => properties[:delivery_tag]))
	  end

	  # Reject this message (XXX currently unimplemented in rabbitmq)
	  # * :requeue => true | false (default false)
	  def reject(opts = {})
	    client.send(Protocol::Basic::Reject.new(opts.merge(:delivery_tag => properties[:delivery_tag])))
	  end

	  def method_missing(meth, *args, &blk)
	    @header.send(meth, *args, &blk)
	  end

	  def inspect
	    @header.inspect
	  end
	end
end

Version data entries

6 entries across 6 versions & 2 rubygems

Version	Path
celldee-bunny-0.0.9	lib/bunny/header.rb
celldee-bunny-0.1.0	lib/bunny/header.rb
celldee-bunny-0.1.1	lib/bunny/header.rb
bunny-0.0.9	lib/bunny/header.rb
bunny-0.1.0	lib/bunny/header.rb
bunny-0.1.1	lib/bunny/header.rb