Method: AMQ::Client::Async::Consumer#register_with_channel

Defined in:
lib/amq/client/async/consumer.rb

#register_with_channel ⇒ Object (protected) 



258
259
260
 
# File 'lib/amq/client/async/consumer.rb', line 258

def register_with_channel
  @channel.consumers[@consumer_tag] = self
end