Consumer fix: reject message from queue and do not requeue when retur…

…ning IConsumer::MESSAGE_REJECT
contributte · Jul 12, 2017 · d07c9a0 · d07c9a0
1 parent cf7a6be
commit d07c9a0
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/Consumer/Consumer.php b/src/Consumer/Consumer.php
@@ -72,7 +72,7 @@ function (Message $message, Channel $channel, Client $client): void {
 						break;
 
 					case IConsumer::MESSAGE_REJECT:
-						$channel->reject($message); // Message will be discarded
+						$channel->reject($message, FALSE); // Message will be discarded
 						break;
 
 					default:
@@ -108,7 +108,7 @@ public function consumeSpecifiedAmountOfMessages(int $amountOfMessages): void
 					break;
 
 				case IConsumer::MESSAGE_REJECT:
-					$channel->reject($message); // Message will be discarded
+					$channel->reject($message, FALSE); // Message will be discarded
 					break;
 
 				default: