lib/amq/client/async/extensions/rabbitmq/basic.rb in amq-client-1.0.4 vs lib/amq/client/async/extensions/rabbitmq/basic.rb in amq-client-1.1.0.pre1

- old
+ new

@@ -8,31 +8,12 @@ module Async module Extensions module RabbitMQ module Basic module ChannelMixin - - # Overrides {AMQ::Client::Channel#reject} behavior to use basic.nack. - # - # @api public - # @see http://www.rabbitmq.com/amqp-0-9-1-quickref.html#basic.nack - def reject(delivery_tag, requeue = true, multi = false) - if multi - @connection.send_frame(Protocol::Basic::Nack.encode(self.id, delivery_tag, multi, requeue)) - else - super(delivery_tag, requeue) - end - end # reject - end # ChannelMixin end # Basic end # RabbitMQ end # Extensions - - class Channel - # use modules, the native Ruby way of extension of existing classes, - # instead of reckless monkey-patching. MK. - include Extensions::RabbitMQ::Basic::ChannelMixin - end # Channel end # Async end # Client end # AMQ