# File lib/amq/client/async/extensions/rabbitmq/cancel.rb, line 23 def self.included receiver receiver.handle(Protocol::Basic::Cancel) do |connection, method_frame| channel = connection.channels[method_frame.channel] basic_cancel = method_frame.decode_payload consumer = channel.consumers[basic_cancel.consumer_tag] # Handle the delivery only if the consumer still exists. consumer.handle_cancel(basic_cancel) if consumer end end
Generated with the Darkfish Rdoc Generator 2.