Module: AMQ::Client::Async::Extensions::RabbitMQ::Basic::ChannelMixin
- Included in:
- Channel
- Defined in:
- lib/amq/client/async/extensions/rabbitmq/basic.rb
Instance Method Summary collapse
-
#reject(delivery_tag, requeue = true, multi = false) ⇒ Object
Overrides Channel#reject behavior to use basic.nack.
Instance Method Details
#reject(delivery_tag, requeue = true, multi = false) ⇒ Object
Overrides Channel#reject behavior to use basic.nack.
18 19 20 21 22 23 24 |
# File 'lib/amq/client/async/extensions/rabbitmq/basic.rb', line 18 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 |