Method: AMQ::Client::Async::Consumer#unregister_with_queue

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

#unregister_with_queue ⇒ Object (protected)

register_with_channel



270
271
272
 
# File 'lib/amq/client/async/consumer.rb', line 270

def unregister_with_queue
  @queue.consumers.delete(@consumer_tag)
end