Github user mtaylor commented on a diff in the pull request:
https://github.com/apache/activemq-artemis/pull/1759#discussion_r160945016
--- Diff:
artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ActiveMQServerImpl.java
---
@@ -2810,19 +2810,27 @@ public Queue createQueue(final SimpleString address,
final QueueConfig.Builder queueConfigBuilder;
- final SimpleString addressToUse = address == null ? queueName :
address;
+ RoutingType routingTypeToUse = (routingType == null ?
ActiveMQDefaultConfiguration.getDefaultRoutingType() : routingType);
--- End diff --
This logic should live in the OpenWire protocol manager.
---
