direct reply to restart

Gsantomaggio · Gsantomaggio · commit a2c861a62c7a · 2025-11-06T12:10:11.000+01:00
Signed-off-by: Gabriele Santomaggio &lt;G.santomaggio@gmail.com&gt;
diff --git a/RabbitMQ.AMQP.Client/Impl/AmqpRequester.cs b/RabbitMQ.AMQP.Client/Impl/AmqpRequester.cs
@@ -134,7 +134,7 @@ private IMessage RequestPostProcess(IMessage request, object correlationId)
             }
 
             string s = GetReplyToQueue();
-            return request.ReplyTo(s)
+            return request.ReplyTo(AddressBuilderHelper.AddressBuilder().Queue(s).Address())
                 .MessageId(correlationId);
         }
 

Original file line number	Diff line number	Diff line change
`@@ -134,7 +134,7 @@ private IMessage RequestPostProcess(IMessage request, object correlationId)`
`134`	`134`	`}`
`135`	`135`
`136`	`136`	`string s = GetReplyToQueue();`
`137`		`- return request.ReplyTo(s)`
	`137`	`+ return request.ReplyTo(AddressBuilderHelper.AddressBuilder().Queue(s).Address())`
`138`	`138`	`.MessageId(correlationId);`
`139`	`139`	`}`
`140`	`140`