Method: AMQ::Client::Async::Consumer#unregister_with_channel
- Defined in:
- lib/amq/client/async/consumer.rb
#unregister_with_channel ⇒ Object (protected)
register_with_queue
266 267 268 |
# File 'lib/amq/client/async/consumer.rb', line 266 def unregister_with_channel @channel.consumers.delete(@consumer_tag) end |