You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by cl...@apache.org on 2018/08/29 20:32:13 UTC
[1/2] activemq-artemis git commit: ARTEMIS-2063 improve logging for
address/queue deployment
Repository: activemq-artemis
Updated Branches:
refs/heads/master 218e3a97f -> 88914e9fd
ARTEMIS-2063 improve logging for address/queue deployment
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/3af9ca05
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/3af9ca05
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/3af9ca05
Branch: refs/heads/master
Commit: 3af9ca057f31e4802312b557c5f80ab1bc920bb8
Parents: 218e3a9
Author: Justin Bertram <jb...@apache.org>
Authored: Wed Aug 29 14:29:10 2018 -0500
Committer: Justin Bertram <jb...@apache.org>
Committed: Wed Aug 29 14:29:49 2018 -0500
----------------------------------------------------------------------
.../activemq/artemis/core/server/ActiveMQServerLogger.java | 8 ++++++--
.../artemis/core/server/impl/ActiveMQServerImpl.java | 3 ++-
2 files changed, 8 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3af9ca05/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/ActiveMQServerLogger.java
----------------------------------------------------------------------
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 b10d652..6aa53f6 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
@@ -94,8 +94,8 @@ public interface ActiveMQServerLogger extends BasicLogger {
void serverStopped(String version, SimpleString nodeId, String uptime);
@LogMessage(level = Logger.Level.INFO)
- @Message(id = 221003, value = "Deploying queue {0} on address {1}", format = Message.Format.MESSAGE_FORMAT)
- void deployQueue(String queueName, String addressName);
+ @Message(id = 221003, value = "Deploying {2} queue {0} on address {1}", format = Message.Format.MESSAGE_FORMAT)
+ void deployQueue(String queueName, String addressName, String routingType);
@LogMessage(level = Logger.Level.INFO)
@Message(id = 221004, value = "{0}", format = Message.Format.MESSAGE_FORMAT)
@@ -426,6 +426,10 @@ public interface ActiveMQServerLogger extends BasicLogger {
@Message(id = 221079, value = "Ignoring prepare on xid as already called : {0}", format = Message.Format.MESSAGE_FORMAT)
void ignoringPrepareOnXidAlreadyCalled(String xid);
+ @LogMessage(level = Logger.Level.INFO)
+ @Message(id = 221080, value = "Deploying address {0} supporting {1}", format = Message.Format.MESSAGE_FORMAT)
+ void deployAddress(String addressName, String routingTypes);
+
@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)
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3af9ca05/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ActiveMQServerImpl.java
----------------------------------------------------------------------
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 054006b..62d3c6e 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
@@ -2744,6 +2744,7 @@ public class ActiveMQServerImpl implements ActiveMQServer {
for (CoreAddressConfiguration config : configuration.getAddressConfigurations()) {
AddressInfo info = new AddressInfo(SimpleString.toSimpleString(config.getName()), config.getRoutingTypes());
addOrUpdateAddressInfo(info);
+ ActiveMQServerLogger.LOGGER.deployAddress(config.getName(), config.getRoutingTypes().toString());
deployQueuesFromListCoreQueueConfiguration(config.getQueueConfigurations());
}
}
@@ -2751,7 +2752,7 @@ public class ActiveMQServerImpl implements ActiveMQServer {
private void deployQueuesFromListCoreQueueConfiguration(List<CoreQueueConfiguration> queues) throws Exception {
for (CoreQueueConfiguration config : queues) {
SimpleString queueName = SimpleString.toSimpleString(config.getName());
- ActiveMQServerLogger.LOGGER.deployQueue(config.getName(), config.getAddress());
+ ActiveMQServerLogger.LOGGER.deployQueue(config.getName(), config.getAddress(), config.getRoutingType().toString());
AddressSettings as = addressSettingsRepository.getMatch(config.getAddress());
// determine if there is an address::queue match; update it if so
int maxConsumers = config.getMaxConsumers() == null ? as.getDefaultMaxConsumers() : config.getMaxConsumers();
[2/2] activemq-artemis git commit: This closes #2280
Posted by cl...@apache.org.
This closes #2280
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/88914e9f
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/88914e9f
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/88914e9f
Branch: refs/heads/master
Commit: 88914e9fd155c0a554cb368049378a69c59e1bc0
Parents: 218e3a9 3af9ca0
Author: Clebert Suconic <cl...@apache.org>
Authored: Wed Aug 29 16:27:49 2018 -0400
Committer: Clebert Suconic <cl...@apache.org>
Committed: Wed Aug 29 16:27:49 2018 -0400
----------------------------------------------------------------------
.../activemq/artemis/core/server/ActiveMQServerLogger.java | 8 ++++++--
.../artemis/core/server/impl/ActiveMQServerImpl.java | 3 ++-
2 files changed, 8 insertions(+), 3 deletions(-)
----------------------------------------------------------------------