This is an automated email from the ASF dual-hosted git repository.
clebertsuconic pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/activemq-artemis.git
The following commit(s) were added to refs/heads/main by this push:
new f3b775aad6 ARTEMIS-5621 Adding address into logger.info
f3b775aad6 is described below
commit f3b775aad6318ce55d90fe26fc34b894ab16d591
Author: Clebert Suconic <[email protected]>
AuthorDate: Thu Aug 14 14:19:08 2025 -0400
ARTEMIS-5621 Adding address into logger.info
---
.../activemq/artemis/core/server/ActiveMQServerLogger.java | 12 ++++++------
.../apache/activemq/artemis/core/server/impl/QueueImpl.java | 6 +++---
2 files changed, 9 insertions(+), 9 deletions(-)
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 fb9683d176..1a8253d5de 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
@@ -1510,12 +1510,12 @@ public interface ActiveMQServerLogger {
@LogMessage(id = 224147, value = "Failed purging folder {}", level =
LogMessage.Level.WARN)
void failedPurgingFolder(String folder);
- @LogMessage(id = 224148, value = "Messages are being dropped on queue {}.
Queue is disabled.", level = LogMessage.Level.INFO)
- void noRouteDisabledQueue(SimpleString queueName);
+ @LogMessage(id = 224148, value = "Messages are being dropped on address {}
/ queue {}. Queue is disabled.", level = LogMessage.Level.INFO)
+ void noRouteDisabledQueue(SimpleString addressName, SimpleString queueName);
- @LogMessage(id = 224149, value = "Messages are being dropped on queue {}.
PurgeOnNoConsumers=true and there are no consumers on this queue.", level =
LogMessage.Level.INFO)
- void noRouteNoConsumers(SimpleString queueName);
+ @LogMessage(id = 224149, value = "Messages are being dropped on address {}
/ queue {}. PurgeOnNoConsumers=true and there are no consumers on this queue.",
level = LogMessage.Level.INFO)
+ void noRouteNoConsumers(SimpleString addressName, SimpleString queueName);
- @LogMessage(id = 224150, value = "Messages will be dropped on queue {}.
Queue is disabled.", level = LogMessage.Level.INFO)
- void noRouteMessagesWillBeDropped(SimpleString queueName);
+ @LogMessage(id = 224150, value = "Messages will be dropped on address {} /
queue {}. Queue is disabled.", level = LogMessage.Level.INFO)
+ void noRouteMessagesWillBeDropped(SimpleString addressName, SimpleString
queueName);
}
diff --git
a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueImpl.java
b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueImpl.java
index 9caf9c43db..aefcba2564 100644
---
a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueImpl.java
+++
b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueImpl.java
@@ -461,7 +461,7 @@ public class QueueImpl extends CriticalComponentImpl
implements Queue {
private void verifyDisabledConfiguration() {
if (noRouteLogging && !this.queueConfiguration.isEnabled()) {
-
ActiveMQServerLogger.LOGGER.noRouteMessagesWillBeDropped(this.getName());
+
ActiveMQServerLogger.LOGGER.noRouteMessagesWillBeDropped(this.getAddress(),
this.getName());
}
}
@@ -581,7 +581,7 @@ public class QueueImpl extends CriticalComponentImpl
implements Queue {
if (!queueConfiguration.isEnabled()) {
if (noRouteLogging) {
noRouteLogging = false;
- ActiveMQServerLogger.LOGGER.noRouteDisabledQueue(this.getName());
+
ActiveMQServerLogger.LOGGER.noRouteDisabledQueue(this.getAddress(),
this.getName());
}
context.setReusable(false);
return;
@@ -591,7 +591,7 @@ public class QueueImpl extends CriticalComponentImpl
implements Queue {
if (getConsumerCount() == 0) {
if (noRouteLogging) {
noRouteLogging = false;
- ActiveMQServerLogger.LOGGER.noRouteNoConsumers(this.getName());
+
ActiveMQServerLogger.LOGGER.noRouteNoConsumers(this.getAddress(),
this.getName());
}
return;
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
For further information, visit: https://activemq.apache.org/contact
