Class/Module Index [+]

Quicksearch

AMQ::Client::Async::Extensions::RabbitMQ::Basic::ConsumerMixin

Public Class Methods

included(receiver) click to toggle source
# 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

Public Instance Methods

handle_cancel(basic_cancel) click to toggle source
# File lib/amq/client/async/extensions/rabbitmq/cancel.rb, line 19
def handle_cancel(basic_cancel)
  self.exec_callback(:scancel, basic_cancel)
end
on_cancel(&block) click to toggle source
# File lib/amq/client/async/extensions/rabbitmq/cancel.rb, line 13
def on_cancel(&block)
  self.append_callback(:scancel, &block)

  self
end

[Validate]

Generated with the Darkfish Rdoc Generator 2.