Contents

module Carrot::AMQP
  class Header
    def initialize(server, header_obj)
      @server = server
      @header = header_obj
    end

    # Acknowledges the receipt of this message with the server.
    def ack
      @server.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 = {})
      @server.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

18 entries across 18 versions & 6 rubygems

Version	Path
cwyckoff-carrot-0.6.2	lib/amqp/header.rb
famoseagle-carrot-0.3.0	lib/amqp/header.rb
famoseagle-carrot-0.4.0	lib/amqp/header.rb
famoseagle-carrot-0.5.0	lib/amqp/header.rb
famoseagle-carrot-0.6.0	lib/amqp/header.rb
famoseagle-carrot-0.7.0	lib/amqp/header.rb
maxlapshin-carrot-0.6.0	lib/amqp/header.rb
carrot-1.2.0	lib/carrot/amqp/header.rb
carrot-1.1.0	lib/carrot/amqp/header.rb
carrot-1.0.0	lib/carrot/amqp/header.rb
carrot-0.8.1	lib/amqp/header.rb
secure_carrot-0.2.0	lib/amqp/header.rb
secure_carrot-0.1.2	lib/amqp/header.rb
secure_carrot-0.1.1	lib/amqp/header.rb
secure_carrot-0.1.0	lib/amqp/header.rb
carrot-0.8.0	lib/amqp/header.rb
sa-carrot-0.7.1	lib/amqp/header.rb
carrot-0.7.0	lib/amqp/header.rb