This is an automated email from the ASF dual-hosted git repository.
robbie 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 734e7f4ae5 ARTEMIS-3950: dont prepare unused debug detail during xml
data import processing
734e7f4ae5 is described below
commit 734e7f4ae52215566f4d51b2be2f62f810f63ab0
Author: Robbie Gemmell <[email protected]>
AuthorDate: Mon Aug 22 16:10:28 2022 +0100
ARTEMIS-3950: dont prepare unused debug detail during xml data import
processing
---
.../cli/commands/tools/xml/XmlDataImporter.java | 26 +++++++++++++---------
1 file changed, 16 insertions(+), 10 deletions(-)
diff --git
a/artemis-cli/src/main/java/org/apache/activemq/artemis/cli/commands/tools/xml/XmlDataImporter.java
b/artemis-cli/src/main/java/org/apache/activemq/artemis/cli/commands/tools/xml/XmlDataImporter.java
index 027db44cb3..efbadbd494 100644
---
a/artemis-cli/src/main/java/org/apache/activemq/artemis/cli/commands/tools/xml/XmlDataImporter.java
+++
b/artemis-cli/src/main/java/org/apache/activemq/artemis/cli/commands/tools/xml/XmlDataImporter.java
@@ -291,11 +291,14 @@ public final class XmlDataImporter extends ActionAbstract
{
}
private void sendMessage(List<String> queues, Message message, File
tempFileName) throws Exception {
- StringBuilder logMessage = new StringBuilder();
- String destination = addressMap.get(queues.get(0));
+ final String destination = addressMap.get(queues.get(0));
+ final ByteBuffer buffer = ByteBuffer.allocate(queues.size() * 8);
- logMessage.append("Sending ").append(message).append(" to address:
").append(destination).append("; routed to queues: ");
- ByteBuffer buffer = ByteBuffer.allocate(queues.size() * 8);
+ final boolean debugLog = logger.isDebugEnabled();
+ final StringBuilder debugLogMessage = debugLog ? new StringBuilder() :
null;
+ if (debugLog) {
+ debugLogMessage.append("Sending ").append(message).append(" to
address: ").append(destination).append("; routed to queues: ");
+ }
for (String queue : queues) {
long queueID;
@@ -310,26 +313,29 @@ public final class XmlDataImporter extends ActionAbstract
{
ClientMessage managementMessage =
managementSession.createMessage(false);
ManagementHelper.putAttribute(managementMessage,
ResourceNames.QUEUE + queue, "ID");
managementSession.start();
- if (logger.isDebugEnabled()) {
+ if (debugLog) {
logger.debug("Requesting ID for: " + queue);
}
ClientMessage reply = requestor.request(managementMessage);
Number idObject = (Number) ManagementHelper.getResult(reply);
queueID = idObject.longValue();
}
- if (logger.isDebugEnabled()) {
+
+ if (debugLog) {
logger.debug("ID for " + queue + " is: " + queueID);
}
queueIDs.put(queue, queueID); // store it so we don't have to
look it up every time
}
- logMessage.append(queue).append(", ");
buffer.putLong(queueID);
+ if (debugLog) {
+ debugLogMessage.append(queue).append(", ");
+ }
}
- logMessage.delete(logMessage.length() - 2, logMessage.length()); // take
off the trailing comma
- if (logger.isDebugEnabled()) {
- logger.debug(logMessage);
+ if (debugLog) {
+ debugLogMessage.delete(debugLogMessage.length() - 2,
debugLogMessage.length()); // take off the trailing comma+space
+ logger.debug(debugLogMessage.toString());
}
message.putBytesProperty(Message.HDR_ROUTE_TO_IDS, buffer.array());