Sha256: 1ac30b4f3c680b03f8995fb7569ac6ade4a7bc106e539276fca55860ed9da7fd
Contents?: true
Size: 750 Bytes
Versions: 41
Compression:
Stored size: 750 Bytes
Contents
class MQ
class Header
include AMQP
def initialize(mq, header_obj)
@mq = mq
@header = header_obj
end
# Acknowledges the receipt of this message with the server.
def ack
@mq.callback{
@mq.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 = {}
@mq.callback{
@mq.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
41 entries across 41 versions & 9 rubygems