symfony
diff --git a/‎src/Symfony/Component/Messenger/Tests/Transport/AmqpExt/ConnectionTest.php
Copy file name to clipboardExpand all lines: src/Symfony/Component/Messenger/Tests/Transport/AmqpExt/ConnectionTest.php
+18Lines changed: 18 additions & 0 deletions b/‎src/Symfony/Component/Messenger/Tests/Transport/AmqpExt/ConnectionTest.php
Copy file name to clipboardExpand all lines: src/Symfony/Component/Messenger/Tests/Transport/AmqpExt/ConnectionTest.php
+18Lines changed: 18 additions & 0 deletions
diff --git a/‎src/Symfony/Component/Messenger/Transport/AmqpExt/Connection.php
Copy file name to clipboardExpand all lines: src/Symfony/Component/Messenger/Transport/AmqpExt/Connection.php
+4-1Lines changed: 4 additions & 1 deletion b/‎src/Symfony/Component/Messenger/Transport/AmqpExt/Connection.php
Copy file name to clipboardExpand all lines: src/Symfony/Component/Messenger/Transport/AmqpExt/Connection.php
+4-1Lines changed: 4 additions & 1 deletion
@@ -233,6 +233,24 @@ public function testItCanDisableTheSetup()
         $connection = Connection::fromDsn('amqp://localhost/%2f/messages?queue[routing_key]=my_key&auto-setup=false', [], true, $factory);
         $connection->publish('body');
     }
+
+    public function testPublishWithQueueOptions()
+    {
+        $factory = new TestAmqpFactory(
+            $amqpConnection = $this->createMock(\AMQPConnection::class),
+            $amqpChannel = $this->createMock(\AMQPChannel::class),
+            $amqpQueue = $this->createMock(\AMQPQueue::class),
+            $amqpExchange = $this->createMock(\AMQPExchange::class)
+        );
+        $headers = [
+            'type' => '*',
+        ];
+        $amqpExchange->expects($this->once())->method('publish')
+            ->with('body', null, 1, ['delivery_mode' => 2, 'headers' => ['token' => 'uuid', 'type' => '*']]);
+
+        $connection = Connection::fromDsn('amqp://localhost/%2f/messages?queue[attributes][delivery_mode]=2&queue[attributes][headers][token]=uuid&queue[flags]=1', [], true, $factory);
+        $connection->publish('body', $headers);
+    }
 }
 
 class TestAmqpFactory extends AmqpFactory
 
@@ -133,7 +133,10 @@ public function publish(string $body, array $headers = []): void
             $this->setup();
         }
 
-        $this->exchange()->publish($body, $this->queueConfiguration['routing_key'] ?? null, AMQP_NOPARAM, ['headers' => $headers]);
+        $flags = $this->queueConfiguration['flags'] ?? AMQP_NOPARAM;
+        $attributes = array_merge_recursive($this->queueConfiguration['attributes'] ?? [], ['headers' => $headers]);
+
+        $this->exchange()->publish($body, $this->queueConfiguration['routing_key'] ?? null, $flags, $attributes);
     }
 
     /**
Original file line number	Diff line number	Diff line change
`@@ -133,7 +133,10 @@ public function publish(string $body, array $headers = []): void`
`133`	`133`	`$this->setup();`
`134`	`134`	`}`
`135`	`135`
`136`		`- $this->exchange()->publish($body, $this->queueConfiguration['routing_key'] ?? null, AMQP_NOPARAM, ['headers' => $headers]);`
	`136`	`+ $flags = $this->queueConfiguration['flags'] ?? AMQP_NOPARAM;`
	`137`	`+ $attributes = array_merge_recursive($this->queueConfiguration['attributes'] ?? [], ['headers' => $headers]);`
	`138`	`+`
	`139`	`+ $this->exchange()->publish($body, $this->queueConfiguration['routing_key'] ?? null, $flags, $attributes);`
`137`	`140`	`}`
`138`	`141`
`139`	`142`	`/**`