Github user gtully commented on a diff in the pull request:
https://github.com/apache/activemq-artemis/pull/1759#discussion_r162117583
--- Diff:
artemis-protocols/artemis-openwire-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/openwire/amq/AMQSession.java
---
@@ -194,7 +195,14 @@ private boolean checkAutoCreateQueue(SimpleString
queueName, boolean isTemporary
try {
if (!queueBinding.isExists()) {
if (bindingQuery.isAutoCreateQueues()) {
- server.createQueue(queueName, RoutingType.ANYCAST,
queueName, null, true, isTemporary);
+ SimpleString queueNameToUse = queueName;
+ SimpleString addressToUse = queueName;
+ if
(CompositeAddress.isFullyQualified(queueName.toString())) {
+ CompositeAddress compositeAddress =
CompositeAddress.getQueueName(queueName.toString());
+ addressToUse = new
SimpleString(compositeAddress.getAddress());
+ queueNameToUse = new
SimpleString(compositeAddress.getQueueName());
+ }
--- End diff --
adding the logic to figure the routingType as the path of least resistance
and the most explicit. The null routing type autocreateaddress case does not
work in createQueue - maybe that is an indication that the relevant code can be
removed.
---
