diff --git a/artemis-protocols/artemis-openwire-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/openwire/amq/AMQConsumer.java b/artemis-protocols/artemis-openwire-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/openwire/amq/AMQConsumer.java index 2db8d835d0..c6ca2310ad 100644 --- a/artemis-protocols/artemis-openwire-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/openwire/amq/AMQConsumer.java +++ b/artemis-protocols/artemis-openwire-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/openwire/amq/AMQConsumer.java @@ -16,6 +16,7 @@ */ package org.apache.activemq.artemis.core.protocol.openwire.amq; +import java.lang.invoke.MethodHandles; import java.util.Comparator; import java.util.List; import java.util.Set; @@ -30,13 +31,12 @@ import java.util.concurrent.atomic.AtomicReference; import java.util.function.Function; import org.apache.activemq.advisory.AdvisorySupport; -import org.apache.activemq.artemis.api.core.ActiveMQQueueExistsException; import org.apache.activemq.artemis.api.core.ICoreMessage; import org.apache.activemq.artemis.api.core.Message; import org.apache.activemq.artemis.api.core.QueueConfiguration; -import org.apache.activemq.artemis.api.core.RoutingType; import org.apache.activemq.artemis.api.core.SimpleString; import org.apache.activemq.artemis.core.client.impl.ClientConsumerImpl; +import org.apache.activemq.artemis.core.protocol.openwire.OpenWireConstants; import org.apache.activemq.artemis.core.protocol.openwire.OpenWireMessageConverter; import org.apache.activemq.artemis.core.server.MessageReference; import org.apache.activemq.artemis.core.server.QueueQueryResult; @@ -48,7 +48,6 @@ import org.apache.activemq.artemis.core.settings.impl.AddressSettings; import org.apache.activemq.artemis.core.transaction.Transaction; import org.apache.activemq.artemis.reader.MessageUtil; import org.apache.activemq.artemis.utils.CompositeAddress; -import org.apache.activemq.artemis.core.protocol.openwire.OpenWireConstants; import org.apache.activemq.artemis.utils.SelectorTranslator; import org.apache.activemq.command.ConsumerControl; import org.apache.activemq.command.ConsumerId; @@ -60,7 +59,6 @@ import org.apache.activemq.command.MessagePull; import org.apache.activemq.command.RemoveInfo; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import java.lang.invoke.MethodHandles; import static org.apache.activemq.artemis.core.protocol.openwire.OpenWireConstants.AMQ_MSG_MESSAGE_ID; @@ -166,12 +164,6 @@ public class AMQConsumer { //only advisory topic consumers need this. ((ServerConsumerImpl)serverConsumer).setPreAcknowledge(preAck); } else { - try { - session.getCoreServer().createQueue(new QueueConfiguration(destinationName) - .setRoutingType(RoutingType.ANYCAST)); - } catch (ActiveMQQueueExistsException e) { - // ignore - } serverConsumer = session.getCoreSession().createConsumer(nativeId, destinationName, selector, info.getPriority(), info.isBrowser(), false, -1); serverConsumer.setlowConsumerDetection(slowConsumerDetectionListener); AddressSettings addrSettings = session.getCoreServer().getAddressSettingsRepository().getMatch(destinationName.toString());