class AMQ::Protocol::Basic::Nack
Attributes
delivery_tag[R]
multiple[R]
requeue[R]
Public Class Methods
decode(data)
click to toggle source
@return
# File lib/amq/protocol/client.rb, line 2069 def self.decode(data) offset = 0 delivery_tag = AMQ::Pack.unpack_uint64_big_endian(data[offset, 8]).first offset += 8 bit_buffer = data[offset, 1].unpack(PACK_CHAR).first offset += 1 multiple = (bit_buffer & (1 << 0)) != 0 requeue = (bit_buffer & (1 << 1)) != 0 self.new(delivery_tag, multiple, requeue) end
encode(channel, delivery_tag, multiple, requeue)
click to toggle source
@return
- u'delivery_tag = false', u'multiple = false', u'requeue = true'
# File lib/amq/protocol/client.rb, line 2093 def self.encode(channel, delivery_tag, multiple, requeue) buffer = @packed_indexes.dup buffer << AMQ::Pack.pack_uint64_big_endian(delivery_tag) bit_buffer = 0 bit_buffer = bit_buffer | (1 << 0) if multiple bit_buffer = bit_buffer | (1 << 1) if requeue buffer << [bit_buffer].pack(PACK_CHAR) MethodFrame.new(buffer, channel) end
has_content?()
click to toggle source
# File lib/amq/protocol/client.rb, line 2087 def self.has_content? false end
new(delivery_tag, multiple, requeue)
click to toggle source
# File lib/amq/protocol/client.rb, line 2081 def initialize(delivery_tag, multiple, requeue) @delivery_tag = delivery_tag @multiple = multiple @requeue = requeue end