From dce2a192952b88ab8b9f5bf75156498b3e9f604a Mon Sep 17 00:00:00 2001 From: Viktor Smagin Date: Tue, 23 Jun 2026 13:15:57 +0400 Subject: [PATCH] Queue auto-delete configuration support --- src/Command/Consume.php | 6 ++++-- src/Dto/ConsumerParameters.php | 2 ++ 2 files changed, 6 insertions(+), 2 deletions(-) diff --git a/src/Command/Consume.php b/src/Command/Consume.php index 7ec28d8..cc3c4ab 100644 --- a/src/Command/Consume.php +++ b/src/Command/Consume.php @@ -24,7 +24,7 @@ class Consume extends Command /** * @var string */ - protected $signature = 'rabbitmq:consume {--connection=} {--queue=} {--exchange=} {--exchange-type=} {--exchange-is-default} {--routing-key=} {--tag=}'; + protected $signature = 'rabbitmq:consume {--connection=} {--queue=} {--queue-auto-delete} {--exchange=} {--exchange-type=} {--exchange-is-default} {--routing-key=} {--tag=}'; /** * @var string @@ -99,7 +99,9 @@ class Consume extends Command { return new Queue( name: $params->queue->value() ?? 'default', - declaration: new QueueDeclaration(), + declaration: new QueueDeclaration( + autoDelete: $params->queueAutoDelete->toBool() + ), bindings: new QueueBindings($params->routingKey->toString()), ); } diff --git a/src/Dto/ConsumerParameters.php b/src/Dto/ConsumerParameters.php index bced2ba..df93e04 100644 --- a/src/Dto/ConsumerParameters.php +++ b/src/Dto/ConsumerParameters.php @@ -10,6 +10,7 @@ use Diffhead\PHP\Dto\Property; /** * @property \Diffhead\PHP\Dto\Property $connection * @property \Diffhead\PHP\Dto\Property $queue + * @property \Diffhead\PHP\Dto\Property $queueAutoDelete * @property \Diffhead\PHP\Dto\Property $exchange * @property \Diffhead\PHP\Dto\Property $routingKey * @property \Diffhead\PHP\Dto\Property $exchangeType @@ -20,6 +21,7 @@ class ConsumerParameters extends Dto { protected Property $connection; protected Property $queue; + protected Property $queueAutoDelete; protected Property $exchange; protected Property $routingKey; protected Property $exchangeType;