diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/ActiveMQServerLogger.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/ActiveMQServerLogger.java index c21bfc1b74..f7038fb9e9 100644 --- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/ActiveMQServerLogger.java +++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/ActiveMQServerLogger.java @@ -305,6 +305,10 @@ public interface ActiveMQServerLogger extends BasicLogger { @Message(id = 221051, value = "Populating security roles from LDAP at: {0}", format = Message.Format.MESSAGE_FORMAT) void populatingSecurityRolesFromLDAP(String url); + @LogMessage(level = Logger.Level.INFO) + @Message(id = 221052, value = "trying to deploy topic {0}", format = Message.Format.MESSAGE_FORMAT) + void deployTopic(SimpleString topicName); + @LogMessage(level = Logger.Level.WARN) @Message(id = 222000, value = "ActiveMQServer is being finalized and has not been stopped. Please remember to stop the server before letting it go out of scope", format = Message.Format.MESSAGE_FORMAT) diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ActiveMQServerImpl.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ActiveMQServerImpl.java index 4963ed8489..8c4b7bd7a8 100644 --- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ActiveMQServerImpl.java +++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ActiveMQServerImpl.java @@ -1276,13 +1276,19 @@ public class ActiveMQServerImpl implements ActiveMQServer { @Override public Queue deployQueue(final SimpleString address, - final SimpleString queueName, + final SimpleString resourceName, final SimpleString filterString, final boolean durable, final boolean temporary) throws Exception { - ActiveMQServerLogger.LOGGER.deployQueue(queueName); - return createQueue(address, queueName, filterString, null, durable, temporary, true, false, false); + if (resourceName.toString().toLowerCase().startsWith("jms.topic")) { + ActiveMQServerLogger.LOGGER.deployTopic(resourceName); + } + else { + ActiveMQServerLogger.LOGGER.deployQueue(resourceName); + } + + return createQueue(address, resourceName, filterString, null, durable, temporary, true, false, false); } @Override