[consumption] add already_ack result, queue consumer does nothing on it.

Author: makasim

pkg/enqueue/Consumption/QueueConsumer.php

@@ -274,6 +274,8 @@ public function consume(ExtensionInterface $runtimeExtension = null): void
                 case Result::REQUEUE:
                     $consumer->reject($message, true);
                     break;
+                case Result::ALREADY_ACKNOWLEDGED:
+                    break;
                 default:
                     throw new \LogicException(sprintf('Status is not supported: %s', $result));
             }

pkg/enqueue/Consumption/Result.php

@@ -22,6 +22,8 @@ class Result
      */
     const REQUEUE = Processor::REQUEUE;
 
+    const ALREADY_ACKNOWLEDGED = 'enqueue.already_acknowledged';
+
     /**
      * @var string
      */

pkg/enqueue/Tests/Consumption/QueueConsumerTest.php

@@ -470,6 +470,40 @@ public function testShouldRejectMessageIfProcessorReturnSuchStatus()
         $queueConsumer->consume();
     }
 
+    public function testShouldDoNothingIfProcessorReturnsAlreadyAcknowledged()
+    {
+        $messageMock = $this->createMessageMock();
+
+        $subscriptionConsumerMock = new DummySubscriptionConsumer();
+        $subscriptionConsumerMock->addMessage($messageMock, 'foo_queue');
+
+        $consumerStub = $this->createConsumerStub('foo_queue');
+        $consumerStub
+            ->expects($this->never())
+            ->method('reject')
+        ;
+        $consumerStub
+            ->expects($this->never())
+            ->method('acknowledge')
+        ;
+
+        $contextStub = $this->createContextStub($consumerStub);
+
+        $processorMock = $this->createProcessorMock();
+        $processorMock
+            ->expects($this->once())
+            ->method('process')
+            ->with($this->identicalTo($messageMock))
+            ->willReturn(Result::ALREADY_ACKNOWLEDGED)
+        ;
+
+        $queueConsumer = new QueueConsumer($contextStub, new BreakCycleExtension(1));
+        $queueConsumer->setFallbackSubscriptionConsumer($subscriptionConsumerMock);
+        $queueConsumer->bind(new NullQueue('foo_queue'), $processorMock);
+
+        $queueConsumer->consume();
+    }
+
     public function testShouldRequeueMessageIfProcessorReturnSuchStatus()
     {
         $messageMock = $this->createMessageMock();