Split queue consumer contract

[samdark]

• Add QueueConsumerInterface for run/listen and remove these methods from QueueInterface
• Make the built-in queue/stub and debug proxying preserve producer vs consumer contracts
• Update console commands, tests, benchmarks, and docs for the split

Fixes #320

[codecov]

Codecov Report

❌ Patch coverage is 0% with 322 lines in your changes missing coverage. Please review.
✅ Project coverage is 0.00%. Comparing base (7e16150) to head (6106db0).

Files with missing lines	Patch %	Lines
src/Provider/QueueFactoryProvider.php	0.00%	76 Missing ⚠️
src/Provider/PredefinedQueueProvider.php	0.00%	46 Missing ⚠️
src/Provider/CompositeQueueProvider.php	0.00%	39 Missing ⚠️
src/QueueConsumer.php	0.00%	26 Missing ⚠️
src/QueueProducer.php	0.00%	25 Missing ⚠️
...ling/Implementation/ExponentialDelayMiddleware.php	0.00%	21 Missing ⚠️
...ureHandling/Implementation/SendAgainMiddleware.php	0.00%	16 Missing ⚠️
src/Debug/QueueProducerDecorator.php	0.00%	13 Missing ⚠️
src/Command/ListenAllCommand.php	0.00%	9 Missing ⚠️
...dleware/FailureHandling/FailureHandlingRequest.php	0.00%	8 Missing ⚠️
... and 11 more

Additional details and impacted files

@@           Coverage Diff            @@
##             master    #321   +/-   ##
========================================
  Coverage      0.00%   0.00%           
- Complexity      322     380   +58     
========================================
  Files            51      54    +3     
  Lines           901    1000   +99     
========================================
- Misses          901    1000   +99     

☔ View full report in Codecov by Harness.
📢 Have feedback on the report? Share it here.

🚀 New features to boost your workflow:

• ❄️ Test Analytics: Detect flaky tests, report on failures, and find test suite problems.

[Copilot]

Pull request overview

This PR splits message production vs consumption responsibilities by removing run() / listen() from QueueInterface and introducing a dedicated QueueConsumerInterface, then updates the core queue implementation, debug decorators, console commands, tests, benchmarks, and docs to match the new contracts (Fixes #320).

Changes:

• Introduce QueueConsumerInterface (run() / listen()) and remove those methods from QueueInterface.
• Update Queue, stub queue, debug provider proxy/decorators, and console commands to preserve producer-only vs consumer-capable queue contracts.
• Update unit tests, benchmarks, and documentation to reflect the split.

Reviewed changes

Copilot reviewed 20 out of 20 changed files in this pull request and generated 3 comments.

Show a summary per file

File	Description
tests/Unit/QueueTest.php	Adds contract assertions for producer vs consumer interfaces.
tests/Unit/Debug/QueueProviderInterfaceProxyTest.php	Verifies consumer-capable queues are decorated with the consumer decorator.
tests/Unit/Debug/QueueDecoratorTest.php	Updates tests to use the new consumer decorator for run()/listen().
tests/Unit/Command/RunCommandTest.php	Updates mocks to use the consumer interface and adds validation test for producer-only queues.
tests/Unit/Command/ListenCommandTest.php	Updates mocks to use the consumer interface and adds validation test for producer-only queues.
tests/Unit/Command/ListenAllCommandTest.php	Updates mocks to use the consumer interface and adds validation test for producer-only queues.
tests/Benchmark/QueueBench.php	Updates benchmark typing/usage after contract split.
stubs/StubQueue.php	Makes the stub queue implement the new consumer contract.
src/QueueInterface.php	Removes run() / listen() from the producer-facing interface.
src/QueueConsumerInterface.php	Adds the new consumer interface with run() / listen().
src/Queue.php	Declares Queue implements both producer and consumer interfaces.
src/Debug/QueueProviderInterfaceProxy.php	Returns consumer decorator when the queue supports consumption.
src/Debug/QueueDecorator.php	Removes consumption methods from the producer-only debug decorator.
src/Debug/QueueConsumerDecorator.php	Adds a decorator that preserves both producer and consumer contracts.
src/Command/RunCommand.php	Enforces that selected queues implement QueueConsumerInterface.
src/Command/ListenCommand.php	Enforces that selected queues implement QueueConsumerInterface.
src/Command/ListenAllCommand.php	Enforces that selected queues implement QueueConsumerInterface.
README.md	Documents producer vs consumer interfaces at a high level.
docs/guide/en/queue-names-advanced.md	Notes that consumer-capable queues implement QueueConsumerInterface.
docs/guide/en/configuration-manual.md	Updates manual configuration docs to use QueueConsumerInterface for consumption.

---

💡 Add Copilot custom instructions for smarter, more guided reviews. Learn how to get started.

[vjik]

What about QueueProviderInterface? If we split queue into two interfaces, then other abstractions should work with them accordingly.

[samdark]

Yeah, I can probably be done. 77b819f

[Copilot]

Pull request overview

Copilot reviewed 82 out of 82 changed files in this pull request and generated no new comments.

Suppressed comments (8)

src/Provider/CompositeQueueProvider.php:81

• Code style: } and return are on the same line. This is inconsistent with the rest of the codebase and is likely to fail PSR-12 / fixer rules.
  src/Provider/CompositeQueueProvider.php:62
• Code style: closing brace and return are on the same line, which is inconsistent with the rest of the codebase and can break code-style checks.
  src/Provider/CompositeQueueProvider.php:94
• Code style: closing brace and return are on the same line, which is inconsistent with the rest of the codebase and can break code-style checks.
  src/QueueProducer.php:65
• Log message grammar: "ID doesn't assigned" is ungrammatical and can be confusing in logs. Use "ID wasn't assigned" (or similar).
  src/Middleware/FailureHandling/Implementation/ExponentialDelayMiddleware.php:43
• Typo in exception message: "less then" should be "less than".
  tests/Unit/Middleware/Consume/ConsumeRequestTest.php:18
• $queue mock is unused (and QueueProducerInterface import becomes unused). This adds noise and can trigger static analysis warnings.
  src/Provider/CompositeQueueProvider.php:49
• Code style: } and return are on the same line. This is inconsistent with the rest of the codebase and is likely to fail PSR-12 / fixer rules.

This issue also appears in the following locations of the same file:

• line 58
• line 77
• line 91
  src/Debug/QueueProducerDecorator.php:27

• debug_backtrace() without flags captures arguments and the whole stack, which is unnecessarily expensive for a debug decorator. Also the current formatting puts statements on the same line as {, which is hard to read and may fail code style checks.

    public function status(string|int $id): MessageStatus
    { /** @psalm-var array{file: string, line: int} $stack */ $stack = debug_backtrace()[0];
        $result = $this->queue->status($id);
        $this->collector->collectStatus((string) $id, $result, $stack['file'] . ':' . $stack['line']);
        return $result;