Method: AMQ::Client::Async::Consumer#handle_cancel_ok

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

#handle_cancel_ok(cancel_ok) ⇒ Object

handle_consume_ok(consume_ok)



213
214
215
216
217
218
219
220
221
222
 
# File 'lib/amq/client/async/consumer.rb', line 213

def handle_cancel_ok(cancel_ok)
  @consumer_tag = nil

  # detach from object graph so that this object will be garbage-collected
  @queue        = nil
  @channel      = nil
  @connection   = nil

  self.exec_callback_once(:cancel, cancel_ok)
end