Method: AMQ::Protocol::Basic::Cancel.encode

Defined in:
lib/amq/protocol/client.rb

.encode(channel, consumer_tag, nowait) ⇒ Object

u’consumer_tag = nil’, u’nowait = false’

Returns:



1744
1745
1746
1747
1748
1749
1750
1751
1752
 
# File 'lib/amq/protocol/client.rb', line 1744

def self.encode(channel, consumer_tag, nowait)
  buffer = @packed_indexes.dup
  buffer << consumer_tag.to_s.bytesize.chr
  buffer << consumer_tag.to_s
  bit_buffer = 0
  bit_buffer = bit_buffer | (1 << 0) if nowait
  buffer << [bit_buffer].pack(PACK_CHAR)
  MethodFrame.new(buffer, channel)
end