Removing superfluous amqp_basic_qos() calls to address php-amqp#53

shawnvan · May 9, 2013 · 2c6df29 · 2c6df29
1 parent e785ad4
commit 2c6df29
Showing 1 changed file with 0 additions and 18 deletions.
diff --git a/amqp_queue.c b/amqp_queue.c
@@ -885,15 +885,6 @@ PHP_METHOD(amqp_queue_class, get)
 	connection = AMQP_GET_CONNECTION(channel);
 	AMQP_VERIFY_CONNECTION(connection, "Could not get messages from queue.");
 
-	/* Set the QOS for this channel to only pull off one message at a time */
-	amqp_basic_qos(
-		connection->connection_resource->connection_state,
-		channel->channel_id,
-		0,						/* prefetch window size */
-		1,						/* prefetch message count */
-		0						/* global flag */
-	);
-
 	/* Build basic.get request */
 	s.ticket = 0,
 	s.queue = amqp_cstring_bytes(queue->name);
@@ -911,15 +902,6 @@ PHP_METHOD(amqp_queue_class, get)
 	MAKE_STD_ZVAL(message);
 	read = read_message_from_channel(connection->connection_resource->connection_state, message TSRMLS_CC);
 
-	/* Set the QOS back to what the user requested at the beginning */
-	amqp_basic_qos(
-		connection->connection_resource->connection_state,
-		channel->channel_id,
-		channel->prefetch_size,		/* prefetch window size */
-		channel->prefetch_count,	/* prefetch message count */
-		0							/* global flag */
-	);
-
 	if (read == AMQP_READ_SUCCESS) {
 		COPY_PZVAL_TO_ZVAL(*return_value, message);
 	} else {