You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by jb...@apache.org on 2021/03/20 16:15:55 UTC
[activemq] branch activemq-5.15.x updated: Fix slf4j logger use
This is an automated email from the ASF dual-hosted git repository.
jbonofre pushed a commit to branch activemq-5.15.x
in repository https://gitbox.apache.org/repos/asf/activemq.git
The following commit(s) were added to refs/heads/activemq-5.15.x by this push:
new c6f66b5 Fix slf4j logger use
c6f66b5 is described below
commit c6f66b535ffcd6f8eb79da0ad15710e61e2b3fc0
Author: jbonofre <jb...@apache.org>
AuthorDate: Sat Mar 20 10:58:07 2021 +0100
Fix slf4j logger use
(cherry picked from commit 1a2de52c5f580c24590c706fcf3b6fc61dc88379)
---
.../org/apache/activemq/broker/BrokerService.java | 81 ++++++++++---------
.../activemq/broker/ProducerBrokerExchange.java | 15 ++--
.../activemq/broker/TransportConnection.java | 30 +++++---
.../activemq/broker/region/AbstractRegion.java | 20 +++--
.../broker/region/PrefetchSubscription.java | 8 +-
.../org/apache/activemq/broker/region/Queue.java | 40 ++++++----
.../activemq/broker/region/RegionBroker.java | 6 +-
.../apache/activemq/broker/region/TempQueue.java | 5 +-
.../org/apache/activemq/broker/region/Topic.java | 5 +-
.../activemq/broker/region/TopicSubscription.java | 15 ++--
.../region/cursors/FilePendingMessageCursor.java | 11 ++-
.../cursors/StoreDurableSubscriberCursor.java | 3 +-
.../policy/AbortSlowAckConsumerStrategy.java | 5 +-
.../region/policy/AbortSlowConsumerStrategy.java | 12 +--
.../policy/PriorityNetworkDispatchPolicy.java | 12 +--
.../activemq/broker/scheduler/SchedulerBroker.java | 13 ++--
.../activemq/broker/util/LoggingBrokerPlugin.java | 3 +-
.../activemq/broker/util/RedeliveryPlugin.java | 5 +-
.../broker/util/TimeStampingBrokerPlugin.java | 3 +-
.../ConditionalNetworkBridgeFilterFactory.java | 13 ++--
.../org/apache/activemq/network/ConduitBridge.java | 15 ++--
.../network/DemandForwardingBridgeSupport.java | 90 +++++++++-------------
.../network/DiscoveryNetworkConnector.java | 4 +-
.../activemq/network/LdapNetworkConnector.java | 8 +-
.../activemq/network/jms/DestinationBridge.java | 2 +-
.../apache/activemq/network/jms/JmsConnector.java | 2 +-
.../security/SimpleCachedLDAPAuthorizationMap.java | 16 ++--
27 files changed, 225 insertions(+), 217 deletions(-)
diff --git a/activemq-broker/src/main/java/org/apache/activemq/broker/BrokerService.java b/activemq-broker/src/main/java/org/apache/activemq/broker/BrokerService.java
index f74f257..ef1a876 100644
--- a/activemq-broker/src/main/java/org/apache/activemq/broker/BrokerService.java
+++ b/activemq-broker/src/main/java/org/apache/activemq/broker/BrokerService.java
@@ -284,7 +284,7 @@ public class BrokerService implements Service {
} else {
ret = Security.addProvider(bouncycastle);
}
- LOG.info("Loaded the Bouncy Castle security provider at position: " + ret);
+ LOG.info("Loaded the Bouncy Castle security provider at position: {}", ret);
} catch(Throwable e) {
// No BouncyCastle found so we use the default Java Security Provider
}
@@ -306,7 +306,7 @@ public class BrokerService implements Service {
}
}
} catch (IOException ie) {
- LOG.warn("Error reading broker version ", ie);
+ LOG.warn("Error reading broker version", ie);
}
BROKER_VERSION = version;
}
@@ -648,7 +648,7 @@ public class BrokerService implements Service {
stop();
}
} catch (Exception ex) {
- LOG.warn("Failed to stop broker after failure in start. This exception will be ignored.", ex);
+ LOG.warn("Failed to stop broker after failure in start. This exception will be ignored", ex);
}
throw e;
} finally {
@@ -749,7 +749,7 @@ public class BrokerService implements Service {
brokerId = broker.getBrokerId();
// need to log this after creating the broker so we have its id and name
- LOG.info("Apache ActiveMQ {} ({}, {}) is starting", new Object[]{ getBrokerVersion(), getBrokerName(), brokerId });
+ LOG.info("Apache ActiveMQ {} ({}, {}) is starting", getBrokerVersion(), getBrokerName(), brokerId);
broker.start();
if (isUseJmx()) {
@@ -776,7 +776,7 @@ public class BrokerService implements Service {
startAllConnectors();
- LOG.info("Apache ActiveMQ {} ({}, {}) started", new Object[]{ getBrokerVersion(), getBrokerName(), brokerId});
+ LOG.info("Apache ActiveMQ {} ({}, {}) started", getBrokerVersion(), getBrokerName(), brokerId);
LOG.info("For help or more information please see: http://activemq.apache.org");
getBroker().brokerServiceStarted();
@@ -839,7 +839,7 @@ public class BrokerService implements Service {
}.start();
}
- LOG.info("Apache ActiveMQ {} ({}, {}) is shutting down", new Object[]{ getBrokerVersion(), getBrokerName(), brokerId} );
+ LOG.info("Apache ActiveMQ {} ({}, {}) is shutting down", getBrokerVersion(), getBrokerName(), brokerId);
removeShutdownHook();
if (this.scheduler != null) {
@@ -899,9 +899,9 @@ public class BrokerService implements Service {
this.destinationFactory = null;
if (startDate != null) {
- LOG.info("Apache ActiveMQ {} ({}, {}) uptime {}", new Object[]{ getBrokerVersion(), getBrokerName(), brokerId, getUptime()});
+ LOG.info("Apache ActiveMQ {} ({}, {}) uptime {}", getBrokerVersion(), getBrokerName(), brokerId, getUptime());
}
- LOG.info("Apache ActiveMQ {} ({}, {}) is shutdown", new Object[]{ getBrokerVersion(), getBrokerName(), brokerId});
+ LOG.info("Apache ActiveMQ {} ({}, {}) is shutdown", getBrokerVersion(), getBrokerName(), brokerId);
synchronized (shutdownHooks) {
for (Runnable hook : shutdownHooks) {
@@ -963,9 +963,8 @@ public class BrokerService implements Service {
if (pollInterval <= 0) {
pollInterval = 30;
}
- LOG.info("Stop gracefully with connectorName: {} queueName: {} timeout: {} pollInterval: {}", new Object[]{
- connectorName, queueName, timeout, pollInterval
- });
+ LOG.info("Stop gracefully with connectorName: {} queueName: {} timeout: {} pollInterval: {}",
+ connectorName, queueName, timeout, pollInterval);
TransportConnector connector;
for (int i = 0; i < transportConnectors.size(); i++) {
connector = transportConnectors.get(i);
@@ -2050,10 +2049,8 @@ public class BrokerService implements Service {
}
if (storeLimit > 0 && storeLimit < maxJournalFileSize) {
- LOG.error("Store limit is " + storeLimit / (1024 * 1024) +
- " mb, whilst the max journal file size for the store is: " +
- maxJournalFileSize / (1024 * 1024) + " mb, " +
- "the store will not accept any data when used.");
+ LOG.error("Store limit is {} mb, whilst the max journal file size for the store is {} mb, the store will not accept any data when used.",
+ (storeLimit / (1024 * 1024)), (maxJournalFileSize / (1024 * 1024)));
}
}
@@ -2083,10 +2080,8 @@ public class BrokerService implements Service {
long storeLimit = usage.getTempUsage().getLimit();
if (storeLimit > 0 && storeLimit < maxJournalFileSize) {
- LOG.error("Temporary Store limit is " + storeLimit / (1024 * 1024) +
- " mb, whilst the max journal file size for the temporary store is: " +
- maxJournalFileSize / (1024 * 1024) + " mb, " +
- "the temp store will not accept any data when used.");
+ LOG.error("Temporary Store limit {} mb, whilst the max journal file size for the temporary store is {} mb, the temp store will not accept any data when used.",
+ (storeLimit / (1024 * 1024)), (maxJournalFileSize / (1024 * 1024)));
}
}
}
@@ -2101,8 +2096,8 @@ public class BrokerService implements Service {
long totalSpace = storeUsage.getTotal() > 0 ? storeUsage.getTotal() : dir.getTotalSpace();
long totalUsableSpace = (storeUsage.getTotal() > 0 ? storeUsage.getTotal() : dir.getUsableSpace()) + storeCurrent;
if (totalUsableSpace < 0 || totalSpace < 0) {
+ LOG.error("File system space reported by {} was negative, possibly a huge file system, set a sane usage.total to provide some guidance", dir);
final String message = "File system space reported by: " + dir + " was negative, possibly a huge file system, set a sane usage.total to provide some guidance";
- LOG.error(message);
throw new ConfigurationException(message);
}
//compute byte value of the percent limit
@@ -2123,11 +2118,11 @@ public class BrokerService implements Service {
//To prevent changing too often, check threshold
if (newLimit - storeLimit >= diskUsageCheckRegrowThreshold) {
- LOG.info("Usable disk space has been increased, attempting to regrow " + storeName + " limit to "
- + percentLimit + "% of the partition size.");
+ LOG.info("Usable disk space has been increased, attempting to regrow {} limit to {}% of the parition size",
+ storeName, percentLimit);
storeUsage.setLimit(newLimit);
- LOG.info(storeName + " limit has been increased to " + newLimit * 100 / totalSpace
- + "% (" + newLimit / oneMeg + " mb) of the partition size.");
+ LOG.info("{} limit has been increase to {}% ({} mb) of the partition size.",
+ (newLimit * 100 / totalSpace), (newLimit / oneMeg));
}
//check if the limit is too large for the amount of usable space
@@ -2144,16 +2139,17 @@ public class BrokerService implements Service {
}
if (percentLimit > 0) {
- LOG.warn(storeName + " limit has been set to "
- + percentLimit + "% (" + bytePercentLimit / oneMeg + " mb)"
- + " of the partition size but there is not enough usable space."
- + " The current store limit (which may have been adjusted by a"
- + " previous usage limit check) is set to (" + storeLimit / oneMeg + " mb)"
- + " but only " + totalUsableSpace * 100 / totalSpace + "% (" + totalUsableSpace / oneMeg + " mb)"
- + " is available - resetting limit");
+ LOG.warn("{} limit has been set to {}% ({} mb) of the partition size but there is not enough usable space." +
+ "The current store limit (which may have been adjusted by a previous usage limit check) is set to ({} mb) " +
+ "but only {}% ({} mb) is available - resetting limit",
+ storeName,
+ percentLimit,
+ (bytePercentLimit / oneMeg),
+ (storeLimit / oneMeg),
+ (totalUsableSpace * 100 / totalSpace),
+ (totalUsableSpace / oneMeg));
} else {
- LOG.warn(message + " - resetting to maximum available disk space: " +
- totalUsableSpace / oneMeg + " mb");
+ LOG.warn("{} - resetting to maximum available disk space: {} mb", message, (totalUsableSpace / oneMeg));
}
storeUsage.setLimit(totalUsableSpace);
}
@@ -2199,7 +2195,8 @@ public class BrokerService implements Service {
if (adjustUsageLimits) {
usage.getMemoryUsage().setPercentOfJvmHeap(70);
- LOG.warn(message + " mb - resetting to 70% of maximum available: " + (usage.getMemoryUsage().getLimit() / (1024 * 1024)) + " mb");
+ LOG.warn("{} mb - resetting to 70% of maximum available: {}",
+ message, (usage.getMemoryUsage().getLimit() / (1024 * 1024)));
} else {
LOG.error(message);
throw new ConfigurationException(message);
@@ -2233,10 +2230,12 @@ public class BrokerService implements Service {
long schedulerLimit = usage.getJobSchedulerUsage().getLimit();
long dirFreeSpace = schedulerDir.getUsableSpace();
if (schedulerLimit > dirFreeSpace) {
- LOG.warn("Job Scheduler Store limit is " + schedulerLimit / (1024 * 1024) +
- " mb, whilst the data directory: " + schedulerDir.getAbsolutePath() +
- " only has " + dirFreeSpace / (1024 * 1024) + " mb of usable space - resetting to " +
- dirFreeSpace / (1024 * 1024) + " mb.");
+ LOG.warn("Job Scheduler Store limit is {} mb, whilst the data directory: {} " +
+ "only has {} mb of usage space - resetting to {} mb.",
+ schedulerLimit / (1024 * 1024),
+ schedulerDir.getAbsolutePath(),
+ dirFreeSpace / (1024 * 1024),
+ dirFreeSpace / (1042 * 1024));
usage.getJobSchedulerUsage().setLimit(dirFreeSpace);
}
}
@@ -2328,7 +2327,7 @@ public class BrokerService implements Service {
ObjectName objectName = createNetworkConnectorObjectName(connector);
getManagementContext().unregisterMBean(objectName);
} catch (Exception e) {
- LOG.warn("Network Connector could not be unregistered from JMX due " + e.getMessage() + ". This exception is ignored.", e);
+ LOG.warn("Network Connector could not be unregistered from JMX due {}. This exception is ignored.", e.getMessage(), e);
}
}
}
@@ -2412,7 +2411,7 @@ public class BrokerService implements Service {
regionBroker = new ManagedRegionBroker(this, getManagementContext(), getBrokerObjectName(),
getTaskRunnerFactory(), getConsumerSystemUsage(), destinationFactory, destinationInterceptor,getScheduler(),getExecutor());
} catch(MalformedObjectNameException me){
- LOG.warn("Cannot create ManagedRegionBroker due " + me.getMessage(), me);
+ LOG.warn("Cannot create ManagedRegionBroker due {}", me.getMessage(), me);
throw new IOException(me);
}
} else {
@@ -2603,7 +2602,7 @@ public class BrokerService implements Service {
protected void logError(String message, Throwable e) {
if (useLoggingForShutdownErrors) {
- LOG.error("Failed to shut down: " + e);
+ LOG.error("Failed to shut down", e);
} else {
System.err.println("Failed to shut down: " + e);
}
diff --git a/activemq-broker/src/main/java/org/apache/activemq/broker/ProducerBrokerExchange.java b/activemq-broker/src/main/java/org/apache/activemq/broker/ProducerBrokerExchange.java
index 99b766b..a216c44 100644
--- a/activemq-broker/src/main/java/org/apache/activemq/broker/ProducerBrokerExchange.java
+++ b/activemq-broker/src/main/java/org/apache/activemq/broker/ProducerBrokerExchange.java
@@ -144,20 +144,17 @@ public class ProducerBrokerExchange {
long lastStoredForMessageProducer = getStoredSequenceIdForMessage(messageSend.getMessageId());
if (producerSequenceId <= lastStoredForMessageProducer) {
canDispatch = false;
- LOG.warn("suppressing duplicate message send [{}] from network producer with producerSequence [{}] less than last stored: {}", new Object[]{
- (LOG.isTraceEnabled() ? messageSend : messageSend.getMessageId()), producerSequenceId, lastStoredForMessageProducer
- });
+ LOG.warn("suppressing duplicate message send [{}] from network producer with producerSequence [{}] less than last stored: {}",
+ (LOG.isTraceEnabled() ? messageSend : messageSend.getMessageId()), producerSequenceId, lastStoredForMessageProducer);
}
} else if (producerSequenceId <= lastSendSequenceNumber.get()) {
canDispatch = false;
if (messageSend.isInTransaction()) {
- LOG.warn("suppressing duplicated message send [{}] with producerSequenceId [{}] <= last stored: {}", new Object[]{
- (LOG.isTraceEnabled() ? messageSend : messageSend.getMessageId()), producerSequenceId, lastSendSequenceNumber
- });
+ LOG.warn("suppressing duplicated message send [{}] with producerSequenceId [{}] <= last stored: {}",
+ (LOG.isTraceEnabled() ? messageSend : messageSend.getMessageId()), producerSequenceId, lastSendSequenceNumber);
} else {
- LOG.debug("suppressing duplicated message send [{}] with producerSequenceId [{}] <= last stored: {}", new Object[]{
- (LOG.isTraceEnabled() ? messageSend : messageSend.getMessageId()), producerSequenceId, lastSendSequenceNumber
- });
+ LOG.debug("suppressing duplicated message send [{}] with producerSequenceId [{}] <= last stored: {}",
+ (LOG.isTraceEnabled() ? messageSend : messageSend.getMessageId()), producerSequenceId, lastSendSequenceNumber);
}
} else {
diff --git a/activemq-broker/src/main/java/org/apache/activemq/broker/TransportConnection.java b/activemq-broker/src/main/java/org/apache/activemq/broker/TransportConnection.java
index d242ef7..1b8d859 100644
--- a/activemq-broker/src/main/java/org/apache/activemq/broker/TransportConnection.java
+++ b/activemq-broker/src/main/java/org/apache/activemq/broker/TransportConnection.java
@@ -238,9 +238,9 @@ public class TransportConnection implements Connection, Task, CommandVisitor {
if (!stopping.get() && status.get() != PENDING_STOP) {
transportException.set(e);
if (TRANSPORTLOG.isDebugEnabled()) {
- TRANSPORTLOG.debug(this + " failed: " + e, e);
+ TRANSPORTLOG.debug("{} failed: {}", this, e.getMessage(), e);
} else if (TRANSPORTLOG.isWarnEnabled() && !expected(e)) {
- TRANSPORTLOG.warn(this + " failed: " + e);
+ TRANSPORTLOG.warn("{} failed", this, e);
}
stopAsync(e);
}
@@ -308,9 +308,9 @@ public class TransportConnection implements Connection, Task, CommandVisitor {
inServiceException = true;
try {
if (SERVICELOG.isDebugEnabled()) {
- SERVICELOG.debug("Async error occurred: " + e, e);
+ SERVICELOG.debug("Async error occurred: {}", e.getMessage(), e);
} else {
- SERVICELOG.warn("Async error occurred: " + e);
+ SERVICELOG.warn("Async error occurred", e);
}
ConnectionError ce = new ConnectionError();
ce.setException(e);
@@ -339,12 +339,15 @@ public class TransportConnection implements Connection, Task, CommandVisitor {
}
} catch (Throwable e) {
if (SERVICELOG.isDebugEnabled() && e.getClass() != BrokerStoppedException.class) {
- SERVICELOG.debug("Error occured while processing " + (responseRequired ? "sync" : "async")
- + " command: " + command + ", exception: " + e, e);
+ SERVICELOG.debug("Error occurred while processing {} command: {}, exception: {}",
+ (responseRequired ? "sync" : "async"),
+ command,
+ e.getMessage(),
+ e);
}
if (e instanceof SuppressReplyException || (e.getCause() instanceof SuppressReplyException)) {
- LOG.info("Suppressing reply to: " + command + " on: " + e + ", cause: " + e.getCause());
+ LOG.info("Suppressing reply to: {} on: {}, cause: {}", command, e, e.getCause());
responseRequired = false;
}
@@ -382,7 +385,7 @@ public class TransportConnection implements Connection, Task, CommandVisitor {
if (brokerService.isRollbackOnlyOnAsyncException() && !(e instanceof IOException) && isInTransaction(command)) {
Transaction transaction = getActiveTransaction(command);
if (transaction != null && !transaction.isRollbackOnly()) {
- LOG.debug("on async exception, force rollback of transaction for: " + command, e);
+ LOG.debug("on async exception, force rollback of transaction for: {}", command, e);
transaction.setRollbackOnly(e);
}
}
@@ -404,7 +407,7 @@ public class TransportConnection implements Connection, Task, CommandVisitor {
}
}
} catch(Exception ignored){
- LOG.trace("failed to find active transaction for command: " + command, ignored);
+ LOG.trace("failed to find active transaction for command: {}", command, ignored);
}
return transaction;
}
@@ -819,7 +822,8 @@ public class TransportConnection implements Connection, Task, CommandVisitor {
}
}
registerConnectionState(info.getConnectionId(), state);
- LOG.debug("Setting up new connection id: {}, address: {}, info: {}", new Object[]{ info.getConnectionId(), getRemoteAddress(), info });
+ LOG.debug("Setting up new connection id: {}, address: {}, info: {}",
+ info.getConnectionId(), getRemoteAddress(), info);
this.faultTolerantConnection = info.isFaultTolerant();
// Setup the context.
String clientId = info.getClientId();
@@ -852,7 +856,8 @@ public class TransportConnection implements Connection, Task, CommandVisitor {
brokerConnectionStates.remove(info.getConnectionId());
}
unregisterConnectionState(info.getConnectionId());
- LOG.warn("Failed to add Connection id={}, clientId={}, clientIP={} due to {}", info.getConnectionId(), clientId, info.getClientIp(), e.getLocalizedMessage());
+ LOG.warn("Failed to add Connection id={}, clientId={}, clientIP={} due to {}",
+ info.getConnectionId(), clientId, info.getClientIp(), e.getLocalizedMessage());
//AMQ-6561 - stop for all exceptions on addConnection
// close this down - in case the peer of this transport doesn't play nice
delayedStop(2000, "Failed with SecurityException: " + e.getLocalizedMessage(), e);
@@ -987,7 +992,8 @@ public class TransportConnection implements Connection, Task, CommandVisitor {
throw e;
} else {
if (TRANSPORTLOG.isDebugEnabled()) {
- TRANSPORTLOG.debug("Unexpected exception on asyncDispatch, command of type: " + command.getDataStructureType(), e);
+ TRANSPORTLOG.debug("Unexpected exception on asyncDispatch, command of type: {}",
+ command.getDataStructureType(), e);
}
}
} finally {
diff --git a/activemq-broker/src/main/java/org/apache/activemq/broker/region/AbstractRegion.java b/activemq-broker/src/main/java/org/apache/activemq/broker/region/AbstractRegion.java
index 8dcb76c..2985ccd 100644
--- a/activemq-broker/src/main/java/org/apache/activemq/broker/region/AbstractRegion.java
+++ b/activemq-broker/src/main/java/org/apache/activemq/broker/region/AbstractRegion.java
@@ -245,8 +245,8 @@ public abstract class AbstractRegion implements Region {
rc.add(sub);
} catch (SecurityException e) {
if (sub.isWildcard()) {
- LOG.debug("Subscription denied for " + sub + " to destination " +
- dest.getActiveMQDestination() + ": " + e.getMessage());
+ LOG.debug("Subscription denied for {} to destination {}: {}",
+ sub, dest.getActiveMQDestination(), e.getMessage());
} else {
throw e;
}
@@ -338,7 +338,8 @@ public abstract class AbstractRegion implements Region {
@Override
@SuppressWarnings("unchecked")
public Subscription addConsumer(ConnectionContext context, ConsumerInfo info) throws Exception {
- LOG.debug("{} adding consumer: {} for destination: {}", new Object[]{ broker.getBrokerName(), info.getConsumerId(), info.getDestination() });
+ LOG.debug("{} adding consumer: {} for destination: {}",
+ broker.getBrokerName(), info.getConsumerId(), info.getDestination());
ActiveMQDestination destination = info.getDestination();
if (destination != null && !destination.isPattern() && !destination.isComposite()) {
// lets auto-create the destination
@@ -406,15 +407,16 @@ public abstract class AbstractRegion implements Region {
removeList.add(dest);
} catch (SecurityException e){
if (sub.isWildcard()) {
- LOG.debug("Subscription denied for " + sub + " to destination " +
- dest.getActiveMQDestination() + ": " + e.getMessage());
+ LOG.debug("Subscription denied for {} to destination {}: {}",
+ sub, dest.getActiveMQDestination(), e.getMessage());
} else {
// remove partial subscriptions
for (Destination remove : removeList) {
try {
remove.removeSubscription(context, sub, info.getLastDeliveredSequenceId());
} catch (Exception ex) {
- LOG.error("Error unsubscribing " + sub + " from " + remove + ": " + ex.getMessage(), ex);
+ LOG.error("Error unsubscribing {} from {}: {}",
+ sub, remove, ex.getMessage(), ex);
}
}
subscriptions.remove(info.getConsumerId());
@@ -460,7 +462,8 @@ public abstract class AbstractRegion implements Region {
@Override
@SuppressWarnings("unchecked")
public void removeConsumer(ConnectionContext context, ConsumerInfo info) throws Exception {
- LOG.debug("{} removing consumer: {} for destination: {}", new Object[]{ broker.getBrokerName(), info.getConsumerId(), info.getDestination() });
+ LOG.debug("{} removing consumer: {} for destination: {}",
+ broker.getBrokerName(), info.getConsumerId(), info.getDestination());
Subscription sub = subscriptions.remove(info.getConsumerId());
// The sub could be removed elsewhere - see ConnectionSplitBroker
@@ -685,7 +688,8 @@ public abstract class AbstractRegion implements Region {
entry.configurePrefetch(sub);
}
}
- LOG.debug("setting prefetch: {}, on subscription: {}; resulting value: {}", new Object[]{ control.getPrefetch(), control.getConsumerId(), sub.getConsumerInfo().getPrefetchSize()});
+ LOG.debug("setting prefetch: {}, on subscription: {}; resulting value: {}",
+ control.getPrefetch(), control.getConsumerId(), sub.getConsumerInfo().getPrefetchSize());
try {
lookup(consumerExchange.getConnectionContext(), control.getDestination(),false).wakeup();
} catch (Exception e) {
diff --git a/activemq-broker/src/main/java/org/apache/activemq/broker/region/PrefetchSubscription.java b/activemq-broker/src/main/java/org/apache/activemq/broker/region/PrefetchSubscription.java
index 83136f2..7f7ce74 100644
--- a/activemq-broker/src/main/java/org/apache/activemq/broker/region/PrefetchSubscription.java
+++ b/activemq-broker/src/main/java/org/apache/activemq/broker/region/PrefetchSubscription.java
@@ -720,7 +720,9 @@ public abstract class PrefetchSubscription extends AbstractSubscription {
if (node != QueueMessageReference.NULL_MESSAGE) {
nodeDest.getDestinationStatistics().getDispatched().increment();
incrementPrefetchCounter(node);
- LOG.trace("{} failed to dispatch: {} - {}, dispatched: {}, inflight: {}", new Object[]{ info.getConsumerId(), message.getMessageId(), message.getDestination(), getSubscriptionStatistics().getDispatched().getCount(), dispatched.size() });
+ LOG.trace("{} failed to dispatch: {} - {}, dispatched: {}, inflight: {}",
+ info.getConsumerId(), message.getMessageId(), message.getDestination(),
+ getSubscriptionStatistics().getDispatched().getCount(), dispatched.size());
}
}
if (node instanceof QueueMessageReference) {
@@ -742,7 +744,9 @@ public abstract class PrefetchSubscription extends AbstractSubscription {
if (node != QueueMessageReference.NULL_MESSAGE) {
nodeDest.getDestinationStatistics().getDispatched().increment();
incrementPrefetchCounter(node);
- LOG.trace("{} dispatched: {} - {}, dispatched: {}, inflight: {}", new Object[]{ info.getConsumerId(), message.getMessageId(), message.getDestination(), getSubscriptionStatistics().getDispatched().getCount(), dispatched.size() });
+ LOG.trace("{} dispatched: {} - {}, dispatched: {}, inflight: {}",
+ info.getConsumerId(), message.getMessageId(), message.getDestination(),
+ getSubscriptionStatistics().getDispatched().getCount(), dispatched.size());
}
}
diff --git a/activemq-broker/src/main/java/org/apache/activemq/broker/region/Queue.java b/activemq-broker/src/main/java/org/apache/activemq/broker/region/Queue.java
index 86471ec..f30c446 100644
--- a/activemq-broker/src/main/java/org/apache/activemq/broker/region/Queue.java
+++ b/activemq-broker/src/main/java/org/apache/activemq/broker/region/Queue.java
@@ -219,7 +219,7 @@ public class Queue extends BaseDestination implements Task, UsageListener, Index
}
}
} catch (InterruptedException e) {
- LOG.debug(getName() + "Producer Flow Control Timeout Task is stopping");
+ LOG.debug("{} Producer Flow Control Timeout Task is stopping", getName());
}
}
}
@@ -289,7 +289,9 @@ public class Queue extends BaseDestination implements Task, UsageListener, Index
public boolean recoverMessage(Message message) {
recoveredAccumulator++;
if ((recoveredAccumulator % 10000) == 0) {
- LOG.info("cursor for {} has recovered {} messages. {}% complete", new Object[]{ getActiveMQDestination().getQualifiedName(), recoveredAccumulator, new Integer((int) (recoveredAccumulator * 100 / totalMessageCount))});
+ LOG.info("cursor for {} has recovered {} messages. {}% complete",
+ getActiveMQDestination().getQualifiedName(), recoveredAccumulator,
+ new Integer((int) (recoveredAccumulator * 100 / totalMessageCount)));
}
// Message could have expired while it was being
// loaded..
@@ -408,7 +410,12 @@ public class Queue extends BaseDestination implements Task, UsageListener, Index
@Override
public void addSubscription(ConnectionContext context, Subscription sub) throws Exception {
- LOG.debug("{} add sub: {}, dequeues: {}, dispatched: {}, inflight: {}", new Object[]{ getActiveMQDestination().getQualifiedName(), sub, getDestinationStatistics().getDequeues().getCount(), getDestinationStatistics().getDispatched().getCount(), getDestinationStatistics().getInflight().getCount() });
+ LOG.debug("{} add sub: {}, dequeues: {}, dispatched: {}, inflight: {}",
+ getActiveMQDestination().getQualifiedName(),
+ sub,
+ getDestinationStatistics().getDequeues().getCount(),
+ getDestinationStatistics().getDispatched().getCount(),
+ getDestinationStatistics().getInflight().getCount());
super.addSubscription(context, sub);
// synchronize with dispatch method so that no new messages are sent
@@ -1191,7 +1198,8 @@ public class Queue extends BaseDestination implements Task, UsageListener, Index
messagesLock.readLock().unlock();
}
- LOG.trace("max {}, alreadyPagedIn {}, messagesCount {}, memoryUsage {}%", new Object[]{max, alreadyPagedIn, messagesInQueue, memoryUsage.getPercentUsage()});
+ LOG.trace("max {}, alreadyPagedIn {}, messagesCount {}, memoryUsage {}%",
+ max, alreadyPagedIn, messagesInQueue, memoryUsage.getPercentUsage());
return (alreadyPagedIn == 0 || (alreadyPagedIn < max)
&& (alreadyPagedIn < messagesInQueue)
&& messages.hasSpace());
@@ -1892,7 +1900,7 @@ public class Queue extends BaseDestination implements Task, UsageListener, Index
}finally {
consumersLock.readLock().unlock();
}
- LOG.debug("{} Message {} sent to {}", new Object[]{ broker.getBrokerName(), msg.getMessageId(), this.destination });
+ LOG.debug("{} Message {} sent to {}",broker.getBrokerName(), msg.getMessageId(), this.destination);
wakeup();
}
@@ -1964,18 +1972,16 @@ public class Queue extends BaseDestination implements Task, UsageListener, Index
if (LOG.isDebugEnabled()) {
LOG.debug("{} toPageIn: {}, force:{}, Inflight: {}, pagedInMessages.size {}, pagedInPendingDispatch.size {}, enqueueCount: {}, dequeueCount: {}, memUsage:{}, maxPageSize:{}",
- new Object[]{
- this,
- toPageIn,
- force,
- destinationStatistics.getInflight().getCount(),
- pagedInMessages.size(),
- pagedInPendingSize,
- destinationStatistics.getEnqueues().getCount(),
- destinationStatistics.getDequeues().getCount(),
- getMemoryUsage().getUsage(),
- maxPageSize
- });
+ this,
+ toPageIn,
+ force,
+ destinationStatistics.getInflight().getCount(),
+ pagedInMessages.size(),
+ pagedInPendingSize,
+ destinationStatistics.getEnqueues().getCount(),
+ destinationStatistics.getDequeues().getCount(),
+ getMemoryUsage().getUsage(),
+ maxPageSize);
}
if (toPageIn > 0 && (force || (haveRealConsumer() && pagedInPendingSize < maxPageSize))) {
diff --git a/activemq-broker/src/main/java/org/apache/activemq/broker/region/RegionBroker.java b/activemq-broker/src/main/java/org/apache/activemq/broker/region/RegionBroker.java
index 32efab4..e1dd52e 100644
--- a/activemq-broker/src/main/java/org/apache/activemq/broker/region/RegionBroker.java
+++ b/activemq-broker/src/main/java/org/apache/activemq/broker/region/RegionBroker.java
@@ -577,7 +577,8 @@ public class RegionBroker extends EmptyBroker {
brokerInfos.put(info.getBrokerId(), existing);
}
existing.incrementRefCount();
- LOG.debug("{} addBroker: {} brokerInfo size: {}", new Object[]{ getBrokerName(), info.getBrokerName(), brokerInfos.size() });
+ LOG.debug("{} addBroker: {} brokerInfo size: {}",
+ getBrokerName(), info.getBrokerName(), brokerInfos.size());
addBrokerInClusterUpdate(info);
}
@@ -588,7 +589,8 @@ public class RegionBroker extends EmptyBroker {
if (existing != null && existing.decrementRefCount() == 0) {
brokerInfos.remove(info.getBrokerId());
}
- LOG.debug("{} removeBroker: {} brokerInfo size: {}", new Object[]{ getBrokerName(), info.getBrokerName(), brokerInfos.size()});
+ LOG.debug("{} removeBroker: {} brokerInfo size: {}",
+ getBrokerName(), info.getBrokerName(), brokerInfos.size());
// When stopping don't send cluster updates since we are the one's tearing down
// our own bridges.
if (!brokerService.isStopping()) {
diff --git a/activemq-broker/src/main/java/org/apache/activemq/broker/region/TempQueue.java b/activemq-broker/src/main/java/org/apache/activemq/broker/region/TempQueue.java
index 8138277..17eeb05 100644
--- a/activemq-broker/src/main/java/org/apache/activemq/broker/region/TempQueue.java
+++ b/activemq-broker/src/main/java/org/apache/activemq/broker/region/TempQueue.java
@@ -84,7 +84,10 @@ public class TempQueue extends Queue{
@Override
public void dispose(ConnectionContext context) throws IOException {
if (this.destinationStatistics.getMessages().getCount() > 0) {
- LOG.info("{} on dispose, purge of {} pending messages: {}", new Object[]{ getActiveMQDestination().getQualifiedName(), this.destinationStatistics.getMessages().getCount(), messages });
+ LOG.info("{} on dispose, purge of {} pending messages: {}",
+ getActiveMQDestination().getQualifiedName(),
+ this.destinationStatistics.getMessages().getCount(),
+ messages);
// we may want to capture these message ids in an advisory
}
try {
diff --git a/activemq-broker/src/main/java/org/apache/activemq/broker/region/Topic.java b/activemq-broker/src/main/java/org/apache/activemq/broker/region/Topic.java
index 59190f1..f1a0595 100644
--- a/activemq-broker/src/main/java/org/apache/activemq/broker/region/Topic.java
+++ b/activemq-broker/src/main/java/org/apache/activemq/broker/region/Topic.java
@@ -877,10 +877,11 @@ public class Topic extends BaseDestination implements Task {
try {
durableTopicSubscription.dispatchPending();
} catch (IOException exception) {
- LOG.warn("After clear of pending, failed to dispatch to: {}, for: {}, pending: {}, exception: {}", new Object[]{
+ LOG.warn("After clear of pending, failed to dispatch to: {}, for: {}, pending: {}, exception: {}",
durableTopicSubscription,
destination,
- durableTopicSubscription.pending, exception });
+ durableTopicSubscription.pending,
+ exception);
}
}
}
diff --git a/activemq-broker/src/main/java/org/apache/activemq/broker/region/TopicSubscription.java b/activemq-broker/src/main/java/org/apache/activemq/broker/region/TopicSubscription.java
index 41c6a48..8b623bd 100644
--- a/activemq-broker/src/main/java/org/apache/activemq/broker/region/TopicSubscription.java
+++ b/activemq-broker/src/main/java/org/apache/activemq/broker/region/TopicSubscription.java
@@ -138,12 +138,10 @@ public class TopicSubscription extends AbstractSubscription {
}
if (!warnedAboutWait) {
LOG.info("{}: Pending message cursor [{}] is full, temp usage ({}%) or memory usage ({}%) limit reached, blocking message add() pending the release of resources.",
- new Object[]{
- toString(),
- matched,
- matched.getSystemUsage().getTempUsage().getPercentUsage(),
- matched.getSystemUsage().getMemoryUsage().getPercentUsage()
- });
+ toString(),
+ matched,
+ matched.getSystemUsage().getTempUsage().getPercentUsage(),
+ matched.getSystemUsage().getMemoryUsage().getPercentUsage());
warnedAboutWait = true;
}
matchedListMutex.wait(20);
@@ -189,9 +187,8 @@ public class TopicSubscription extends AbstractSubscription {
// lets avoid an infinite loop if we are given a bad eviction strategy
// for a bad strategy lets just not evict
if (messagesToEvict == 0) {
- LOG.warn("No messages to evict returned for {} from eviction strategy: {} out of {} candidates", new Object[]{
- destination, messageEvictionStrategy, list.size()
- });
+ LOG.warn("No messages to evict returned for {} from eviction strategy: {} out of {} candidates",
+ destination, messageEvictionStrategy, list.size());
break;
}
}
diff --git a/activemq-broker/src/main/java/org/apache/activemq/broker/region/cursors/FilePendingMessageCursor.java b/activemq-broker/src/main/java/org/apache/activemq/broker/region/cursors/FilePendingMessageCursor.java
index f23d817..801208c 100644
--- a/activemq-broker/src/main/java/org/apache/activemq/broker/region/cursors/FilePendingMessageCursor.java
+++ b/activemq-broker/src/main/java/org/apache/activemq/broker/region/cursors/FilePendingMessageCursor.java
@@ -31,7 +31,6 @@ import org.apache.activemq.broker.region.IndirectMessageReference;
import org.apache.activemq.broker.region.MessageReference;
import org.apache.activemq.broker.region.QueueMessageReference;
import org.apache.activemq.command.Message;
-import org.apache.activemq.filter.NonCachedMessageEvaluationContext;
import org.apache.activemq.openwire.OpenWireFormat;
import org.apache.activemq.store.PList;
import org.apache.activemq.store.PListEntry;
@@ -443,8 +442,9 @@ public class FilePendingMessageCursor extends AbstractPendingMessageCursor imple
long start = 0;
if (LOG.isTraceEnabled()) {
start = System.currentTimeMillis();
- LOG.trace("{}, flushToDisk() mem list size: {} {}", new Object[] { name, memoryList.size(),
- (systemUsage != null ? systemUsage.getMemoryUsage() : "") });
+ LOG.trace("{}, flushToDisk() mem list size: {} {}",
+ name, memoryList.size(),
+ (systemUsage != null ? systemUsage.getMemoryUsage() : ""));
}
for (Iterator<MessageReference> iterator = memoryList.iterator(); iterator.hasNext();) {
MessageReference node = iterator.next();
@@ -461,7 +461,10 @@ public class FilePendingMessageCursor extends AbstractPendingMessageCursor imple
}
memoryList.clear();
setCacheEnabled(false);
- LOG.trace("{}, flushToDisk() done - {} ms {}", new Object[]{ name, (System.currentTimeMillis() - start), (systemUsage != null ? systemUsage.getMemoryUsage() : "") });
+ LOG.trace("{}, flushToDisk() done - {} ms {}",
+ name,
+ (System.currentTimeMillis() - start),
+ (systemUsage != null ? systemUsage.getMemoryUsage() : ""));
}
}
diff --git a/activemq-broker/src/main/java/org/apache/activemq/broker/region/cursors/StoreDurableSubscriberCursor.java b/activemq-broker/src/main/java/org/apache/activemq/broker/region/cursors/StoreDurableSubscriberCursor.java
index 807f26a..55a7755 100644
--- a/activemq-broker/src/main/java/org/apache/activemq/broker/region/cursors/StoreDurableSubscriberCursor.java
+++ b/activemq-broker/src/main/java/org/apache/activemq/broker/region/cursors/StoreDurableSubscriberCursor.java
@@ -199,7 +199,8 @@ public class StoreDurableSubscriberCursor extends AbstractPendingMessageCursor {
if (prioritizedMessages && immediatePriorityDispatch && tsp.isPaging()) {
if (msg.getPriority() > tsp.getLastRecoveredPriority()) {
tsp.recoverMessage(node.getMessage(), true);
- LOG.trace("cached high priority ({}) message: {}, current paged batch priority: {}, cache size: {}", new Object[]{ msg.getPriority(), msg.getMessageId(), tsp.getLastRecoveredPriority(), tsp.batchList.size()});
+ LOG.trace("cached high priority ({}) message: {}, current paged batch priority: {}, cache size: {}",
+ msg.getPriority(), msg.getMessageId(), tsp.getLastRecoveredPriority(), tsp.batchList.size());
}
}
}
diff --git a/activemq-broker/src/main/java/org/apache/activemq/broker/region/policy/AbortSlowAckConsumerStrategy.java b/activemq-broker/src/main/java/org/apache/activemq/broker/region/policy/AbortSlowAckConsumerStrategy.java
index 68e0148..36d42f5 100644
--- a/activemq-broker/src/main/java/org/apache/activemq/broker/region/policy/AbortSlowAckConsumerStrategy.java
+++ b/activemq-broker/src/main/java/org/apache/activemq/broker/region/policy/AbortSlowAckConsumerStrategy.java
@@ -156,7 +156,10 @@ public class AbortSlowAckConsumerStrategy extends AbortSlowConsumerStrategy {
slowConsumers.remove(entry.getKey());
} else {
- LOG.trace("Not yet time to abort consumer {}: slow duration = {}, slow count = {}", new Object[]{ entry.getKey().getConsumerInfo().getConsumerId(), entry.getValue().markCount * getCheckPeriod(), entry.getValue().slowCount });
+ LOG.trace("Not yet time to abort consumer {}: slow duration = {}, slow count = {}",
+ entry.getKey().getConsumerInfo().getConsumerId(),
+ entry.getValue().markCount * getCheckPeriod(),
+ entry.getValue().slowCount);
}
}
diff --git a/activemq-broker/src/main/java/org/apache/activemq/broker/region/policy/AbortSlowConsumerStrategy.java b/activemq-broker/src/main/java/org/apache/activemq/broker/region/policy/AbortSlowConsumerStrategy.java
index 62d583f..c4380ca 100644
--- a/activemq-broker/src/main/java/org/apache/activemq/broker/region/policy/AbortSlowConsumerStrategy.java
+++ b/activemq-broker/src/main/java/org/apache/activemq/broker/region/policy/AbortSlowConsumerStrategy.java
@@ -110,7 +110,7 @@ public class AbortSlowConsumerStrategy implements SlowConsumerStrategy, Runnable
slowConsumers.remove(entry.getKey());
}
} else {
- LOG.info("sub: " + entry.getKey().getConsumerInfo().getConsumerId() + " is no longer slow");
+ LOG.info("sub: {} is no longer slow", entry.getKey().getConsumerInfo().getConsumerId());
slowConsumers.remove(entry.getKey());
}
}
@@ -130,7 +130,7 @@ public class AbortSlowConsumerStrategy implements SlowConsumerStrategy, Runnable
Connection connection = connectionContext.getConnection();
if (connection == null) {
- LOG.debug("slowConsumer abort ignored, no connection in context:" + connectionContext);
+ LOG.debug("slowConsumer abort ignored, no connection in context: {}", connectionContext);
}
if (!abortMap.containsKey(connection)) {
@@ -152,9 +152,9 @@ public class AbortSlowConsumerStrategy implements SlowConsumerStrategy, Runnable
if (LOG.isTraceEnabled()) {
for (Subscription subscription : subscriptions) {
LOG.trace("Connection {} being aborted because of slow consumer: {} on destination: {}",
- new Object[] { connection.getConnectionId(),
- subscription.getConsumerInfo().getConsumerId(),
- subscription.getActiveMQDestination() });
+ connection.getConnectionId(),
+ subscription.getConsumerInfo().getConsumerId(),
+ subscription.getActiveMQDestination());
}
}
@@ -224,7 +224,7 @@ public class AbortSlowConsumerStrategy implements SlowConsumerStrategy, Runnable
toAbort.put(sub, entry);
abortSubscription(toAbort, abortSubscriberConnection);
} else {
- LOG.warn("cannot abort subscription as it no longer exists in the map of slow consumers: " + sub);
+ LOG.warn("cannot abort subscription as it no longer exists in the map of slow consumers: {}", sub);
}
}
}
diff --git a/activemq-broker/src/main/java/org/apache/activemq/broker/region/policy/PriorityNetworkDispatchPolicy.java b/activemq-broker/src/main/java/org/apache/activemq/broker/region/policy/PriorityNetworkDispatchPolicy.java
index a71825c..f032958 100644
--- a/activemq-broker/src/main/java/org/apache/activemq/broker/region/policy/PriorityNetworkDispatchPolicy.java
+++ b/activemq-broker/src/main/java/org/apache/activemq/broker/region/policy/PriorityNetworkDispatchPolicy.java
@@ -57,12 +57,12 @@ public class PriorityNetworkDispatchPolicy extends SimpleDispatchPolicy {
// higher priority matching sub exists
highestPrioritySub = false;
LOG.debug("ignoring lower priority: {} [{}, {}] in favour of: {} [{}, {}]",
- new Object[]{ candidate,
- candidate.getConsumerInfo().getNetworkConsumerIds(),
- candidate.getConsumerInfo().getNetworkConsumerIds(),
- sub,
- sub.getConsumerInfo().getNetworkConsumerIds(),
- sub.getConsumerInfo().getNetworkConsumerIds() });
+ candidate,
+ candidate.getConsumerInfo().getNetworkConsumerIds(),
+ candidate.getConsumerInfo().getNetworkConsumerIds(),
+ sub,
+ sub.getConsumerInfo().getNetworkConsumerIds(),
+ sub.getConsumerInfo().getNetworkConsumerIds());
}
}
}
diff --git a/activemq-broker/src/main/java/org/apache/activemq/broker/scheduler/SchedulerBroker.java b/activemq-broker/src/main/java/org/apache/activemq/broker/scheduler/SchedulerBroker.java
index d857416..f0c2d72 100644
--- a/activemq-broker/src/main/java/org/apache/activemq/broker/scheduler/SchedulerBroker.java
+++ b/activemq-broker/src/main/java/org/apache/activemq/broker/scheduler/SchedulerBroker.java
@@ -82,14 +82,14 @@ public class SchedulerBroker extends BrokerFilter implements JobListener {
@Override
public void dispatchSync(Command message) {
if (message instanceof ExceptionResponse) {
- LOG.warn("Unexpected response: " + message);
+ LOG.warn("Unexpected response: {}", message);
}
}
@Override
public void dispatchAsync(Command command) {
if (command instanceof ExceptionResponse) {
- LOG.warn("Unexpected response: " + command);
+ LOG.warn("Unexpected response: {}", command);
}
}
@@ -100,7 +100,7 @@ public class SchedulerBroker extends BrokerFilter implements JobListener {
@Override
public void serviceException(Throwable error) {
- LOG.warn("Unexpected exception: " + error, error);
+ LOG.warn("Unexpected exception", error);
}
@Override
@@ -145,7 +145,7 @@ public class SchedulerBroker extends BrokerFilter implements JobListener {
@Override
public void serviceExceptionAsync(IOException e) {
- LOG.warn("Unexpected async ioexception: " + e, e);
+ LOG.warn("Unexpected async ioexception", e);
}
@Override
@@ -292,7 +292,7 @@ public class SchedulerBroker extends BrokerFilter implements JobListener {
long now = System.currentTimeMillis();
if (now >= nextWarn) {
- LOG.info("" + usage + ": " + logMessage + " (blocking for: " + (now - start) / 1000 + "s)");
+ LOG.info("{}: {} (blocking for: {}s)", usage, logMessage, (now - start) / 1000);
nextWarn = now + 30000l;
}
}
@@ -392,7 +392,8 @@ public class SchedulerBroker extends BrokerFilter implements JobListener {
messageSend.setExpiration(expiration);
}
messageSend.setTimestamp(newTimeStamp);
- LOG.debug("Set message {} timestamp from {} to {}", new Object[]{ messageSend.getMessageId(), oldTimestamp, newTimeStamp });
+ LOG.debug("Set message {} timestamp from {} to {}",
+ messageSend.getMessageId(), oldTimestamp, newTimeStamp);
}
}
diff --git a/activemq-broker/src/main/java/org/apache/activemq/broker/util/LoggingBrokerPlugin.java b/activemq-broker/src/main/java/org/apache/activemq/broker/util/LoggingBrokerPlugin.java
index 4f93bcd..0cbfc2e 100644
--- a/activemq-broker/src/main/java/org/apache/activemq/broker/util/LoggingBrokerPlugin.java
+++ b/activemq-broker/src/main/java/org/apache/activemq/broker/util/LoggingBrokerPlugin.java
@@ -156,7 +156,8 @@ public class LoggingBrokerPlugin extends BrokerPluginSupport {
if (isLogAll() || isLogConsumerEvents()) {
LOG.info("Acknowledging message for client ID: {}{}", consumerExchange.getConnectionContext().getClientId(), (ack.getMessageCount() == 1 ? ", " + ack.getLastMessageId() : ""));
if (ack.getMessageCount() > 1) {
- LOG.trace("Message count: {}, First Message Id: {}, Last Message Id: {}", new Object[]{ ack.getMessageCount(), ack.getFirstMessageId(), ack.getLastMessageId() });
+ LOG.trace("Message count: {}, First Message Id: {}, Last Message Id: {}",
+ ack.getMessageCount(), ack.getFirstMessageId(), ack.getLastMessageId());
}
}
super.acknowledge(consumerExchange, ack);
diff --git a/activemq-broker/src/main/java/org/apache/activemq/broker/util/RedeliveryPlugin.java b/activemq-broker/src/main/java/org/apache/activemq/broker/util/RedeliveryPlugin.java
index f270744..d8bd0b6 100644
--- a/activemq-broker/src/main/java/org/apache/activemq/broker/util/RedeliveryPlugin.java
+++ b/activemq-broker/src/main/java/org/apache/activemq/broker/util/RedeliveryPlugin.java
@@ -170,9 +170,8 @@ public class RedeliveryPlugin extends BrokerPluginSupport {
private void scheduleRedelivery(ConnectionContext context, MessageReference messageReference, long delay, int redeliveryCount) throws Exception {
if (LOG.isTraceEnabled()) {
Destination regionDestination = (Destination) messageReference.getRegionDestination();
- LOG.trace("redelivery #{} of: {} with delay: {}, dest: {}", new Object[]{
- redeliveryCount, messageReference.getMessageId(), delay, regionDestination.getActiveMQDestination()
- });
+ LOG.trace("redelivery #{} of: {} with delay: {}, dest: {}",
+ redeliveryCount, messageReference.getMessageId(), delay, regionDestination.getActiveMQDestination());
}
final Message old = messageReference.getMessage();
Message message = old.copy();
diff --git a/activemq-broker/src/main/java/org/apache/activemq/broker/util/TimeStampingBrokerPlugin.java b/activemq-broker/src/main/java/org/apache/activemq/broker/util/TimeStampingBrokerPlugin.java
index af6128f..6a91456 100644
--- a/activemq-broker/src/main/java/org/apache/activemq/broker/util/TimeStampingBrokerPlugin.java
+++ b/activemq-broker/src/main/java/org/apache/activemq/broker/util/TimeStampingBrokerPlugin.java
@@ -125,7 +125,8 @@ public class TimeStampingBrokerPlugin extends BrokerPluginSupport {
message.setExpiration(expiration);
}
message.setTimestamp(newTimeStamp);
- LOG.debug("Set message {} timestamp from {} to {}", new Object[]{ message.getMessageId(), oldTimestamp, newTimeStamp });
+ LOG.debug("Set message {} timestamp from {} to {}",
+ message.getMessageId(), oldTimestamp, newTimeStamp);
}
}
super.send(producerExchange, message);
diff --git a/activemq-broker/src/main/java/org/apache/activemq/network/ConditionalNetworkBridgeFilterFactory.java b/activemq-broker/src/main/java/org/apache/activemq/network/ConditionalNetworkBridgeFilterFactory.java
index 61b21bc..62005f2 100644
--- a/activemq-broker/src/main/java/org/apache/activemq/network/ConditionalNetworkBridgeFilterFactory.java
+++ b/activemq-broker/src/main/java/org/apache/activemq/network/ConditionalNetworkBridgeFilterFactory.java
@@ -109,7 +109,8 @@ public class ConditionalNetworkBridgeFilterFactory implements NetworkBridgeFilte
if (match) {
LOG.trace("Replaying [{}] for [{}] back to origin in the absence of a local consumer", message.getMessageId(), message.getDestination());
} else {
- LOG.trace("Suppressing replay of [{}] for [{}] back to origin {}", new Object[]{ message.getMessageId(), message.getDestination(), Arrays.asList(message.getBrokerPath())} );
+ LOG.trace("Suppressing replay of [{}] for [{}] back to origin {}",
+ message.getMessageId(), message.getDestination(), Arrays.asList(message.getBrokerPath()));
}
} else {
@@ -118,9 +119,8 @@ public class ConditionalNetworkBridgeFilterFactory implements NetworkBridgeFilte
}
if (match && rateLimitExceeded()) {
- LOG.trace("Throttled network consumer rejecting [{}] for [{}] {}>{}/{}", new Object[]{
- message.getMessageId(), message.getDestination(), matchCount, rateLimit, rateDuration
- });
+ LOG.trace("Throttled network consumer rejecting [{}] for [{}] {}>{}/{}",
+ message.getMessageId(), message.getDestination(), matchCount, rateLimit, rateDuration);
match = false;
}
@@ -136,9 +136,8 @@ public class ConditionalNetworkBridgeFilterFactory implements NetworkBridgeFilte
List<Subscription> consumers = regionDestination.getConsumers();
for (Subscription sub : consumers) {
if (!sub.getConsumerInfo().isNetworkSubscription() && !sub.getConsumerInfo().isBrowser()) {
- LOG.trace("Not replaying [{}] for [{}] to origin due to existing local consumer: {}", new Object[]{
- message.getMessageId(), message.getDestination(), sub.getConsumerInfo()
- });
+ LOG.trace("Not replaying [{}] for [{}] to origin due to existing local consumer: {}",
+ message.getMessageId(), message.getDestination(), sub.getConsumerInfo());
return false;
}
}
diff --git a/activemq-broker/src/main/java/org/apache/activemq/network/ConduitBridge.java b/activemq-broker/src/main/java/org/apache/activemq/network/ConduitBridge.java
index a4b5072..d08ae53 100644
--- a/activemq-broker/src/main/java/org/apache/activemq/network/ConduitBridge.java
+++ b/activemq-broker/src/main/java/org/apache/activemq/network/ConduitBridge.java
@@ -70,9 +70,8 @@ public class ConduitBridge extends DemandForwardingBridge {
for (DemandSubscription ds : subscriptionMapByLocalId.values()) {
DestinationFilter filter = DestinationFilter.parseFilter(ds.getLocalInfo().getDestination());
if (canConduit(ds) && filter.matches(info.getDestination())) {
- LOG.debug("{} {} with ids {} matched (add interest) {}", new Object[]{
- configuration.getBrokerName(), info, info.getNetworkConsumerIds(), ds
- });
+ LOG.debug("{} {} with ids {} matched (add interest) {}",
+ configuration.getBrokerName(), info, info.getNetworkConsumerIds(), ds);
// add the interest in the subscription
if (!info.isDurable()) {
ds.add(info.getConsumerId());
@@ -118,9 +117,8 @@ public class ConduitBridge extends DemandForwardingBridge {
for (DemandSubscription ds : subscriptionMapByLocalId.values()) {
if (ds.remove(id)) {
- LOG.debug("{} on {} from {} removed interest for: {} from {}", new Object[]{
- configuration.getBrokerName(), localBroker, remoteBrokerName, id, ds
- });
+ LOG.debug("{} on {} from {} removed interest for: {} from {}",
+ configuration.getBrokerName(), localBroker, remoteBrokerName, id, ds);
}
if (ds.isEmpty()) {
tmpList.add(ds);
@@ -129,9 +127,8 @@ public class ConduitBridge extends DemandForwardingBridge {
for (DemandSubscription ds : tmpList) {
removeSubscription(ds);
- LOG.debug("{} on {} from {} removed {}", new Object[]{
- configuration.getBrokerName(), localBroker, remoteBrokerName, ds
- });
+ LOG.debug("{} on {} from {} removed {}",
+ configuration.getBrokerName(), localBroker, remoteBrokerName, ds);
}
}
}
diff --git a/activemq-broker/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java b/activemq-broker/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java
index 5ca2d34..330162b 100644
--- a/activemq-broker/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java
+++ b/activemq-broker/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java
@@ -283,9 +283,8 @@ public abstract class DemandForwardingBridgeSupport implements NetworkBridge, Br
try {
// local start complete
if (startedLatch.getCount() < 2) {
- LOG.trace("{} unregister bridge ({}) to {}", new Object[]{
- configuration.getBrokerName(), this, remoteBrokerName
- });
+ LOG.trace("{} unregister bridge ({}) to {}",
+ configuration.getBrokerName(), this, remoteBrokerName);
brokerService.getBroker().removeBroker(null, remoteBrokerInfo);
brokerService.getBroker().networkBridgeStopped(remoteBrokerInfo);
}
@@ -408,9 +407,8 @@ public abstract class DemandForwardingBridgeSupport implements NetworkBridge, Br
// and if so just stop now before registering anything.
remoteBrokerId = remoteBrokerInfo.getBrokerId();
if (localBrokerId.equals(remoteBrokerId)) {
- LOG.trace("{} disconnecting remote loop back connector for: {}, with id: {}", new Object[]{
- configuration.getBrokerName(), remoteBrokerName, remoteBrokerId
- });
+ LOG.trace("{} disconnecting remote loop back connector for: {}, with id: {}",
+ configuration.getBrokerName(), remoteBrokerName, remoteBrokerId);
ServiceSupport.dispose(localBroker);
ServiceSupport.dispose(remoteBroker);
// the bridge is left in a bit of limbo, but it won't get retried
@@ -552,12 +550,10 @@ public abstract class DemandForwardingBridgeSupport implements NetworkBridge, Br
// new peer broker (a consumer can work with remote broker also)
brokerService.getBroker().addBroker(null, remoteBrokerInfo);
- LOG.info("Network connection between {} and {} ({}) has been established.", new Object[]{
- localBroker, remoteBroker, remoteBrokerName
- });
- LOG.trace("{} register bridge ({}) to {}", new Object[]{
- configuration.getBrokerName(), this, remoteBrokerName
- });
+ LOG.info("Network connection between {} and {} ({}) has been established.",
+ localBroker, remoteBroker, remoteBrokerName);
+ LOG.trace("{} register bridge ({}) to {}",
+ configuration.getBrokerName(), this, remoteBrokerName);
} else {
LOG.warn("Bridge was disposed before the startLocalBridge() method was fully executed.");
}
@@ -923,7 +919,7 @@ public abstract class DemandForwardingBridgeSupport implements NetworkBridge, Br
try {
remoteBroker.oneway(ack);
} catch (IOException e) {
- LOG.warn("Failed to send advisory ack " + ack, e);
+ LOG.warn("Failed to send advisory ack {}", ack, e);
}
}
});
@@ -944,25 +940,22 @@ public abstract class DemandForwardingBridgeSupport implements NetworkBridge, Br
}
if (path != null && networkTTL > -1 && path.length >= networkTTL) {
- LOG.debug("{} Ignoring sub from {}, restricted to {} network hops only: {}", new Object[]{
- configuration.getBrokerName(), remoteBrokerName, networkTTL, info
- });
+ LOG.debug("{} Ignoring sub from {}, restricted to {} network hops only: {}",
+ configuration.getBrokerName(), remoteBrokerName, networkTTL, info);
return;
}
if (contains(path, localBrokerPath[0])) {
// Ignore this consumer as it's a consumer we locally sent to the broker.
- LOG.debug("{} Ignoring sub from {}, already routed through this broker once: {}", new Object[]{
- configuration.getBrokerName(), remoteBrokerName, info
- });
+ LOG.debug("{} Ignoring sub from {}, already routed through this broker once: {}",
+ configuration.getBrokerName(), remoteBrokerName, info);
return;
}
if (!isPermissableDestination(info.getDestination())) {
// ignore if not in the permitted or in the excluded list
- LOG.debug("{} Ignoring sub from {}, destination {} is not permitted: {}", new Object[]{
- configuration.getBrokerName(), remoteBrokerName, info.getDestination(), info
- });
+ LOG.debug("{} Ignoring sub from {}, destination {} is not permitted: {}",
+ configuration.getBrokerName(), remoteBrokerName, info.getDestination(), info);
return;
}
@@ -981,9 +974,8 @@ public abstract class DemandForwardingBridgeSupport implements NetworkBridge, Br
final DestinationInfo destInfo = (DestinationInfo) data;
BrokerId[] path = destInfo.getBrokerPath();
if (path != null && networkTTL > -1 && path.length >= networkTTL) {
- LOG.debug("{} Ignoring destination {} restricted to {} network hops only", new Object[]{
- configuration.getBrokerName(), destInfo, networkTTL
- });
+ LOG.debug("{} Ignoring destination {} restricted to {} network hops only",
+ configuration.getBrokerName(), destInfo, networkTTL);
return;
}
if (contains(destInfo.getBrokerPath(), localBrokerPath[0])) {
@@ -997,9 +989,8 @@ public abstract class DemandForwardingBridgeSupport implements NetworkBridge, Br
tempDest.setConnectionId(localSessionInfo.getSessionId().getConnectionId());
}
destInfo.setBrokerPath(appendToBrokerPath(destInfo.getBrokerPath(), getRemoteBrokerPath()));
- LOG.trace("{} bridging {} destination on {} from {}, destination: {}", new Object[]{
- configuration.getBrokerName(), (destInfo.isAddOperation() ? "add" : "remove"), localBroker, remoteBrokerName, destInfo
- });
+ LOG.trace("{} bridging {} destination on {} from {}, destination: {}",
+ configuration.getBrokerName(), (destInfo.isAddOperation() ? "add" : "remove"), localBroker, remoteBrokerName, destInfo);
if (destInfo.isRemoveOperation()) {
// Serialize with removeSub operations such that all removeSub advisories
// are generated
@@ -1106,7 +1097,7 @@ public abstract class DemandForwardingBridgeSupport implements NetworkBridge, Br
return;
}
- LOG.info("Network connection between {} and {} shutdown due to a local error: {}", new Object[]{localBroker, remoteBroker, error});
+ LOG.info("Network connection between {} and {} shutdown due to a local error: {}", localBroker, remoteBroker, error);
LOG.debug("The local Exception was: {}", error, error);
brokerService.getTaskRunnerFactory().execute(new Runnable() {
@@ -1137,7 +1128,7 @@ public abstract class DemandForwardingBridgeSupport implements NetworkBridge, Br
}
} catch (Exception e) {
- LOG.warn("failed to fire forward failure advisory, cause: {}", (Object)e);
+ LOG.warn("failed to fire forward failure advisory, cause: {}", e);
LOG.debug("detail", e);
}
}
@@ -1155,7 +1146,7 @@ public abstract class DemandForwardingBridgeSupport implements NetworkBridge, Br
protected void removeSubscription(final DemandSubscription sub) throws IOException {
if (sub != null) {
- LOG.trace("{} remove local subscription: {} for remote {}", new Object[]{configuration.getBrokerName(), sub.getLocalInfo().getConsumerId(), sub.getRemoteInfo().getConsumerId()});
+ LOG.trace("{} remove local subscription: {} for remote {}", configuration.getBrokerName(), sub.getLocalInfo().getConsumerId(), sub.getRemoteInfo().getConsumerId());
// ensure not available for conduit subs pending removal
subscriptionMapByLocalId.remove(sub.getLocalInfo().getConsumerId());
@@ -1206,9 +1197,8 @@ public abstract class DemandForwardingBridgeSupport implements NetworkBridge, Br
if (sub != null && md.getMessage() != null && sub.incrementOutstandingResponses()) {
if (suppressMessageDispatch(md, sub)) {
- LOG.debug("{} message not forwarded to {} because message came from there or fails TTL, brokerPath: {}, message: {}", new Object[]{
- configuration.getBrokerName(), remoteBrokerName, Arrays.toString(md.getMessage().getBrokerPath()), md.getMessage()
- });
+ LOG.debug("{} message not forwarded to {} because message came from there or fails TTL, brokerPath: {}, message: {}",
+ configuration.getBrokerName(), remoteBrokerName, Arrays.toString(md.getMessage().getBrokerPath()), md.getMessage());
// still ack as it may be durable
try {
localBroker.oneway(new MessageAck(md, MessageAck.INDIVIDUAL_ACK_TYPE, 1));
@@ -1219,9 +1209,8 @@ public abstract class DemandForwardingBridgeSupport implements NetworkBridge, Br
}
Message message = configureMessage(md);
- LOG.debug("bridging ({} -> {}), consumer: {}, destination: {}, brokerPath: {}, message: {}", new Object[]{
- configuration.getBrokerName(), remoteBrokerName, md.getConsumerId(), message.getDestination(), Arrays.toString(message.getBrokerPath()), (LOG.isTraceEnabled() ? message : message.getMessageId())
- });
+ LOG.debug("bridging ({} -> {}), consumer: {}, destination: {}, brokerPath: {}, message: {}",
+ configuration.getBrokerName(), remoteBrokerName, md.getConsumerId(), message.getDestination(), Arrays.toString(message.getBrokerPath()), (LOG.isTraceEnabled() ? message : message.getMessageId()));
if (isDuplex() && NetworkBridgeFilter.isAdvisoryInterpretedByNetworkBridge(message)) {
try {
// never request b/c they are eventually acked async
@@ -1498,18 +1487,16 @@ public abstract class DemandForwardingBridgeSupport implements NetworkBridge, Br
boolean suppress = false;
if (existingSub.getConsumerInfo().getPriority() >= candidateInfo.getPriority()) {
- LOG.debug("{} Ignoring duplicate subscription from {}, sub: {} is duplicate by network subscription with equal or higher network priority: {}, networkConsumerIds: {}", new Object[]{
- configuration.getBrokerName(), remoteBrokerName, candidateInfo, existingSub, existingSub.getConsumerInfo().getNetworkConsumerIds()
- });
+ LOG.debug("{} Ignoring duplicate subscription from {}, sub: {} is duplicate by network subscription with equal or higher network priority: {}, networkConsumerIds: {}",
+ configuration.getBrokerName(), remoteBrokerName, candidateInfo, existingSub, existingSub.getConsumerInfo().getNetworkConsumerIds());
suppress = true;
} else {
// remove the existing lower priority duplicate and allow this candidate
try {
removeDuplicateSubscription(existingSub);
- LOG.debug("{} Replacing duplicate subscription {} with sub from {}, which has a higher priority, new sub: {}, networkConsumerIds: {}", new Object[]{
- configuration.getBrokerName(), existingSub.getConsumerInfo(), remoteBrokerName, candidateInfo, candidateInfo.getNetworkConsumerIds()
- });
+ LOG.debug("{} Replacing duplicate subscription {} with sub from {}, which has a higher priority, new sub: {}, networkConsumerIds: {}",
+ configuration.getBrokerName(), existingSub.getConsumerInfo(), remoteBrokerName, candidateInfo, candidateInfo.getNetworkConsumerIds());
} catch (IOException e) {
LOG.error("Failed to remove duplicated sub as a result of sub with higher priority, sub: {}", existingSub, e);
}
@@ -1588,7 +1575,7 @@ public abstract class DemandForwardingBridgeSupport implements NetworkBridge, Br
priority -= info.getBrokerPath().length + 1;
}
result.getLocalInfo().setPriority(priority);
- LOG.debug("{} using priority: {} for subscription: {}", new Object[]{configuration.getBrokerName(), priority, info});
+ LOG.debug("{} using priority: {} for subscription: {}", configuration.getBrokerName(), priority, info);
}
configureDemandSubscription(info, result);
return result;
@@ -1641,14 +1628,12 @@ public abstract class DemandForwardingBridgeSupport implements NetworkBridge, Br
protected void removeDemandSubscription(ConsumerId id) throws IOException {
DemandSubscription sub = subscriptionMapByRemoteId.remove(id);
- LOG.debug("{} remove request on {} from {}, consumer id: {}, matching sub: {}", new Object[]{
- configuration.getBrokerName(), localBroker, remoteBrokerName, id, sub
- });
+ LOG.debug("{} remove request on {} from {}, consumer id: {}, matching sub: {}",
+ configuration.getBrokerName(), localBroker, remoteBrokerName, id, sub);
if (sub != null) {
removeSubscription(sub);
- LOG.debug("{} removed sub on {} from {}: {}", new Object[]{
- configuration.getBrokerName(), localBroker, remoteBrokerName, sub.getRemoteInfo()
- });
+ LOG.debug("{} removed sub on {} from {}: {}",
+ configuration.getBrokerName(), localBroker, remoteBrokerName, sub.getRemoteInfo());
}
}
@@ -1964,9 +1949,8 @@ public abstract class DemandForwardingBridgeSupport implements NetworkBridge, Br
long lastStoredForMessageProducer = getStoredSequenceIdForMessage(message.getMessageId());
if (producerSequenceId <= lastStoredForMessageProducer) {
result = false;
- LOG.debug("suppressing duplicate message send [{}] from network producer with producerSequence [{}] less than last stored: {}", new Object[]{
- (LOG.isTraceEnabled() ? message : message.getMessageId()), producerSequenceId, lastStoredForMessageProducer
- });
+ LOG.debug("suppressing duplicate message send [{}] from network producer with producerSequence [{}] less than last stored: {}",
+ (LOG.isTraceEnabled() ? message : message.getMessageId()), producerSequenceId, lastStoredForMessageProducer);
}
}
return result;
diff --git a/activemq-broker/src/main/java/org/apache/activemq/network/DiscoveryNetworkConnector.java b/activemq-broker/src/main/java/org/apache/activemq/network/DiscoveryNetworkConnector.java
index 3850da5..6591c60 100644
--- a/activemq-broker/src/main/java/org/apache/activemq/network/DiscoveryNetworkConnector.java
+++ b/activemq-broker/src/main/java/org/apache/activemq/network/DiscoveryNetworkConnector.java
@@ -114,7 +114,7 @@ public class DiscoveryNetworkConnector extends NetworkConnector implements Disco
try {
connectUri = URISupport.applyParameters(connectUri, parameters, DISCOVERED_OPTION_PREFIX);
} catch (URISyntaxException e) {
- LOG.warn("could not apply query parameters: {} to: {}", new Object[]{ parameters, connectUri }, e);
+ LOG.warn("could not apply query parameters: {} to: {}",parameters, connectUri, e);
}
LOG.info("Establishing network connection from {} to {}", localURI, connectUri);
@@ -162,7 +162,7 @@ public class DiscoveryNetworkConnector extends NetworkConnector implements Disco
} catch (Exception e) {
ServiceSupport.dispose(localTransport);
ServiceSupport.dispose(remoteTransport);
- LOG.warn("Could not start network bridge between: {} and: {} due to: {}", new Object[]{ localURI, uri, e.getMessage() });
+ LOG.warn("Could not start network bridge between: {} and: {} due to: {}", localURI, uri, e.getMessage());
LOG.debug("Start failure exception: ", e);
try {
// Will remove bridge and active event.
diff --git a/activemq-broker/src/main/java/org/apache/activemq/network/LdapNetworkConnector.java b/activemq-broker/src/main/java/org/apache/activemq/network/LdapNetworkConnector.java
index 341ea30..5efd82b 100644
--- a/activemq-broker/src/main/java/org/apache/activemq/network/LdapNetworkConnector.java
+++ b/activemq-broker/src/main/java/org/apache/activemq/network/LdapNetworkConnector.java
@@ -290,14 +290,14 @@ public class LdapNetworkConnector extends NetworkConnector implements NamespaceC
protected synchronized void addConnector(SearchResult result) throws Exception {
String uuid = toUUID(result);
if (uuidMap.containsKey(uuid)) {
- LOG.warn("connector already regsitered for UUID [{}]", uuid);
+ LOG.warn("connector already registered for UUID [{}]", uuid);
return;
}
URI connectorURI = toURI(result);
if (connectorMap.containsKey(connectorURI)) {
int referenceCount = referenceMap.get(connectorURI) + 1;
- LOG.warn("connector reference added for URI [{}], UUID [{}], total reference(s) [{}]", new Object[]{ connectorURI, uuid, referenceCount });
+ LOG.warn("connector reference added for URI [{}], UUID [{}], total reference(s) [{}]",connectorURI, uuid, referenceCount);
referenceMap.put(connectorURI, referenceCount);
uuidMap.put(uuid, connectorURI);
return;
@@ -357,7 +357,7 @@ public class LdapNetworkConnector extends NetworkConnector implements NamespaceC
int referenceCount = referenceMap.get(connectorURI) - 1;
referenceMap.put(connectorURI, referenceCount);
uuidMap.remove(uuid);
- LOG.debug("connector referenced removed for URI [{}], UUID[{}], remaining reference(s) [{}]", new Object[]{ connectorURI, uuid, referenceCount });
+ LOG.debug("connector referenced removed for URI [{}], UUID[{}], remaining reference(s) [{}]", connectorURI, uuid, referenceCount);
if (referenceCount > 0) {
return;
@@ -434,7 +434,7 @@ public class LdapNetworkConnector extends NetworkConnector implements NamespaceC
String uuidNew = event.getNewBinding().getName();
URI connectorURI = uuidMap.remove(uuidOld);
uuidMap.put(uuidNew, connectorURI);
- LOG.debug("connector reference renamed for URI [{}], Old UUID [{}], New UUID [{}]", new Object[]{ connectorURI, uuidOld, uuidNew });
+ LOG.debug("connector reference renamed for URI [{}], Old UUID [{}], New UUID [{}]", connectorURI, uuidOld, uuidNew);
}
/**
diff --git a/activemq-broker/src/main/java/org/apache/activemq/network/jms/DestinationBridge.java b/activemq-broker/src/main/java/org/apache/activemq/network/jms/DestinationBridge.java
index 4a1a78c..8d9bdbc 100644
--- a/activemq-broker/src/main/java/org/apache/activemq/network/jms/DestinationBridge.java
+++ b/activemq-broker/src/main/java/org/apache/activemq/network/jms/DestinationBridge.java
@@ -149,7 +149,7 @@ public abstract class DestinationBridge implements Service, MessageListener {
return;
} catch (Exception e) {
- LOG.info("failed to forward message on attempt: {} reason: {} message: {}", new Object[]{ attempt, e, message });
+ LOG.info("failed to forward message on attempt: {} reason: {} message: {}", attempt, e, message);
}
}
}
diff --git a/activemq-broker/src/main/java/org/apache/activemq/network/jms/JmsConnector.java b/activemq-broker/src/main/java/org/apache/activemq/network/jms/JmsConnector.java
index 6cb223a..b09b96a 100644
--- a/activemq-broker/src/main/java/org/apache/activemq/network/jms/JmsConnector.java
+++ b/activemq-broker/src/main/java/org/apache/activemq/network/jms/JmsConnector.java
@@ -626,7 +626,7 @@ public abstract class JmsConnector implements Service {
return;
} catch(Exception e) {
- LOG.debug("Failed to establish initial {} connection for JmsConnector [{}]", new Object[]{ (local ? "local" : "foreign"), attempt }, e);
+ LOG.debug("Failed to establish initial {} connection for JmsConnector [{}]", (local ? "local" : "foreign"), attempt, e);
} finally {
attempt++;
}
diff --git a/activemq-broker/src/main/java/org/apache/activemq/security/SimpleCachedLDAPAuthorizationMap.java b/activemq-broker/src/main/java/org/apache/activemq/security/SimpleCachedLDAPAuthorizationMap.java
index 77cbb20..87a6069 100644
--- a/activemq-broker/src/main/java/org/apache/activemq/security/SimpleCachedLDAPAuthorizationMap.java
+++ b/activemq-broker/src/main/java/org/apache/activemq/security/SimpleCachedLDAPAuthorizationMap.java
@@ -237,7 +237,7 @@ public class SimpleCachedLDAPAuthorizationMap implements AuthorizationMap {
currentContext.search(queueSearchBase, getFilterForPermissionType(permissionType),
constraints), DestinationType.QUEUE, permissionType);
} catch (Exception e) {
- LOG.error("Policy not applied!. Error processing policy under '{}' with filter '{}'", new Object[]{ queueSearchBase, getFilterForPermissionType(permissionType) }, e);
+ LOG.error("Policy not applied!. Error processing policy under '{}' with filter '{}'", queueSearchBase, getFilterForPermissionType(permissionType), e);
}
}
@@ -247,7 +247,7 @@ public class SimpleCachedLDAPAuthorizationMap implements AuthorizationMap {
currentContext.search(topicSearchBase, getFilterForPermissionType(permissionType),
constraints), DestinationType.TOPIC, permissionType);
} catch (Exception e) {
- LOG.error("Policy not applied!. Error processing policy under '{}' with filter '{}'", new Object[]{ topicSearchBase, getFilterForPermissionType(permissionType) }, e);
+ LOG.error("Policy not applied!. Error processing policy under '{}' with filter '{}'", topicSearchBase, getFilterForPermissionType(permissionType), e);
}
}
@@ -257,7 +257,7 @@ public class SimpleCachedLDAPAuthorizationMap implements AuthorizationMap {
currentContext.search(tempSearchBase, getFilterForPermissionType(permissionType),
constraints), DestinationType.TEMP, permissionType);
} catch (Exception e) {
- LOG.error("Policy not applied!. Error processing policy under '{}' with filter '{}'", new Object[]{ tempSearchBase, getFilterForPermissionType(permissionType) }, e);
+ LOG.error("Policy not applied!. Error processing policy under '{}' with filter '{}'", tempSearchBase, getFilterForPermissionType(permissionType), e);
}
}
@@ -405,7 +405,7 @@ public class SimpleCachedLDAPAuthorizationMap implements AuthorizationMap {
try {
memberAttributes = context.getAttributes(memberDn, new String[] { "objectClass", groupNameAttribute, userNameAttribute });
} catch (NamingException e) {
- LOG.error("Policy not applied! Unknown member {} in policy entry {}", new Object[]{ memberDn, result.getNameInNamespace() }, e);
+ LOG.error("Policy not applied! Unknown member {} in policy entry {}", memberDn, result.getNameInNamespace(), e);
continue;
}
@@ -419,7 +419,7 @@ public class SimpleCachedLDAPAuthorizationMap implements AuthorizationMap {
group = true;
Attribute name = memberAttributes.get(groupNameAttribute);
if (name == null) {
- LOG.error("Policy not applied! Group {} does not have name attribute {} under entry {}", new Object[]{ memberDn, groupNameAttribute, result.getNameInNamespace() });
+ LOG.error("Policy not applied! Group {} does not have name attribute {} under entry {}", memberDn, groupNameAttribute, result.getNameInNamespace());
break;
}
@@ -430,7 +430,7 @@ public class SimpleCachedLDAPAuthorizationMap implements AuthorizationMap {
user = true;
Attribute name = memberAttributes.get(userNameAttribute);
if (name == null) {
- LOG.error("Policy not applied! User {} does not have name attribute {} under entry {}", new Object[]{ memberDn, userNameAttribute, result.getNameInNamespace() });
+ LOG.error("Policy not applied! User {} does not have name attribute {} under entry {}", memberDn, userNameAttribute, result.getNameInNamespace());
break;
}
@@ -901,9 +901,9 @@ public class SimpleCachedLDAPAuthorizationMap implements AuthorizationMap {
}
}
} catch (InvalidNameException e) {
- LOG.error("Policy not applied! Error parsing DN for object rename for rename of {} to {}", new Object[]{ oldBinding.getName(), newBinding.getName() }, e);
+ LOG.error("Policy not applied! Error parsing DN for object rename for rename of {} to {}", oldBinding.getName(), newBinding.getName(), e);
} catch (Exception e) {
- LOG.error("Policy not applied! Error processing object rename for rename of {} to {}", new Object[]{ oldBinding.getName(), newBinding.getName() }, e);
+ LOG.error("Policy not applied! Error processing object rename for rename of {} to {}", oldBinding.getName(), newBinding.getName(), e);
}
}