This is an automated email from the ASF dual-hosted git repository.
tabish pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/activemq-artemis.git
The following commit(s) were added to refs/heads/main by this push:
new 23b6be11fd ARTEMIS-5717 Minor correctness fix for handling of
temporary queues
23b6be11fd is described below
commit 23b6be11fd228f69a4855691f9763615095d0f60
Author: Timothy Bish <[email protected]>
AuthorDate: Tue Oct 28 13:56:34 2025 -0400
ARTEMIS-5717 Minor correctness fix for handling of temporary queues
Ensure the code chooses the correct routing type based on seleceted
preference.
---
.../artemis/protocol/amqp/proton/ProtonServerReceiverContext.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/proton/ProtonServerReceiverContext.java
b/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/proton/ProtonServerReceiverContext.java
index 624e0d18ae..51270c10a7 100644
---
a/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/proton/ProtonServerReceiverContext.java
+++
b/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/proton/ProtonServerReceiverContext.java
@@ -92,7 +92,7 @@ public class ProtonServerReceiverContext extends
ProtonAbstractReceiver {
try {
if (getPreferredRoutingType() == RoutingType.ANYCAST) {
- sessionSPI.createTemporaryQueue(address,
explicitRoutingType);
+ sessionSPI.createTemporaryQueue(address,
RoutingType.ANYCAST);
} else {
sessionSPI.createTemporaryAddress(address);
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
For further information, visit: https://activemq.apache.org/contact
