class AMQ::Protocol::Basic::Ack
Attributes
delivery_tag[R]
multiple[R]
Public Class Methods
decode(data)
click to toggle source
@return
# File lib/amq/protocol/client.rb, line 1937 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 self.new(delivery_tag, multiple) end
encode(channel, delivery_tag, multiple)
click to toggle source
@return
- u'delivery_tag = false', u'multiple = false'
# File lib/amq/protocol/client.rb, line 1959 def self.encode(channel, delivery_tag, multiple) buffer = @packed_indexes.dup buffer << AMQ::Pack.pack_uint64_big_endian(delivery_tag) bit_buffer = 0 bit_buffer = bit_buffer | (1 << 0) if multiple buffer << [bit_buffer].pack(PACK_CHAR) MethodFrame.new(buffer, channel) end
has_content?()
click to toggle source
# File lib/amq/protocol/client.rb, line 1953 def self.has_content? false end
new(delivery_tag, multiple)
click to toggle source
# File lib/amq/protocol/client.rb, line 1948 def initialize(delivery_tag, multiple) @delivery_tag = delivery_tag @multiple = multiple end