channel.rb in amq-client-0.9.6

- old
+ new

@@ -131,21 +131,21 @@
         # @group Message acknowledgements
 
         # Acknowledge one or all messages on the channel.
         #
         # @api public
-        # @see http://bit.ly/amqp091reference AMQP 0.9.1 protocol reference (Section 1.8.3.13.)
+        # @see files.travis-ci.org/docs/amqp/0.9.1/AMQP091Reference.pdf 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/amqp091reference AMQP 0.9.1 protocol reference (Section 1.8.3.14.)
+        # @see files.travis-ci.org/docs/amqp/0.9.1/AMQP091Reference.pdf 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/amqp091reference AMQP 0.9.1 protocol reference (Section 1.8.3.16.)
+        # @see files.travis-ci.org/docs/amqp/0.9.1/AMQP091Reference.pdf 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
@@ -179,21 +179,21 @@
         def qos(prefetch_size = 0, prefetch_count = 32, global = false, &block)
           @connection.send_frame(Protocol::Basic::Qos.encode(@id, prefetch_size, prefetch_count, global))
 
           self.redefine_callback :qos, &block
           self
-        end # qos(prefetch_size = 4096, prefetch_count = 32, global = false, &block)
+        end # qos
 
         # Asks the peer to pause or restart the flow of content data sent to a consumer.
         # This is a simple flow­control mechanism that a peer can use to avoid overflowing its
         # queues or otherwise finding itself receiving more messages than it can process. Note that
         # 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/amqp091reference AMQP 0.9.1 protocol reference (Section 1.5.2.3.)
+        # @see files.travis-ci.org/docs/amqp/0.9.1/AMQP091Reference.pdf 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
@@ -410,14 +410,9 @@
 
         # @api plugin
         # @private
         def handle_close(channel_close)
           self.status = :closed
-          # Confirm closing the channel so that the broker will actually release all resources.
-          # TODO: channel.close-ok in the Java client takes no arguments. Almost certainly
-          #       this is an issue with our code generator. MK.
-          @connection.send_frame(Protocol::Channel::CloseOk.encode(@id))
-          
           self.connection.clear_frames_on(self.id)
 
           self.exec_callback_yielding_self(:error, channel_close)
 
           self.handle_connection_interruption(channel_close)