Message metadata (aka envelope).
Acknowledges the receipt of this message with the server. @param [Boolean] multiple Whether or not to acknowledge multiple messages @api public
# File lib/amqp/header.rb, line 33 def ack(multiple = false) @channel.acknowledge(@method.delivery_tag, multiple) end
# File lib/amqp/header.rb, line 54 def consumer_tag @method.consumer_tag end
# File lib/amqp/header.rb, line 83 def content_type @attributes[:content_type] end
# File lib/amqp/header.rb, line 103 def correlation_id @attributes[:correlation_id] end
# File lib/amqp/header.rb, line 79 def delivery_mode @attributes[:delivery_mode] end
# File lib/amqp/header.rb, line 50 def delivery_tag @method.delivery_tag end
# File lib/amqp/header.rb, line 66 def exchange @method.exchange end
@deprecated
# File lib/amqp/header.rb, line 71 def header @attributes end
# File lib/amqp/header.rb, line 75 def headers @attributes[:headers] end
# File lib/amqp/header.rb, line 107 def message_id @attributes[:message_id] end
Returns AMQP message attributes. @api public
# File lib/amqp/header.rb, line 114 def method_missing(meth, *args, &blk) if @attributes && args.empty? && blk.nil? && @attributes.has_key?(meth) @attributes[meth] else @method.__send__(meth, *args, &blk) end end
# File lib/amqp/header.rb, line 95 def priority @attributes[:priority] end
# File lib/amqp/header.rb, line 58 def redelivered @method.redelivered end
# File lib/amqp/header.rb, line 62 def redelivered? @method.redelivered end
Reject this message. @option opts [Hash] :requeue (false) Whether message should be requeued. @api public
# File lib/amqp/header.rb, line 40 def reject(opts = {}) @channel.reject(@method.delivery_tag, opts.fetch(:requeue, false)) end
# File lib/amqp/header.rb, line 99 def reply_to @attributes[:reply_to] end
# File lib/amqp/header.rb, line 87 def timestamp @attributes[:timestamp] end
@return [Hash] AMQP message header w/o method-specific information. @api public
# File lib/amqp/header.rb, line 46 def to_hash @attributes end
Generated with the Darkfish Rdoc Generator 2.