lib/amq/client/async/channel.rb in amq-client-0.9.0.pre2 vs lib/amq/client/async/channel.rb in amq-client-0.9.0
- old
+ new
@@ -131,21 +131,21 @@
# @group Message acknowledgements
# Acknowledge one or all messages on the channel.
#
# @api public
- # @see http://bit.ly/htCzCX AMQP 0.9.1 protocol documentation (Section 1.8.3.13.)
+ # @see http://bit.ly/amqp091reference AMQP 0.9.1 protocol reference (Section 1.8.3.13.)
def acknowledge(delivery_tag, multiple = false)
@connection.send_frame(Protocol::Basic::Ack.encode(self.id, delivery_tag, multiple))
self
end # acknowledge(delivery_tag, multiple = false)
# Reject a message with given delivery tag.
#
# @api public
- # @see http://bit.ly/htCzCX AMQP 0.9.1 protocol documentation (Section 1.8.3.14.)
+ # @see http://bit.ly/amqp091reference AMQP 0.9.1 protocol reference (Section 1.8.3.14.)
def reject(delivery_tag, requeue = true)
@connection.send_frame(Protocol::Basic::Reject.encode(self.id, delivery_tag, requeue))
self
end # reject(delivery_tag, requeue = true)
@@ -154,11 +154,11 @@
# to be redelivered.
#
# @return [Channel] self
#
# @note RabbitMQ as of 2.3.1 does not support basic.recover with requeue = false.
- # @see http://bit.ly/htCzCX AMQP 0.9.1 protocol documentation (Section 1.8.3.16.)
+ # @see http://bit.ly/amqp091reference AMQP 0.9.1 protocol reference (Section 1.8.3.16.)
# @api public
def recover(requeue = true, &block)
@connection.send_frame(Protocol::Basic::Recover.encode(@id, requeue))
self.redefine_callback :recover, &block
@@ -189,10 +189,10 @@
# this method is not intended for window control. It does not affect contents returned to
# Queue#get callers.
#
# @param [Boolean] active Desired flow state.
#
- # @see http://bit.ly/htCzCX AMQP 0.9.1 protocol documentation (Section 1.5.2.3.)
+ # @see http://bit.ly/amqp091reference AMQP 0.9.1 protocol reference (Section 1.5.2.3.)
# @api public
def flow(active = false, &block)
@connection.send_frame(Protocol::Channel::Flow.encode(@id, active))
self.redefine_callback :flow, &block