activeTempDestinations = new ConcurrentHashMap();
diff --git a/activemq-core/src/main/java/org/apache/activemq/ActiveMQMessageConsumer.java b/activemq-core/src/main/java/org/apache/activemq/ActiveMQMessageConsumer.java
index 2d598a72da..329d9b929d 100755
--- a/activemq-core/src/main/java/org/apache/activemq/ActiveMQMessageConsumer.java
+++ b/activemq-core/src/main/java/org/apache/activemq/ActiveMQMessageConsumer.java
@@ -59,8 +59,8 @@ import org.apache.activemq.transaction.Synchronization;
import org.apache.activemq.util.Callback;
import org.apache.activemq.util.IntrospectionSupport;
import org.apache.activemq.util.JMSExceptionSupport;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
/**
* A client uses a MessageConsumer
object to receive messages
@@ -108,7 +108,7 @@ public class ActiveMQMessageConsumer implements MessageAvailableConsumer, StatsC
}
}
- private static final Log LOG = LogFactory.getLog(ActiveMQMessageConsumer.class);
+ private static final Logger LOG = LoggerFactory.getLogger(ActiveMQMessageConsumer.class);
protected final Scheduler scheduler;
protected final ActiveMQSession session;
protected final ConsumerInfo info;
diff --git a/activemq-core/src/main/java/org/apache/activemq/ActiveMQPrefetchPolicy.java b/activemq-core/src/main/java/org/apache/activemq/ActiveMQPrefetchPolicy.java
index bae9993ce3..b790dea087 100755
--- a/activemq-core/src/main/java/org/apache/activemq/ActiveMQPrefetchPolicy.java
+++ b/activemq-core/src/main/java/org/apache/activemq/ActiveMQPrefetchPolicy.java
@@ -17,8 +17,8 @@
package org.apache.activemq;
import java.io.Serializable;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
/**
* Defines the prefetch message policies for different types of consumers
@@ -35,7 +35,7 @@ public class ActiveMQPrefetchPolicy extends Object implements Serializable {
public static final int DEFAULT_INPUT_STREAM_PREFETCH=100;
public static final int DEFAULT_TOPIC_PREFETCH = MAX_PREFETCH_SIZE;
- private static final Log LOG = LogFactory.getLog(ActiveMQPrefetchPolicy.class);
+ private static final Logger LOG = LoggerFactory.getLogger(ActiveMQPrefetchPolicy.class);
private int queuePrefetch;
private int queueBrowserPrefetch;
diff --git a/activemq-core/src/main/java/org/apache/activemq/ActiveMQSession.java b/activemq-core/src/main/java/org/apache/activemq/ActiveMQSession.java
index fe54fcd76e..82e560cfce 100755
--- a/activemq-core/src/main/java/org/apache/activemq/ActiveMQSession.java
+++ b/activemq-core/src/main/java/org/apache/activemq/ActiveMQSession.java
@@ -88,8 +88,8 @@ import org.apache.activemq.transaction.Synchronization;
import org.apache.activemq.usage.MemoryUsage;
import org.apache.activemq.util.Callback;
import org.apache.activemq.util.LongSequenceGenerator;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
/**
*
@@ -196,7 +196,7 @@ public class ActiveMQSession implements Session, QueueSession, TopicSession, Sta
void afterDelivery(ActiveMQSession session, Message msg);
}
- private static final Log LOG = LogFactory.getLog(ActiveMQSession.class);
+ private static final Logger LOG = LoggerFactory.getLogger(ActiveMQSession.class);
private final Scheduler scheduler;
private final ThreadPoolExecutor connectionExecutor;
diff --git a/activemq-core/src/main/java/org/apache/activemq/ActiveMQSessionExecutor.java b/activemq-core/src/main/java/org/apache/activemq/ActiveMQSessionExecutor.java
index 2fdca37499..bc8e6f1621 100755
--- a/activemq-core/src/main/java/org/apache/activemq/ActiveMQSessionExecutor.java
+++ b/activemq-core/src/main/java/org/apache/activemq/ActiveMQSessionExecutor.java
@@ -24,8 +24,8 @@ import org.apache.activemq.command.MessageDispatch;
import org.apache.activemq.thread.Task;
import org.apache.activemq.thread.TaskRunner;
import org.apache.activemq.util.JMSExceptionSupport;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
/**
* A utility class used by the Session for dispatching messages asynchronously
@@ -35,7 +35,7 @@ import org.apache.commons.logging.LogFactory;
* @see javax.jms.Session
*/
public class ActiveMQSessionExecutor implements Task {
- private static final Log LOG = LogFactory.getLog(ActiveMQSessionExecutor.class);
+ private static final Logger LOG = LoggerFactory.getLogger(ActiveMQSessionExecutor.class);
private final ActiveMQSession session;
private final MessageDispatchChannel messageQueue;
diff --git a/activemq-core/src/main/java/org/apache/activemq/AdvisoryConsumer.java b/activemq-core/src/main/java/org/apache/activemq/AdvisoryConsumer.java
index a537d9ab41..0a61c8ae3e 100755
--- a/activemq-core/src/main/java/org/apache/activemq/AdvisoryConsumer.java
+++ b/activemq-core/src/main/java/org/apache/activemq/AdvisoryConsumer.java
@@ -27,11 +27,11 @@ import org.apache.activemq.command.DataStructure;
import org.apache.activemq.command.DestinationInfo;
import org.apache.activemq.command.MessageAck;
import org.apache.activemq.command.MessageDispatch;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
public class AdvisoryConsumer implements ActiveMQDispatcher {
- private static final transient Log LOG = LogFactory.getLog(AdvisoryConsumer.class);
+ private static final transient Logger LOG = LoggerFactory.getLogger(AdvisoryConsumer.class);
int deliveredCounter;
diff --git a/activemq-core/src/main/java/org/apache/activemq/TransactionContext.java b/activemq-core/src/main/java/org/apache/activemq/TransactionContext.java
index 4136d791de..cd5b1ae2c4 100755
--- a/activemq-core/src/main/java/org/apache/activemq/TransactionContext.java
+++ b/activemq-core/src/main/java/org/apache/activemq/TransactionContext.java
@@ -42,8 +42,8 @@ import org.apache.activemq.command.XATransactionId;
import org.apache.activemq.transaction.Synchronization;
import org.apache.activemq.util.JMSExceptionSupport;
import org.apache.activemq.util.LongSequenceGenerator;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
/**
* A TransactionContext provides the means to control a JMS transaction. It
@@ -65,7 +65,7 @@ import org.apache.commons.logging.LogFactory;
*/
public class TransactionContext implements XAResource {
- private static final Log LOG = LogFactory.getLog(TransactionContext.class);
+ private static final Logger LOG = LoggerFactory.getLogger(TransactionContext.class);
// XATransactionId -> ArrayList of TransactionContext objects
private final static ConcurrentHashMap> ENDED_XA_TRANSACTION_CONTEXTS = new ConcurrentHashMap>();
diff --git a/activemq-core/src/main/java/org/apache/activemq/advisory/AdvisoryBroker.java b/activemq-core/src/main/java/org/apache/activemq/advisory/AdvisoryBroker.java
index b676dfbc34..2f116a0ec9 100755
--- a/activemq-core/src/main/java/org/apache/activemq/advisory/AdvisoryBroker.java
+++ b/activemq-core/src/main/java/org/apache/activemq/advisory/AdvisoryBroker.java
@@ -34,8 +34,8 @@ import org.apache.activemq.state.ProducerState;
import org.apache.activemq.usage.Usage;
import org.apache.activemq.util.IdGenerator;
import org.apache.activemq.util.LongSequenceGenerator;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
/**
* This broker filter handles tracking the state of the broker for purposes of
@@ -45,7 +45,7 @@ import org.apache.commons.logging.LogFactory;
*/
public class AdvisoryBroker extends BrokerFilter {
- private static final Log LOG = LogFactory.getLog(AdvisoryBroker.class);
+ private static final Logger LOG = LoggerFactory.getLogger(AdvisoryBroker.class);
private static final IdGenerator ID_GENERATOR = new IdGenerator();
protected final ConcurrentHashMap connections = new ConcurrentHashMap();
diff --git a/activemq-core/src/main/java/org/apache/activemq/advisory/ConsumerEventSource.java b/activemq-core/src/main/java/org/apache/activemq/advisory/ConsumerEventSource.java
index 93deffd1af..6b331febba 100644
--- a/activemq-core/src/main/java/org/apache/activemq/advisory/ConsumerEventSource.java
+++ b/activemq-core/src/main/java/org/apache/activemq/advisory/ConsumerEventSource.java
@@ -34,8 +34,8 @@ import org.apache.activemq.command.ActiveMQTopic;
import org.apache.activemq.command.ConsumerId;
import org.apache.activemq.command.ConsumerInfo;
import org.apache.activemq.command.RemoveInfo;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
/**
* An object which can be used to listen to the number of active consumers
@@ -44,7 +44,7 @@ import org.apache.commons.logging.LogFactory;
* @version $Revision$
*/
public class ConsumerEventSource implements Service, MessageListener {
- private static final Log LOG = LogFactory.getLog(ConsumerEventSource.class);
+ private static final Logger LOG = LoggerFactory.getLogger(ConsumerEventSource.class);
private final Connection connection;
private final ActiveMQDestination destination;
diff --git a/activemq-core/src/main/java/org/apache/activemq/advisory/DestinationSource.java b/activemq-core/src/main/java/org/apache/activemq/advisory/DestinationSource.java
index 0f3b906b24..6b9ab9675b 100644
--- a/activemq-core/src/main/java/org/apache/activemq/advisory/DestinationSource.java
+++ b/activemq-core/src/main/java/org/apache/activemq/advisory/DestinationSource.java
@@ -35,8 +35,8 @@ import org.apache.activemq.command.ActiveMQTempQueue;
import org.apache.activemq.command.ActiveMQTempTopic;
import org.apache.activemq.command.ActiveMQTopic;
import org.apache.activemq.command.DestinationInfo;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
/**
* A helper class which keeps track of the Destinations available in a broker and allows you to listen to them
@@ -45,7 +45,7 @@ import org.apache.commons.logging.LogFactory;
* @version $Revision$
*/
public class DestinationSource implements MessageListener {
- private static final Log LOG = LogFactory.getLog(ConsumerEventSource.class);
+ private static final Logger LOG = LoggerFactory.getLogger(ConsumerEventSource.class);
private AtomicBoolean started = new AtomicBoolean(false);
private final Connection connection;
private Session session;
@@ -189,4 +189,4 @@ public class DestinationSource implements MessageListener {
listener.onDestinationEvent(event);
}
}
-}
\ No newline at end of file
+}
diff --git a/activemq-core/src/main/java/org/apache/activemq/advisory/ProducerEventSource.java b/activemq-core/src/main/java/org/apache/activemq/advisory/ProducerEventSource.java
index 2ca45d7404..3a02437229 100644
--- a/activemq-core/src/main/java/org/apache/activemq/advisory/ProducerEventSource.java
+++ b/activemq-core/src/main/java/org/apache/activemq/advisory/ProducerEventSource.java
@@ -34,8 +34,8 @@ import org.apache.activemq.command.ActiveMQTopic;
import org.apache.activemq.command.ProducerId;
import org.apache.activemq.command.ProducerInfo;
import org.apache.activemq.command.RemoveInfo;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
/**
* An object which can be used to listen to the number of active consumers
@@ -44,7 +44,7 @@ import org.apache.commons.logging.LogFactory;
* @version $Revision: 359679 $
*/
public class ProducerEventSource implements Service, MessageListener {
- private static final Log LOG = LogFactory.getLog(ProducerEventSource.class);
+ private static final Logger LOG = LoggerFactory.getLogger(ProducerEventSource.class);
private final Connection connection;
private final ActiveMQDestination destination;
diff --git a/activemq-core/src/main/java/org/apache/activemq/broker/BrokerPluginSupport.java b/activemq-core/src/main/java/org/apache/activemq/broker/BrokerPluginSupport.java
index d2ff04efb5..ade726b91c 100644
--- a/activemq-core/src/main/java/org/apache/activemq/broker/BrokerPluginSupport.java
+++ b/activemq-core/src/main/java/org/apache/activemq/broker/BrokerPluginSupport.java
@@ -16,8 +16,8 @@
*/
package org.apache.activemq.broker;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
/**
* A useful base class for implementing broker plugins.
@@ -25,7 +25,7 @@ import org.apache.commons.logging.LogFactory;
* @version $Revision$
*/
public abstract class BrokerPluginSupport extends MutableBrokerFilter implements BrokerPlugin {
- private static final Log LOG = LogFactory.getLog(BrokerPluginSupport.class);
+ private static final Logger LOG = LoggerFactory.getLogger(BrokerPluginSupport.class);
public BrokerPluginSupport() {
super(null);
}
diff --git a/activemq-core/src/main/java/org/apache/activemq/broker/BrokerRegistry.java b/activemq-core/src/main/java/org/apache/activemq/broker/BrokerRegistry.java
index f9ada38e1d..e49a6d57a0 100755
--- a/activemq-core/src/main/java/org/apache/activemq/broker/BrokerRegistry.java
+++ b/activemq-core/src/main/java/org/apache/activemq/broker/BrokerRegistry.java
@@ -20,15 +20,15 @@ import java.util.Collections;
import java.util.HashMap;
import java.util.Iterator;
import java.util.Map;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
/**
* @version $Revision: 1.3 $
*/
public class BrokerRegistry {
- private static final Log LOG = LogFactory.getLog(BrokerRegistry.class);
+ private static final Logger LOG = LoggerFactory.getLogger(BrokerRegistry.class);
private static final BrokerRegistry INSTANCE = new BrokerRegistry();
private final Object mutex = new Object();
diff --git a/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java b/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java
index 0fb7b1e0b1..add9dc4515 100644
--- a/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java
+++ b/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java
@@ -92,8 +92,8 @@ import org.apache.activemq.transport.TransportServer;
import org.apache.activemq.transport.vm.VMTransportFactory;
import org.apache.activemq.usage.SystemUsage;
import org.apache.activemq.util.*;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
/**
* Manages the lifecycle of an ActiveMQ Broker. A BrokerService consists of a
* number of transport connectors, network connectors and a bunch of properties
@@ -107,7 +107,7 @@ public class BrokerService implements Service {
public static final String DEFAULT_PORT = "61616";
public static final String LOCAL_HOST_NAME;
public static final String DEFAULT_BROKER_NAME = "localhost";
- private static final Log LOG = LogFactory.getLog(BrokerService.class);
+ private static final Logger LOG = LoggerFactory.getLogger(BrokerService.class);
private static final long serialVersionUID = 7353129142305630237L;
private boolean useJmx = true;
private boolean enableStatistics = true;
@@ -412,7 +412,7 @@ public class BrokerService implements Service {
public void masterFailed() {
if (shutdownOnMasterFailure) {
- LOG.fatal("The Master has failed ... shutting down");
+ LOG.error("The Master has failed ... shutting down");
try {
stop();
} catch (Exception e) {
@@ -893,7 +893,7 @@ public class BrokerService implements Service {
}
return systemUsage;
} catch (IOException e) {
- LOG.fatal("Cannot create SystemUsage", e);
+ LOG.error("Cannot create SystemUsage", e);
throw new RuntimeException("Fatally failed to create SystemUsage" + e.getMessage());
}
}
diff --git a/activemq-core/src/main/java/org/apache/activemq/broker/ProducerBrokerExchange.java b/activemq-core/src/main/java/org/apache/activemq/broker/ProducerBrokerExchange.java
index eff6bd225e..c33eb641fd 100755
--- a/activemq-core/src/main/java/org/apache/activemq/broker/ProducerBrokerExchange.java
+++ b/activemq-core/src/main/java/org/apache/activemq/broker/ProducerBrokerExchange.java
@@ -20,8 +20,8 @@ import org.apache.activemq.broker.region.Destination;
import org.apache.activemq.broker.region.Region;
import org.apache.activemq.command.Message;
import org.apache.activemq.state.ProducerState;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
/**
* Holds internal state in the broker for a MessageProducer
@@ -30,7 +30,7 @@ import org.apache.commons.logging.LogFactory;
*/
public class ProducerBrokerExchange {
- private static final Log LOG = LogFactory.getLog(ProducerBrokerExchange.class);
+ private static final Logger LOG = LoggerFactory.getLogger(ProducerBrokerExchange.class);
private ConnectionContext connectionContext;
private Destination regionDestination;
private Region region;
diff --git a/activemq-core/src/main/java/org/apache/activemq/broker/TransactionBroker.java b/activemq-core/src/main/java/org/apache/activemq/broker/TransactionBroker.java
index d2c1bf5da1..c4995f74d7 100755
--- a/activemq-core/src/main/java/org/apache/activemq/broker/TransactionBroker.java
+++ b/activemq-core/src/main/java/org/apache/activemq/broker/TransactionBroker.java
@@ -40,8 +40,8 @@ import org.apache.activemq.transaction.Transaction;
import org.apache.activemq.transaction.XATransaction;
import org.apache.activemq.util.IOExceptionSupport;
import org.apache.activemq.util.WrappedException;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
/**
* This broker filter handles the transaction related operations in the Broker
@@ -51,7 +51,7 @@ import org.apache.commons.logging.LogFactory;
*/
public class TransactionBroker extends BrokerFilter {
- private static final Log LOG = LogFactory.getLog(TransactionBroker.class);
+ private static final Logger LOG = LoggerFactory.getLogger(TransactionBroker.class);
// The prepared XA transactions.
private TransactionStore transactionStore;
diff --git a/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnection.java b/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnection.java
index f335495b0e..330a39e0ee 100755
--- a/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnection.java
+++ b/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnection.java
@@ -94,17 +94,17 @@ import org.apache.activemq.util.IntrospectionSupport;
import org.apache.activemq.util.MarshallingSupport;
import org.apache.activemq.util.ServiceSupport;
import org.apache.activemq.util.URISupport;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
import static org.apache.activemq.thread.DefaultThreadPools.getDefaultTaskRunnerFactory;
/**
* @version $Revision: 1.8 $
*/
public class TransportConnection implements Connection, Task, CommandVisitor {
- private static final Log LOG = LogFactory.getLog(TransportConnection.class);
- private static final Log TRANSPORTLOG = LogFactory.getLog(TransportConnection.class.getName() + ".Transport");
- private static final Log SERVICELOG = LogFactory.getLog(TransportConnection.class.getName() + ".Service");
+ private static final Logger LOG = LoggerFactory.getLogger(TransportConnection.class);
+ private static final Logger TRANSPORTLOG = LoggerFactory.getLogger(TransportConnection.class.getName() + ".Transport");
+ private static final Logger SERVICELOG = LoggerFactory.getLogger(TransportConnection.class.getName() + ".Service");
// Keeps track of the broker and connector that created this connection.
protected final Broker broker;
protected final TransportConnector connector;
diff --git a/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnector.java b/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnector.java
index 56d1b2f77e..9e01c04985 100755
--- a/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnector.java
+++ b/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnector.java
@@ -40,8 +40,8 @@ import org.apache.activemq.transport.discovery.DiscoveryAgent;
import org.apache.activemq.transport.discovery.DiscoveryAgentFactory;
import org.apache.activemq.util.ServiceStopper;
import org.apache.activemq.util.ServiceSupport;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
/**
* @org.apache.xbean.XBean
@@ -49,7 +49,7 @@ import org.apache.commons.logging.LogFactory;
*/
public class TransportConnector implements Connector, BrokerServiceAware {
- final Log LOG = LogFactory.getLog(TransportConnector.class);
+ final Logger LOG = LoggerFactory.getLogger(TransportConnector.class);
protected CopyOnWriteArrayList connections = new CopyOnWriteArrayList();
protected TransportStatusDetector statusDector;
diff --git a/activemq-core/src/main/java/org/apache/activemq/broker/TransportStatusDetector.java b/activemq-core/src/main/java/org/apache/activemq/broker/TransportStatusDetector.java
index 41ad06ec1a..2600f44cd4 100755
--- a/activemq-core/src/main/java/org/apache/activemq/broker/TransportStatusDetector.java
+++ b/activemq-core/src/main/java/org/apache/activemq/broker/TransportStatusDetector.java
@@ -23,8 +23,8 @@ import java.util.concurrent.atomic.AtomicBoolean;
import org.apache.activemq.Service;
import org.apache.activemq.ThreadPriorities;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
/**
* Used to provide information on the status of the Connection
@@ -32,7 +32,7 @@ import org.apache.commons.logging.LogFactory;
* @version $Revision: 1.5 $
*/
public class TransportStatusDetector implements Service, Runnable {
- private static final Log LOG = LogFactory.getLog(TransportStatusDetector.class);
+ private static final Logger LOG = LoggerFactory.getLogger(TransportStatusDetector.class);
private TransportConnector connector;
private Set collectionCandidates = new CopyOnWriteArraySet();
private AtomicBoolean started = new AtomicBoolean(false);
diff --git a/activemq-core/src/main/java/org/apache/activemq/broker/cluster/ConnectionSplitBroker.java b/activemq-core/src/main/java/org/apache/activemq/broker/cluster/ConnectionSplitBroker.java
index 8ec9c35543..c14b1739e4 100644
--- a/activemq-core/src/main/java/org/apache/activemq/broker/cluster/ConnectionSplitBroker.java
+++ b/activemq-core/src/main/java/org/apache/activemq/broker/cluster/ConnectionSplitBroker.java
@@ -26,8 +26,8 @@ import org.apache.activemq.broker.region.Subscription;
import org.apache.activemq.command.ActiveMQDestination;
import org.apache.activemq.command.ConsumerId;
import org.apache.activemq.command.ConsumerInfo;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
/**
* Monitors for client connections that may fail to another broker - but this
@@ -37,7 +37,7 @@ import org.apache.commons.logging.LogFactory;
* @version $Revision$
*/
public class ConnectionSplitBroker extends BrokerFilter{
- private static final Log LOG = LogFactory.getLog(ConnectionSplitBroker.class);
+ private static final Logger LOG = LoggerFactory.getLogger(ConnectionSplitBroker.class);
private ListnetworkConsumerList = new ArrayList();
public ConnectionSplitBroker(Broker next) {
super(next);
diff --git a/activemq-core/src/main/java/org/apache/activemq/broker/ft/MasterBroker.java b/activemq-core/src/main/java/org/apache/activemq/broker/ft/MasterBroker.java
index 46f437123e..da15d1229d 100755
--- a/activemq-core/src/main/java/org/apache/activemq/broker/ft/MasterBroker.java
+++ b/activemq-core/src/main/java/org/apache/activemq/broker/ft/MasterBroker.java
@@ -48,8 +48,8 @@ import org.apache.activemq.command.TransactionInfo;
import org.apache.activemq.transport.MutexTransport;
import org.apache.activemq.transport.ResponseCorrelator;
import org.apache.activemq.transport.Transport;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
/**
* The Message Broker which passes messages to a slave
@@ -58,7 +58,7 @@ import org.apache.commons.logging.LogFactory;
*/
public class MasterBroker extends InsertableMutableBrokerFilter {
- private static final Log LOG = LogFactory.getLog(MasterBroker.class);
+ private static final Logger LOG = LoggerFactory.getLogger(MasterBroker.class);
private Transport slave;
private AtomicBoolean started = new AtomicBoolean(false);
diff --git a/activemq-core/src/main/java/org/apache/activemq/broker/ft/MasterConnector.java b/activemq-core/src/main/java/org/apache/activemq/broker/ft/MasterConnector.java
index 038b22292c..e7a2c35fef 100644
--- a/activemq-core/src/main/java/org/apache/activemq/broker/ft/MasterConnector.java
+++ b/activemq-core/src/main/java/org/apache/activemq/broker/ft/MasterConnector.java
@@ -43,8 +43,8 @@ import org.apache.activemq.transport.TransportFactory;
import org.apache.activemq.util.IdGenerator;
import org.apache.activemq.util.ServiceStopper;
import org.apache.activemq.util.ServiceSupport;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
/**
* Connects a Slave Broker to a Master when using > primitives = new HashMap>();
- private static final Log LOG = LogFactory.getLog("org.apache.activemq.audit");
+ private static final Logger LOG = LoggerFactory.getLogger("org.apache.activemq.audit");
private static boolean audit;
private static AuditLogService auditLog;
diff --git a/activemq-core/src/main/java/org/apache/activemq/broker/jmx/DestinationView.java b/activemq-core/src/main/java/org/apache/activemq/broker/jmx/DestinationView.java
index 6a1cc0ad94..830f0dd301 100644
--- a/activemq-core/src/main/java/org/apache/activemq/broker/jmx/DestinationView.java
+++ b/activemq-core/src/main/java/org/apache/activemq/broker/jmx/DestinationView.java
@@ -48,11 +48,11 @@ import org.apache.activemq.command.Message;
import org.apache.activemq.filter.BooleanExpression;
import org.apache.activemq.filter.MessageEvaluationContext;
import org.apache.activemq.selector.SelectorParser;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
public class DestinationView implements DestinationViewMBean {
- private static final Log LOG = LogFactory.getLog(DestinationViewMBean.class);
+ private static final Logger LOG = LoggerFactory.getLogger(DestinationViewMBean.class);
protected final Destination destination;
protected final ManagedRegionBroker broker;
diff --git a/activemq-core/src/main/java/org/apache/activemq/broker/jmx/ManagedRegionBroker.java b/activemq-core/src/main/java/org/apache/activemq/broker/jmx/ManagedRegionBroker.java
index 4a1ba20f39..6df655e13b 100755
--- a/activemq-core/src/main/java/org/apache/activemq/broker/jmx/ManagedRegionBroker.java
+++ b/activemq-core/src/main/java/org/apache/activemq/broker/jmx/ManagedRegionBroker.java
@@ -71,11 +71,11 @@ import org.apache.activemq.usage.SystemUsage;
import org.apache.activemq.util.JMXSupport;
import org.apache.activemq.util.ServiceStopper;
import org.apache.activemq.util.SubscriptionKey;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
public class ManagedRegionBroker extends RegionBroker {
- private static final Log LOG = LogFactory.getLog(ManagedRegionBroker.class);
+ private static final Logger LOG = LoggerFactory.getLogger(ManagedRegionBroker.class);
private final ManagementContext managementContext;
private final ObjectName brokerObjectName;
private final Map topics = new ConcurrentHashMap();
diff --git a/activemq-core/src/main/java/org/apache/activemq/broker/jmx/ManagedTransportConnection.java b/activemq-core/src/main/java/org/apache/activemq/broker/jmx/ManagedTransportConnection.java
index 4bd01b469d..1228bb5527 100644
--- a/activemq-core/src/main/java/org/apache/activemq/broker/jmx/ManagedTransportConnection.java
+++ b/activemq-core/src/main/java/org/apache/activemq/broker/jmx/ManagedTransportConnection.java
@@ -25,8 +25,8 @@ import org.apache.activemq.thread.TaskRunnerFactory;
import org.apache.activemq.transport.Transport;
import org.apache.activemq.util.IOExceptionSupport;
import org.apache.activemq.util.JMXSupport;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
import java.io.IOException;
import java.util.Hashtable;
import javax.management.ObjectName;
@@ -37,7 +37,7 @@ import javax.management.ObjectName;
* @version $Revision: 1.1 $
*/
public class ManagedTransportConnection extends TransportConnection {
- private static final Log LOG = LogFactory.getLog(ManagedTransportConnection.class);
+ private static final Logger LOG = LoggerFactory.getLogger(ManagedTransportConnection.class);
private final ManagementContext managementContext;
private final ObjectName connectorName;
diff --git a/activemq-core/src/main/java/org/apache/activemq/broker/jmx/ManagementContext.java b/activemq-core/src/main/java/org/apache/activemq/broker/jmx/ManagementContext.java
index 928a5def66..3a95d3ff56 100644
--- a/activemq-core/src/main/java/org/apache/activemq/broker/jmx/ManagementContext.java
+++ b/activemq-core/src/main/java/org/apache/activemq/broker/jmx/ManagementContext.java
@@ -17,8 +17,8 @@
package org.apache.activemq.broker.jmx;
import org.apache.activemq.Service;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
import javax.management.*;
import javax.management.remote.JMXConnectorServer;
@@ -46,7 +46,7 @@ public class ManagementContext implements Service {
* Default activemq domain
*/
public static final String DEFAULT_DOMAIN = "org.apache.activemq";
- private static final Log LOG = LogFactory.getLog(ManagementContext.class);
+ private static final Logger LOG = LoggerFactory.getLogger(ManagementContext.class);
private MBeanServer beanServer;
private String jmxDomainName = DEFAULT_DOMAIN;
private boolean useMBeanServer = true;
diff --git a/activemq-core/src/main/java/org/apache/activemq/broker/region/AbstractRegion.java b/activemq-core/src/main/java/org/apache/activemq/broker/region/AbstractRegion.java
index f03e50c577..4b6d98ff81 100755
--- a/activemq-core/src/main/java/org/apache/activemq/broker/region/AbstractRegion.java
+++ b/activemq-core/src/main/java/org/apache/activemq/broker/region/AbstractRegion.java
@@ -44,15 +44,15 @@ import org.apache.activemq.filter.DestinationMap;
import org.apache.activemq.security.SecurityContext;
import org.apache.activemq.thread.TaskRunnerFactory;
import org.apache.activemq.usage.SystemUsage;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
/**
* @version $Revision: 1.14 $
*/
public abstract class AbstractRegion implements Region {
- private static final Log LOG = LogFactory.getLog(AbstractRegion.class);
+ private static final Logger LOG = LoggerFactory.getLogger(AbstractRegion.class);
protected final Map destinations = new ConcurrentHashMap();
protected final DestinationMap destinationMap = new DestinationMap();
diff --git a/activemq-core/src/main/java/org/apache/activemq/broker/region/AbstractSubscription.java b/activemq-core/src/main/java/org/apache/activemq/broker/region/AbstractSubscription.java
index e3e1c1a418..581784e8fc 100755
--- a/activemq-core/src/main/java/org/apache/activemq/broker/region/AbstractSubscription.java
+++ b/activemq-core/src/main/java/org/apache/activemq/broker/region/AbstractSubscription.java
@@ -34,12 +34,12 @@ import org.apache.activemq.filter.LogicExpression;
import org.apache.activemq.filter.MessageEvaluationContext;
import org.apache.activemq.filter.NoLocalExpression;
import org.apache.activemq.selector.SelectorParser;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
public abstract class AbstractSubscription implements Subscription {
- private static final Log LOG = LogFactory.getLog(AbstractSubscription.class);
+ private static final Logger LOG = LoggerFactory.getLogger(AbstractSubscription.class);
protected Broker broker;
protected ConnectionContext context;
protected ConsumerInfo info;
diff --git a/activemq-core/src/main/java/org/apache/activemq/broker/region/AbstractTempRegion.java b/activemq-core/src/main/java/org/apache/activemq/broker/region/AbstractTempRegion.java
index c106b10779..7469c90c24 100644
--- a/activemq-core/src/main/java/org/apache/activemq/broker/region/AbstractTempRegion.java
+++ b/activemq-core/src/main/java/org/apache/activemq/broker/region/AbstractTempRegion.java
@@ -27,14 +27,14 @@ import org.apache.activemq.broker.ConnectionContext;
import org.apache.activemq.command.ActiveMQDestination;
import org.apache.activemq.thread.TaskRunnerFactory;
import org.apache.activemq.usage.SystemUsage;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
/**
*
*/
public abstract class AbstractTempRegion extends AbstractRegion {
- private static final Log LOG = LogFactory.getLog(TempQueueRegion.class);
+ private static final Logger LOG = LoggerFactory.getLogger(TempQueueRegion.class);
private Map cachedDestinations = new HashMap();
private final boolean doCacheTempDestinations;
diff --git a/activemq-core/src/main/java/org/apache/activemq/broker/region/BaseDestination.java b/activemq-core/src/main/java/org/apache/activemq/broker/region/BaseDestination.java
index 39488d632d..cd22c6003d 100755
--- a/activemq-core/src/main/java/org/apache/activemq/broker/region/BaseDestination.java
+++ b/activemq-core/src/main/java/org/apache/activemq/broker/region/BaseDestination.java
@@ -35,7 +35,7 @@ import org.apache.activemq.store.MessageStore;
import org.apache.activemq.usage.MemoryUsage;
import org.apache.activemq.usage.SystemUsage;
import org.apache.activemq.usage.Usage;
-import org.apache.commons.logging.Log;
+import org.slf4j.Logger;
/**
* @version $Revision: 1.12 $
@@ -600,7 +600,7 @@ public abstract class BaseDestination implements Destination {
}
}
- protected abstract Log getLog();
+ protected abstract Logger getLog();
public void setSlowConsumerStrategy(SlowConsumerStrategy slowConsumerStrategy) {
this.slowConsumerStrategy = slowConsumerStrategy;
diff --git a/activemq-core/src/main/java/org/apache/activemq/broker/region/DurableTopicSubscription.java b/activemq-core/src/main/java/org/apache/activemq/broker/region/DurableTopicSubscription.java
index 83fafca35b..091ad523a5 100755
--- a/activemq-core/src/main/java/org/apache/activemq/broker/region/DurableTopicSubscription.java
+++ b/activemq-core/src/main/java/org/apache/activemq/broker/region/DurableTopicSubscription.java
@@ -40,12 +40,12 @@ import org.apache.activemq.usage.SystemUsage;
import org.apache.activemq.usage.Usage;
import org.apache.activemq.usage.UsageListener;
import org.apache.activemq.util.SubscriptionKey;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
public class DurableTopicSubscription extends PrefetchSubscription implements UsageListener {
- private static final Log LOG = LogFactory.getLog(DurableTopicSubscription.class);
+ private static final Logger LOG = LoggerFactory.getLogger(DurableTopicSubscription.class);
private final ConcurrentHashMap redeliveredMessages = new ConcurrentHashMap();
private final ConcurrentHashMap destinations = new ConcurrentHashMap();
private final SubscriptionKey subscriptionKey;
diff --git a/activemq-core/src/main/java/org/apache/activemq/broker/region/PrefetchSubscription.java b/activemq-core/src/main/java/org/apache/activemq/broker/region/PrefetchSubscription.java
index 54c758f64e..9e2b4cc6bc 100755
--- a/activemq-core/src/main/java/org/apache/activemq/broker/region/PrefetchSubscription.java
+++ b/activemq-core/src/main/java/org/apache/activemq/broker/region/PrefetchSubscription.java
@@ -41,8 +41,8 @@ import org.apache.activemq.command.Response;
import org.apache.activemq.thread.Scheduler;
import org.apache.activemq.transaction.Synchronization;
import org.apache.activemq.usage.SystemUsage;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
/**
* A subscription that honors the pre-fetch option of the ConsumerInfo.
@@ -51,7 +51,7 @@ import org.apache.commons.logging.LogFactory;
*/
public abstract class PrefetchSubscription extends AbstractSubscription {
- private static final Log LOG = LogFactory.getLog(PrefetchSubscription.class);
+ private static final Logger LOG = LoggerFactory.getLogger(PrefetchSubscription.class);
protected final Scheduler scheduler;
protected PendingMessageCursor pending;
diff --git a/activemq-core/src/main/java/org/apache/activemq/broker/region/Queue.java b/activemq-core/src/main/java/org/apache/activemq/broker/region/Queue.java
index 9e5f34b791..185d2150ac 100755
--- a/activemq-core/src/main/java/org/apache/activemq/broker/region/Queue.java
+++ b/activemq-core/src/main/java/org/apache/activemq/broker/region/Queue.java
@@ -71,8 +71,8 @@ import org.apache.activemq.transaction.Synchronization;
import org.apache.activemq.usage.Usage;
import org.apache.activemq.usage.UsageListener;
import org.apache.activemq.util.BrokerSupport;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
/**
* The Queue is a List of MessageEntry objects that are dispatched to matching
@@ -81,7 +81,7 @@ import org.apache.commons.logging.LogFactory;
* @version $Revision: 1.28 $
*/
public class Queue extends BaseDestination implements Task, UsageListener {
- protected static final Log LOG = LogFactory.getLog(Queue.class);
+ protected static final Logger LOG = LoggerFactory.getLogger(Queue.class);
protected final TaskRunnerFactory taskFactory;
protected TaskRunner taskRunner;
private final ReentrantReadWriteLock consumersLock = new ReentrantReadWriteLock();
@@ -294,7 +294,7 @@ public class Queue extends BaseDestination implements Task, UsageListener {
try {
messages.addMessageLast(message);
} catch (Exception e) {
- LOG.fatal("Failed to add message to cursor", e);
+ LOG.error("Failed to add message to cursor", e);
}
}finally {
messagesLock.writeLock().unlock();
@@ -1405,7 +1405,7 @@ public class Queue extends BaseDestination implements Task, UsageListener {
}
}
} catch (Exception e) {
- LOG.error(e);
+ LOG.error(e.toString());
}
}
@@ -2057,7 +2057,7 @@ public class Queue extends BaseDestination implements Task, UsageListener {
}
@Override
- protected Log getLog() {
+ protected Logger getLog() {
return LOG;
}
}
diff --git a/activemq-core/src/main/java/org/apache/activemq/broker/region/QueueDispatchSelector.java b/activemq-core/src/main/java/org/apache/activemq/broker/region/QueueDispatchSelector.java
index 481c0f206a..47908296dc 100644
--- a/activemq-core/src/main/java/org/apache/activemq/broker/region/QueueDispatchSelector.java
+++ b/activemq-core/src/main/java/org/apache/activemq/broker/region/QueueDispatchSelector.java
@@ -27,8 +27,8 @@ import org.apache.activemq.command.ActiveMQDestination;
import org.apache.activemq.command.ActiveMQMessage;
import org.apache.activemq.command.ConsumerId;
import org.apache.activemq.command.Message;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
/**
* Queue dispatch policy that determines if a message can be sent to a subscription
@@ -37,7 +37,7 @@ import org.apache.commons.logging.LogFactory;
* @version $Revision$
*/
public class QueueDispatchSelector extends SimpleDispatchSelector {
- private static final Log LOG = LogFactory.getLog(QueueDispatchSelector.class);
+ private static final Logger LOG = LoggerFactory.getLogger(QueueDispatchSelector.class);
private Subscription exclusiveConsumer;
diff --git a/activemq-core/src/main/java/org/apache/activemq/broker/region/QueueSubscription.java b/activemq-core/src/main/java/org/apache/activemq/broker/region/QueueSubscription.java
index eb95d381f7..40a4f70e1f 100755
--- a/activemq-core/src/main/java/org/apache/activemq/broker/region/QueueSubscription.java
+++ b/activemq-core/src/main/java/org/apache/activemq/broker/region/QueueSubscription.java
@@ -27,12 +27,12 @@ import org.apache.activemq.command.ConsumerInfo;
import org.apache.activemq.command.Message;
import org.apache.activemq.command.MessageAck;
import org.apache.activemq.usage.SystemUsage;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
public class QueueSubscription extends PrefetchSubscription implements LockOwner {
- private static final Log LOG = LogFactory.getLog(QueueSubscription.class);
+ private static final Logger LOG = LoggerFactory.getLogger(QueueSubscription.class);
public QueueSubscription(Broker broker, SystemUsage usageManager, ConnectionContext context, ConsumerInfo info) throws InvalidSelectorException {
super(broker,usageManager, context, info);
diff --git a/activemq-core/src/main/java/org/apache/activemq/broker/region/RegionBroker.java b/activemq-core/src/main/java/org/apache/activemq/broker/region/RegionBroker.java
index 5328b1569c..761131db50 100755
--- a/activemq-core/src/main/java/org/apache/activemq/broker/region/RegionBroker.java
+++ b/activemq-core/src/main/java/org/apache/activemq/broker/region/RegionBroker.java
@@ -67,8 +67,8 @@ import org.apache.activemq.util.IdGenerator;
import org.apache.activemq.util.InetAddressUtil;
import org.apache.activemq.util.LongSequenceGenerator;
import org.apache.activemq.util.ServiceStopper;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
/**
* Routes Broker operations to the correct messaging regions for processing.
@@ -77,7 +77,7 @@ import org.apache.commons.logging.LogFactory;
*/
public class RegionBroker extends EmptyBroker {
public static final String ORIGINAL_EXPIRATION = "originalExpiration";
- private static final Log LOG = LogFactory.getLog(RegionBroker.class);
+ private static final Logger LOG = LoggerFactory.getLogger(RegionBroker.class);
private static final IdGenerator BROKER_ID_GENERATOR = new IdGenerator();
protected final DestinationStatistics destinationStatistics = new DestinationStatistics();
@@ -861,7 +861,7 @@ public class RegionBroker extends EmptyBroker {
try {
return getBrokerService().getBroker();
} catch (Exception e) {
- LOG.fatal("Trying to get Root Broker " + e);
+ LOG.error("Trying to get Root Broker " + e);
throw new RuntimeException("The broker from the BrokerService should not throw an exception");
}
}
diff --git a/activemq-core/src/main/java/org/apache/activemq/broker/region/TempQueue.java b/activemq-core/src/main/java/org/apache/activemq/broker/region/TempQueue.java
index 4c3b82b374..3c50f7a02f 100755
--- a/activemq-core/src/main/java/org/apache/activemq/broker/region/TempQueue.java
+++ b/activemq-core/src/main/java/org/apache/activemq/broker/region/TempQueue.java
@@ -24,8 +24,8 @@ import org.apache.activemq.command.ActiveMQDestination;
import org.apache.activemq.command.ActiveMQTempDestination;
import org.apache.activemq.store.MessageStore;
import org.apache.activemq.thread.TaskRunnerFactory;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
/**
* The Queue is a List of MessageEntry objects that are dispatched to matching
@@ -34,7 +34,7 @@ import org.apache.commons.logging.LogFactory;
* @version $Revision: 1.28 $
*/
public class TempQueue extends Queue{
- private static final Log LOG = LogFactory.getLog(TempQueue.class);
+ private static final Logger LOG = LoggerFactory.getLogger(TempQueue.class);
private final ActiveMQTempDestination tempDest;
diff --git a/activemq-core/src/main/java/org/apache/activemq/broker/region/TempQueueRegion.java b/activemq-core/src/main/java/org/apache/activemq/broker/region/TempQueueRegion.java
index 1eb1612ffc..1ab34fd5ef 100755
--- a/activemq-core/src/main/java/org/apache/activemq/broker/region/TempQueueRegion.java
+++ b/activemq-core/src/main/java/org/apache/activemq/broker/region/TempQueueRegion.java
@@ -26,14 +26,14 @@ import org.apache.activemq.command.ConsumerInfo;
import org.apache.activemq.command.MessageDispatchNotification;
import org.apache.activemq.thread.TaskRunnerFactory;
import org.apache.activemq.usage.SystemUsage;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
/**
* @version $Revision: 1.7 $
*/
public class TempQueueRegion extends AbstractTempRegion {
- private static final Log LOG = LogFactory.getLog(TempQueueRegion.class);
+ private static final Logger LOG = LoggerFactory.getLogger(TempQueueRegion.class);
private final BrokerService brokerService;
public TempQueueRegion(RegionBroker broker, BrokerService brokerService, DestinationStatistics destinationStatistics, SystemUsage memoryManager, TaskRunnerFactory taskRunnerFactory,
diff --git a/activemq-core/src/main/java/org/apache/activemq/broker/region/TempTopicRegion.java b/activemq-core/src/main/java/org/apache/activemq/broker/region/TempTopicRegion.java
index 9ce31efffd..12933ad92c 100755
--- a/activemq-core/src/main/java/org/apache/activemq/broker/region/TempTopicRegion.java
+++ b/activemq-core/src/main/java/org/apache/activemq/broker/region/TempTopicRegion.java
@@ -24,15 +24,15 @@ import org.apache.activemq.command.ActiveMQDestination;
import org.apache.activemq.command.ConsumerInfo;
import org.apache.activemq.thread.TaskRunnerFactory;
import org.apache.activemq.usage.SystemUsage;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
/**
* @version $Revision: 1.7 $
*/
public class TempTopicRegion extends AbstractTempRegion {
- private static final Log LOG = LogFactory.getLog(TempTopicRegion.class);
+ private static final Logger LOG = LoggerFactory.getLogger(TempTopicRegion.class);
public TempTopicRegion(RegionBroker broker, DestinationStatistics destinationStatistics, SystemUsage memoryManager, TaskRunnerFactory taskRunnerFactory,
DestinationFactory destinationFactory) {
diff --git a/activemq-core/src/main/java/org/apache/activemq/broker/region/Topic.java b/activemq-core/src/main/java/org/apache/activemq/broker/region/Topic.java
index 0a4d533674..d5fa89589b 100755
--- a/activemq-core/src/main/java/org/apache/activemq/broker/region/Topic.java
+++ b/activemq-core/src/main/java/org/apache/activemq/broker/region/Topic.java
@@ -52,8 +52,8 @@ import org.apache.activemq.thread.TaskRunnerFactory;
import org.apache.activemq.thread.Valve;
import org.apache.activemq.transaction.Synchronization;
import org.apache.activemq.util.SubscriptionKey;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
/**
* The Topic is a destination that sends a copy of a message to every active
@@ -62,7 +62,7 @@ import org.apache.commons.logging.LogFactory;
* @version $Revision: 1.21 $
*/
public class Topic extends BaseDestination implements Task {
- protected static final Log LOG = LogFactory.getLog(Topic.class);
+ protected static final Logger LOG = LoggerFactory.getLogger(Topic.class);
private final TopicMessageStore topicStore;
protected final CopyOnWriteArrayList consumers = new CopyOnWriteArrayList();
protected final Valve dispatchValve = new Valve(true);
@@ -662,7 +662,7 @@ public class Topic extends BaseDestination implements Task {
}
@Override
- protected Log getLog() {
+ protected Logger getLog() {
return LOG;
}
diff --git a/activemq-core/src/main/java/org/apache/activemq/broker/region/TopicRegion.java b/activemq-core/src/main/java/org/apache/activemq/broker/region/TopicRegion.java
index a29829b859..44fc5876b9 100755
--- a/activemq-core/src/main/java/org/apache/activemq/broker/region/TopicRegion.java
+++ b/activemq-core/src/main/java/org/apache/activemq/broker/region/TopicRegion.java
@@ -38,14 +38,14 @@ import org.apache.activemq.thread.TaskRunnerFactory;
import org.apache.activemq.usage.SystemUsage;
import org.apache.activemq.util.LongSequenceGenerator;
import org.apache.activemq.util.SubscriptionKey;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
/**
* @version $Revision: 1.12 $
*/
public class TopicRegion extends AbstractRegion {
- private static final Log LOG = LogFactory.getLog(TopicRegion.class);
+ private static final Logger LOG = LoggerFactory.getLogger(TopicRegion.class);
protected final ConcurrentHashMap durableSubscriptions = new ConcurrentHashMap();
private final LongSequenceGenerator recoveredDurableSubIdGenerator = new LongSequenceGenerator();
private final SessionId recoveredDurableSubSessionId = new SessionId(new ConnectionId("OFFLINE"), recoveredDurableSubIdGenerator.getNextSequenceId());
diff --git a/activemq-core/src/main/java/org/apache/activemq/broker/region/TopicSubscription.java b/activemq-core/src/main/java/org/apache/activemq/broker/region/TopicSubscription.java
index 5a876f8660..2fe405a1f2 100755
--- a/activemq-core/src/main/java/org/apache/activemq/broker/region/TopicSubscription.java
+++ b/activemq-core/src/main/java/org/apache/activemq/broker/region/TopicSubscription.java
@@ -38,12 +38,12 @@ import org.apache.activemq.command.MessagePull;
import org.apache.activemq.command.Response;
import org.apache.activemq.transaction.Synchronization;
import org.apache.activemq.usage.SystemUsage;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
public class TopicSubscription extends AbstractSubscription {
- private static final Log LOG = LogFactory.getLog(TopicSubscription.class);
+ private static final Logger LOG = LoggerFactory.getLogger(TopicSubscription.class);
private static final AtomicLong CURSOR_NAME_COUNTER = new AtomicLong(0);
protected PendingMessageCursor matched;
diff --git a/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/AbstractStoreCursor.java b/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/AbstractStoreCursor.java
index d6edbbca62..8bd9f43365 100644
--- a/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/AbstractStoreCursor.java
+++ b/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/AbstractStoreCursor.java
@@ -22,15 +22,15 @@ import org.apache.activemq.broker.region.MessageReference;
import org.apache.activemq.command.Message;
import org.apache.activemq.command.MessageId;
import org.apache.activemq.store.MessageRecoveryListener;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
/**
* Store based cursor
*
*/
public abstract class AbstractStoreCursor extends AbstractPendingMessageCursor implements MessageRecoveryListener {
- private static final Log LOG = LogFactory.getLog(AbstractStoreCursor.class);
+ private static final Logger LOG = LoggerFactory.getLogger(AbstractStoreCursor.class);
protected final Destination regionDestination;
private final PendingList batchList;
private Iterator iterator = null;
diff --git a/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/FilePendingMessageCursor.java b/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/FilePendingMessageCursor.java
index 55b2201573..2b4d812a54 100755
--- a/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/FilePendingMessageCursor.java
+++ b/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/FilePendingMessageCursor.java
@@ -36,8 +36,8 @@ import org.apache.activemq.usage.SystemUsage;
import org.apache.activemq.usage.Usage;
import org.apache.activemq.usage.UsageListener;
import org.apache.activemq.wireformat.WireFormat;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
import org.apache.kahadb.util.ByteSequence;
/**
@@ -47,7 +47,7 @@ import org.apache.kahadb.util.ByteSequence;
* @version $Revision$
*/
public class FilePendingMessageCursor extends AbstractPendingMessageCursor implements UsageListener {
- static final Log LOG = LogFactory.getLog(FilePendingMessageCursor.class);
+ static final Logger LOG = LoggerFactory.getLogger(FilePendingMessageCursor.class);
private static final AtomicLong NAME_COUNT = new AtomicLong();
protected Broker broker;
private final PListStore store;
diff --git a/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/QueueStorePrefetch.java b/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/QueueStorePrefetch.java
index 77ee08c91b..c607782f43 100755
--- a/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/QueueStorePrefetch.java
+++ b/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/QueueStorePrefetch.java
@@ -21,8 +21,8 @@ import org.apache.activemq.broker.region.Queue;
import org.apache.activemq.command.Message;
import org.apache.activemq.command.MessageId;
import org.apache.activemq.store.MessageStore;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
/**
* persist pending messages pending message (messages awaiting dispatch to a
@@ -31,7 +31,7 @@ import org.apache.commons.logging.LogFactory;
* @version $Revision: 474985 $
*/
class QueueStorePrefetch extends AbstractStoreCursor {
- private static final Log LOG = LogFactory.getLog(QueueStorePrefetch.class);
+ private static final Logger LOG = LoggerFactory.getLogger(QueueStorePrefetch.class);
private final MessageStore store;
/**
diff --git a/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/StoreDurableSubscriberCursor.java b/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/StoreDurableSubscriberCursor.java
index 1f6379d5f6..8d67195147 100755
--- a/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/StoreDurableSubscriberCursor.java
+++ b/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/StoreDurableSubscriberCursor.java
@@ -30,8 +30,8 @@ import org.apache.activemq.broker.region.Subscription;
import org.apache.activemq.broker.region.Topic;
import org.apache.activemq.command.Message;
import org.apache.activemq.usage.SystemUsage;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
/**
* persist pending messages pending message (messages awaiting dispatch to a
@@ -41,7 +41,7 @@ import org.apache.commons.logging.LogFactory;
*/
public class StoreDurableSubscriberCursor extends AbstractPendingMessageCursor {
- private static final Log LOG = LogFactory.getLog(StoreDurableSubscriberCursor.class);
+ private static final Logger LOG = LoggerFactory.getLogger(StoreDurableSubscriberCursor.class);
private static final int UNKNOWN = -1;
private final String clientId;
private final String subscriberName;
diff --git a/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/StoreQueueCursor.java b/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/StoreQueueCursor.java
index eea0cd346f..73c5a720e7 100755
--- a/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/StoreQueueCursor.java
+++ b/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/StoreQueueCursor.java
@@ -21,8 +21,8 @@ import org.apache.activemq.broker.region.MessageReference;
import org.apache.activemq.broker.region.Queue;
import org.apache.activemq.command.Message;
import org.apache.activemq.usage.SystemUsage;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
/**
* Store based Cursor for Queues
@@ -31,7 +31,7 @@ import org.apache.commons.logging.LogFactory;
*/
public class StoreQueueCursor extends AbstractPendingMessageCursor {
- private static final Log LOG = LogFactory.getLog(StoreQueueCursor.class);
+ private static final Logger LOG = LoggerFactory.getLogger(StoreQueueCursor.class);
private final Broker broker;
private int pendingCount;
private final Queue queue;
diff --git a/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/TopicStorePrefetch.java b/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/TopicStorePrefetch.java
index 800e8268c0..7280291f61 100755
--- a/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/TopicStorePrefetch.java
+++ b/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/TopicStorePrefetch.java
@@ -23,8 +23,8 @@ import org.apache.activemq.command.MessageId;
import org.apache.activemq.filter.MessageEvaluationContext;
import org.apache.activemq.filter.NonCachedMessageEvaluationContext;
import org.apache.activemq.store.TopicMessageStore;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
/**
* persist pendingCount messages pendingCount message (messages awaiting disptach
@@ -33,7 +33,7 @@ import org.apache.commons.logging.LogFactory;
* @version $Revision$
*/
class TopicStorePrefetch extends AbstractStoreCursor {
- private static final Log LOG = LogFactory.getLog(TopicStorePrefetch.class);
+ private static final Logger LOG = LoggerFactory.getLogger(TopicStorePrefetch.class);
private final TopicMessageStore store;
private final String clientId;
private final String subscriberName;
diff --git a/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/AbortSlowConsumerStrategy.java b/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/AbortSlowConsumerStrategy.java
index 61390deb22..05bd573005 100644
--- a/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/AbortSlowConsumerStrategy.java
+++ b/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/AbortSlowConsumerStrategy.java
@@ -29,8 +29,8 @@ import org.apache.activemq.broker.region.Subscription;
import org.apache.activemq.command.ConsumerControl;
import org.apache.activemq.thread.Scheduler;
import org.apache.activemq.transport.InactivityIOException;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
/**
* Abort slow consumers when they reach the configured threshold of slowness, default is slow for 30 seconds
@@ -39,7 +39,7 @@ import org.apache.commons.logging.LogFactory;
*/
public class AbortSlowConsumerStrategy implements SlowConsumerStrategy, Runnable {
- private static final Log LOG = LogFactory.getLog(AbortSlowConsumerStrategy.class);
+ private static final Logger LOG = LoggerFactory.getLogger(AbortSlowConsumerStrategy.class);
private String name = "AbortSlowConsumerStrategy@" + hashCode();
private Scheduler scheduler;
diff --git a/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/AbstractDeadLetterStrategy.java b/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/AbstractDeadLetterStrategy.java
index 7e98931dc3..2ab82b90c0 100644
--- a/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/AbstractDeadLetterStrategy.java
+++ b/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/AbstractDeadLetterStrategy.java
@@ -18,8 +18,8 @@ package org.apache.activemq.broker.region.policy;
import org.apache.activemq.ActiveMQMessageAudit;
import org.apache.activemq.command.Message;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
/**
* A strategy for choosing which destination is used for dead letter queue
@@ -28,7 +28,7 @@ import org.apache.commons.logging.LogFactory;
* @version $Revision: 426366 $
*/
public abstract class AbstractDeadLetterStrategy implements DeadLetterStrategy {
- private static final Log LOG = LogFactory.getLog(AbstractDeadLetterStrategy.class);
+ private static final Logger LOG = LoggerFactory.getLogger(AbstractDeadLetterStrategy.class);
private boolean processNonPersistent = false;
private boolean processExpired = true;
private ActiveMQMessageAudit audit = new ActiveMQMessageAudit();
diff --git a/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PolicyEntry.java b/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PolicyEntry.java
index c62f2738bb..9fe3a825ba 100644
--- a/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PolicyEntry.java
+++ b/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PolicyEntry.java
@@ -31,8 +31,8 @@ import org.apache.activemq.broker.region.group.MessageGroupHashBucketFactory;
import org.apache.activemq.broker.region.group.MessageGroupMapFactory;
import org.apache.activemq.filter.DestinationMapEntry;
import org.apache.activemq.usage.SystemUsage;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
/**
* Represents an entry in a {@link PolicyMap} for assigning policies to a
@@ -43,7 +43,7 @@ import org.apache.commons.logging.LogFactory;
*/
public class PolicyEntry extends DestinationMapEntry {
- private static final Log LOG = LogFactory.getLog(PolicyEntry.class);
+ private static final Logger LOG = LoggerFactory.getLogger(PolicyEntry.class);
private DispatchPolicy dispatchPolicy;
private SubscriptionRecoveryPolicy subscriptionRecoveryPolicy;
private boolean sendAdvisoryIfNoConsumers;
diff --git a/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PriorityNetworkDispatchPolicy.java b/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PriorityNetworkDispatchPolicy.java
index d2008df94d..79b61956bd 100644
--- a/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PriorityNetworkDispatchPolicy.java
+++ b/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PriorityNetworkDispatchPolicy.java
@@ -25,8 +25,8 @@ import org.apache.activemq.broker.region.Subscription;
import org.apache.activemq.command.ConsumerId;
import org.apache.activemq.command.ConsumerInfo;
import org.apache.activemq.filter.MessageEvaluationContext;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
/**
* dispatch policy that ignores lower priority duplicate network consumers,
@@ -36,7 +36,7 @@ import org.apache.commons.logging.LogFactory;
*/
public class PriorityNetworkDispatchPolicy extends SimpleDispatchPolicy {
- private static final Log LOG = LogFactory.getLog(PriorityNetworkDispatchPolicy.class);
+ private static final Logger LOG = LoggerFactory.getLogger(PriorityNetworkDispatchPolicy.class);
@Override
public boolean dispatch(MessageReference node,
MessageEvaluationContext msgContext,
diff --git a/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/QueryBasedSubscriptionRecoveryPolicy.java b/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/QueryBasedSubscriptionRecoveryPolicy.java
index 15a17dcd38..11f4884e1a 100644
--- a/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/QueryBasedSubscriptionRecoveryPolicy.java
+++ b/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/QueryBasedSubscriptionRecoveryPolicy.java
@@ -34,8 +34,8 @@ import org.apache.activemq.command.MessageId;
import org.apache.activemq.command.ProducerId;
import org.apache.activemq.command.SessionId;
import org.apache.activemq.util.IdGenerator;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
/**
* This implementation of {@link SubscriptionRecoveryPolicy} will perform a user
@@ -46,7 +46,7 @@ import org.apache.commons.logging.LogFactory;
*/
public class QueryBasedSubscriptionRecoveryPolicy implements SubscriptionRecoveryPolicy {
- private static final Log LOG = LogFactory.getLog(QueryBasedSubscriptionRecoveryPolicy.class);
+ private static final Logger LOG = LoggerFactory.getLogger(QueryBasedSubscriptionRecoveryPolicy.class);
private MessageQuery query;
private final AtomicLong messageSequence = new AtomicLong(0);
diff --git a/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/RoundRobinDispatchPolicy.java b/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/RoundRobinDispatchPolicy.java
index cf8b1d38c4..13a2e23a8f 100755
--- a/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/RoundRobinDispatchPolicy.java
+++ b/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/RoundRobinDispatchPolicy.java
@@ -21,8 +21,8 @@ import java.util.List;
import org.apache.activemq.broker.region.MessageReference;
import org.apache.activemq.broker.region.Subscription;
import org.apache.activemq.filter.MessageEvaluationContext;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
/**
* Simple dispatch policy that sends a message to every subscription that
@@ -32,7 +32,7 @@ import org.apache.commons.logging.LogFactory;
* @version $Revision$
*/
public class RoundRobinDispatchPolicy implements DispatchPolicy {
- static final Log LOG = LogFactory.getLog(RoundRobinDispatchPolicy.class);
+ static final Logger LOG = LoggerFactory.getLogger(RoundRobinDispatchPolicy.class);
/**
* @param node
diff --git a/activemq-core/src/main/java/org/apache/activemq/broker/region/virtual/MirroredQueue.java b/activemq-core/src/main/java/org/apache/activemq/broker/region/virtual/MirroredQueue.java
index 3998b76601..ff1acab391 100644
--- a/activemq-core/src/main/java/org/apache/activemq/broker/region/virtual/MirroredQueue.java
+++ b/activemq-core/src/main/java/org/apache/activemq/broker/region/virtual/MirroredQueue.java
@@ -25,8 +25,8 @@ import org.apache.activemq.broker.region.DestinationInterceptor;
import org.apache.activemq.command.ActiveMQDestination;
import org.apache.activemq.command.ActiveMQTopic;
import org.apache.activemq.command.Message;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
/**
* Creates Mirrored
@@ -36,7 +36,7 @@ import org.apache.commons.logging.LogFactory;
* @org.apache.xbean.XBean
*/
public class MirroredQueue implements DestinationInterceptor, BrokerServiceAware {
- private static final transient Log LOG = LogFactory.getLog(MirroredQueue.class);
+ private static final transient Logger LOG = LoggerFactory.getLogger(MirroredQueue.class);
private String prefix = "VirtualTopic.Mirror.";
private String postfix = "";
private boolean copyMessage = true;
@@ -143,4 +143,4 @@ public class MirroredQueue implements DestinationInterceptor, BrokerServiceAware
return new ActiveMQTopic(prefix + original.getPhysicalName() + postfix);
}
-}
\ No newline at end of file
+}
diff --git a/activemq-core/src/main/java/org/apache/activemq/broker/scheduler/JobSchedulerImpl.java b/activemq-core/src/main/java/org/apache/activemq/broker/scheduler/JobSchedulerImpl.java
index 8c840b0f85..8f5755a20b 100644
--- a/activemq-core/src/main/java/org/apache/activemq/broker/scheduler/JobSchedulerImpl.java
+++ b/activemq-core/src/main/java/org/apache/activemq/broker/scheduler/JobSchedulerImpl.java
@@ -31,8 +31,8 @@ import javax.jms.MessageFormatException;
import org.apache.activemq.util.IdGenerator;
import org.apache.activemq.util.ServiceStopper;
import org.apache.activemq.util.ServiceSupport;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
import org.apache.kahadb.index.BTreeIndex;
import org.apache.kahadb.journal.Location;
import org.apache.kahadb.page.Transaction;
@@ -41,7 +41,7 @@ import org.apache.kahadb.util.LongMarshaller;
import org.apache.kahadb.util.VariableMarshaller;
class JobSchedulerImpl extends ServiceSupport implements Runnable, JobScheduler {
- private static final Log LOG = LogFactory.getLog(JobSchedulerImpl.class);
+ private static final Logger LOG = LoggerFactory.getLogger(JobSchedulerImpl.class);
final JobSchedulerStore store;
private final AtomicBoolean running = new AtomicBoolean();
private String name;
diff --git a/activemq-core/src/main/java/org/apache/activemq/broker/scheduler/JobSchedulerStore.java b/activemq-core/src/main/java/org/apache/activemq/broker/scheduler/JobSchedulerStore.java
index 2600c4bc2f..9b71835f1b 100644
--- a/activemq-core/src/main/java/org/apache/activemq/broker/scheduler/JobSchedulerStore.java
+++ b/activemq-core/src/main/java/org/apache/activemq/broker/scheduler/JobSchedulerStore.java
@@ -31,8 +31,8 @@ import java.util.Map.Entry;
import org.apache.activemq.util.IOHelper;
import org.apache.activemq.util.ServiceStopper;
import org.apache.activemq.util.ServiceSupport;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
import org.apache.kahadb.index.BTreeIndex;
import org.apache.kahadb.journal.Journal;
import org.apache.kahadb.journal.Location;
@@ -46,7 +46,7 @@ import org.apache.kahadb.util.StringMarshaller;
import org.apache.kahadb.util.VariableMarshaller;
public class JobSchedulerStore extends ServiceSupport {
- static final Log LOG = LogFactory.getLog(JobSchedulerStore.class);
+ static final Logger LOG = LoggerFactory.getLogger(JobSchedulerStore.class);
private static final int DATABASE_LOCKED_WAIT_DELAY = 10 * 1000;
public static final int CLOSED_STATE = 1;
diff --git a/activemq-core/src/main/java/org/apache/activemq/broker/scheduler/SchedulerBroker.java b/activemq-core/src/main/java/org/apache/activemq/broker/scheduler/SchedulerBroker.java
index 27f707e3af..6fa08cd27d 100644
--- a/activemq-core/src/main/java/org/apache/activemq/broker/scheduler/SchedulerBroker.java
+++ b/activemq-core/src/main/java/org/apache/activemq/broker/scheduler/SchedulerBroker.java
@@ -37,12 +37,12 @@ import org.apache.activemq.util.IdGenerator;
import org.apache.activemq.util.LongSequenceGenerator;
import org.apache.activemq.util.TypeConversionSupport;
import org.apache.activemq.wireformat.WireFormat;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
import org.apache.kahadb.util.ByteSequence;
public class SchedulerBroker extends BrokerFilter implements JobListener {
- private static final Log LOG = LogFactory.getLog(SchedulerBroker.class);
+ private static final Logger LOG = LoggerFactory.getLogger(SchedulerBroker.class);
private static final IdGenerator ID_GENERATOR = new IdGenerator();
private final LongSequenceGenerator messageIdGenerator = new LongSequenceGenerator();
private final AtomicBoolean started = new AtomicBoolean();
diff --git a/activemq-core/src/main/java/org/apache/activemq/broker/util/CommandAgent.java b/activemq-core/src/main/java/org/apache/activemq/broker/util/CommandAgent.java
index e270a39163..e07933630d 100644
--- a/activemq-core/src/main/java/org/apache/activemq/broker/util/CommandAgent.java
+++ b/activemq-core/src/main/java/org/apache/activemq/broker/util/CommandAgent.java
@@ -29,8 +29,8 @@ import org.apache.activemq.ActiveMQConnectionFactory;
import org.apache.activemq.Service;
import org.apache.activemq.advisory.AdvisorySupport;
import org.apache.activemq.util.ServiceStopper;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
/**
* An agent which listens to commands on a JMS destination
@@ -39,7 +39,7 @@ import org.apache.commons.logging.LogFactory;
* @org.apache.xbean.XBean
*/
public class CommandAgent implements Service, ExceptionListener {
- private static final Log LOG = LogFactory.getLog(CommandAgent.class);
+ private static final Logger LOG = LoggerFactory.getLogger(CommandAgent.class);
private String brokerUrl = "vm://localhost";
private String username;
diff --git a/activemq-core/src/main/java/org/apache/activemq/broker/util/CommandMessageListener.java b/activemq-core/src/main/java/org/apache/activemq/broker/util/CommandMessageListener.java
index 7b0c4c5079..89f3fb2a4a 100644
--- a/activemq-core/src/main/java/org/apache/activemq/broker/util/CommandMessageListener.java
+++ b/activemq-core/src/main/java/org/apache/activemq/broker/util/CommandMessageListener.java
@@ -28,14 +28,14 @@ import javax.jms.TextMessage;
import org.apache.activemq.command.ActiveMQTextMessage;
import org.apache.activemq.util.FactoryFinder;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
/**
* @version $Revision: $
*/
public class CommandMessageListener implements MessageListener {
- private static final Log LOG = LogFactory.getLog(CommandMessageListener.class);
+ private static final Logger LOG = LoggerFactory.getLogger(CommandMessageListener.class);
private Session session;
private MessageProducer producer;
diff --git a/activemq-core/src/main/java/org/apache/activemq/broker/util/DefaultAuditLog.java b/activemq-core/src/main/java/org/apache/activemq/broker/util/DefaultAuditLog.java
index a63ecda248..d047fc0185 100644
--- a/activemq-core/src/main/java/org/apache/activemq/broker/util/DefaultAuditLog.java
+++ b/activemq-core/src/main/java/org/apache/activemq/broker/util/DefaultAuditLog.java
@@ -16,12 +16,12 @@
*/
package org.apache.activemq.broker.util;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
public class DefaultAuditLog implements AuditLog {
- private static final Log LOG = LogFactory.getLog("org.apache.activemq.audit");
+ private static final Logger LOG = LoggerFactory.getLogger("org.apache.activemq.audit");
public void log(AuditLogEntry entry) {
LOG.info(entry.toString());
diff --git a/activemq-core/src/main/java/org/apache/activemq/broker/util/LoggingBrokerPlugin.java b/activemq-core/src/main/java/org/apache/activemq/broker/util/LoggingBrokerPlugin.java
index 0d2a7a1bb8..c7a1752276 100644
--- a/activemq-core/src/main/java/org/apache/activemq/broker/util/LoggingBrokerPlugin.java
+++ b/activemq-core/src/main/java/org/apache/activemq/broker/util/LoggingBrokerPlugin.java
@@ -42,8 +42,8 @@ import org.apache.activemq.command.Response;
import org.apache.activemq.command.SessionInfo;
import org.apache.activemq.command.TransactionId;
import org.apache.activemq.usage.Usage;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
/**
* A simple Broker intercepter which allows you to enable/disable logging.
@@ -53,7 +53,7 @@ import org.apache.commons.logging.LogFactory;
public class LoggingBrokerPlugin extends BrokerPluginSupport {
- private static final Log LOG = LogFactory.getLog(LoggingBrokerPlugin.class);
+ private static final Logger LOG = LoggerFactory.getLogger(LoggingBrokerPlugin.class);
private boolean logAll = false;
private boolean logMessageEvents = false;
@@ -78,7 +78,7 @@ public class LoggingBrokerPlugin extends BrokerPluginSupport {
}
/**
- * Log all Events that go through the Plugin
+ * Logger all Events that go through the Plugin
*/
public void setLogAll(boolean logAll) {
this.logAll = logAll;
@@ -89,7 +89,7 @@ public class LoggingBrokerPlugin extends BrokerPluginSupport {
}
/**
- * Log Events that are related to message processing
+ * Logger Events that are related to message processing
*/
public void setLogMessageEvents(boolean logMessageEvents) {
this.logMessageEvents = logMessageEvents;
@@ -100,7 +100,7 @@ public class LoggingBrokerPlugin extends BrokerPluginSupport {
}
/**
- * Log Events that are related to connections and sessions
+ * Logger Events that are related to connections and sessions
*/
public void setLogConnectionEvents(boolean logConnectionEvents) {
this.logConnectionEvents = logConnectionEvents;
@@ -111,7 +111,7 @@ public class LoggingBrokerPlugin extends BrokerPluginSupport {
}
/**
- * Log Events that are related to transaction processing
+ * Logger Events that are related to transaction processing
*/
public void setLogTransactionEvents(boolean logTransactionEvents) {
this.logTransactionEvents = logTransactionEvents;
@@ -122,7 +122,7 @@ public class LoggingBrokerPlugin extends BrokerPluginSupport {
}
/**
- * Log Events that are related to Consumers
+ * Logger Events that are related to Consumers
*/
public void setLogConsumerEvents(boolean logConsumerEvents) {
this.logConsumerEvents = logConsumerEvents;
@@ -133,7 +133,7 @@ public class LoggingBrokerPlugin extends BrokerPluginSupport {
}
/**
- * Log Events that are related to Producers
+ * Logger Events that are related to Producers
*/
public void setLogProducerEvents(boolean logProducerEvents) {
this.logProducerEvents = logProducerEvents;
@@ -144,7 +144,7 @@ public class LoggingBrokerPlugin extends BrokerPluginSupport {
}
/**
- * Log Events that are normally internal to the broker
+ * Logger Events that are normally internal to the broker
*/
public void setLogInternalEvents(boolean logInternalEvents) {
this.logInternalEvents = logInternalEvents;
@@ -558,7 +558,7 @@ public class LoggingBrokerPlugin extends BrokerPluginSupport {
buf.append(") Session(");
buf.append(subs.getConsumerInfo().getConsumerId().getSessionId());
buf.append(")");
- LOG.info(buf);
+ LOG.info(buf.toString());
}
super.slowConsumer(context, destination, subs);
}
diff --git a/activemq-core/src/main/java/org/apache/activemq/broker/util/TimeStampingBrokerPlugin.java b/activemq-core/src/main/java/org/apache/activemq/broker/util/TimeStampingBrokerPlugin.java
index 4df1a653e6..a28992efab 100644
--- a/activemq-core/src/main/java/org/apache/activemq/broker/util/TimeStampingBrokerPlugin.java
+++ b/activemq-core/src/main/java/org/apache/activemq/broker/util/TimeStampingBrokerPlugin.java
@@ -19,8 +19,8 @@ package org.apache.activemq.broker.util;
import org.apache.activemq.broker.BrokerPluginSupport;
import org.apache.activemq.broker.ProducerBrokerExchange;
import org.apache.activemq.command.Message;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
/**
* A Broker interceptor which updates a JMS Client's timestamp on the message
@@ -45,7 +45,7 @@ import org.apache.commons.logging.LogFactory;
* @version $Revision$
*/
public class TimeStampingBrokerPlugin extends BrokerPluginSupport {
- private static final Log LOG = LogFactory.getLog(TimeStampingBrokerPlugin.class);
+ private static final Logger LOG = LoggerFactory.getLogger(TimeStampingBrokerPlugin.class);
/**
* variable which (when non-zero) is used to override
* the expiration date for messages that arrive with
diff --git a/activemq-core/src/main/java/org/apache/activemq/broker/util/TraceBrokerPathPlugin.java b/activemq-core/src/main/java/org/apache/activemq/broker/util/TraceBrokerPathPlugin.java
index fb8c4169a0..fe57ffd660 100644
--- a/activemq-core/src/main/java/org/apache/activemq/broker/util/TraceBrokerPathPlugin.java
+++ b/activemq-core/src/main/java/org/apache/activemq/broker/util/TraceBrokerPathPlugin.java
@@ -21,8 +21,8 @@ import java.util.Map;
import org.apache.activemq.broker.BrokerPluginSupport;
import org.apache.activemq.command.MessageDispatch;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
/**
* The TraceBrokerPathPlugin can be used in a network of Brokers. Each Broker
@@ -38,7 +38,7 @@ import org.apache.commons.logging.LogFactory;
public class TraceBrokerPathPlugin extends BrokerPluginSupport {
private String stampProperty = "BrokerPath";
- private static final Log LOG = LogFactory.getLog(TraceBrokerPathPlugin.class);
+ private static final Logger LOG = LoggerFactory.getLogger(TraceBrokerPathPlugin.class);
public String getStampProperty() {
return stampProperty;
diff --git a/activemq-core/src/main/java/org/apache/activemq/broker/util/UDPTraceBrokerPlugin.java b/activemq-core/src/main/java/org/apache/activemq/broker/util/UDPTraceBrokerPlugin.java
index 9e87c5d9b8..19eb5e1924 100644
--- a/activemq-core/src/main/java/org/apache/activemq/broker/util/UDPTraceBrokerPlugin.java
+++ b/activemq-core/src/main/java/org/apache/activemq/broker/util/UDPTraceBrokerPlugin.java
@@ -55,8 +55,8 @@ import org.apache.activemq.util.ByteArrayOutputStream;
import org.apache.activemq.util.ByteSequence;
import org.apache.activemq.wireformat.WireFormat;
import org.apache.activemq.wireformat.WireFormatFactory;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
/**
* A Broker interceptor which allows you to trace all operations to a UDP
@@ -67,7 +67,7 @@ import org.apache.commons.logging.LogFactory;
*/
public class UDPTraceBrokerPlugin extends BrokerPluginSupport {
- private static final Log LOG = LogFactory.getLog(UDPTraceBrokerPlugin.class);
+ private static final Logger LOG = LoggerFactory.getLogger(UDPTraceBrokerPlugin.class);
protected WireFormat wireFormat;
protected WireFormatFactory wireFormatFactory;
protected int maxTraceDatagramSize = 1024 * 4;
diff --git a/activemq-core/src/main/java/org/apache/activemq/broker/view/DotFileInterceptorSupport.java b/activemq-core/src/main/java/org/apache/activemq/broker/view/DotFileInterceptorSupport.java
index 3b6d3d3123..2b586197a7 100644
--- a/activemq-core/src/main/java/org/apache/activemq/broker/view/DotFileInterceptorSupport.java
+++ b/activemq-core/src/main/java/org/apache/activemq/broker/view/DotFileInterceptorSupport.java
@@ -21,8 +21,8 @@ import java.io.PrintWriter;
import org.apache.activemq.broker.Broker;
import org.apache.activemq.broker.BrokerFilter;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
/**
* Useful base class
@@ -30,7 +30,7 @@ import org.apache.commons.logging.LogFactory;
* @version $Revision: $
*/
public abstract class DotFileInterceptorSupport extends BrokerFilter {
- private final Log log = LogFactory.getLog(DotFileInterceptorSupport.class);
+ private final Logger log = LoggerFactory.getLogger(DotFileInterceptorSupport.class);
private String file;
diff --git a/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQTempDestination.java b/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQTempDestination.java
index 6a75bc1954..46b6eee7ec 100755
--- a/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQTempDestination.java
+++ b/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQTempDestination.java
@@ -18,8 +18,8 @@ package org.apache.activemq.command;
import javax.jms.JMSException;
import org.apache.activemq.ActiveMQConnection;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
/**
* @openwire:marshaller
@@ -27,7 +27,7 @@ import org.apache.commons.logging.LogFactory;
*/
public abstract class ActiveMQTempDestination extends ActiveMQDestination {
- private static final Log LOG = LogFactory.getLog(ActiveMQTempDestination.class);
+ private static final Logger LOG = LoggerFactory.getLogger(ActiveMQTempDestination.class);
protected transient ActiveMQConnection connection;
protected transient String connectionId;
protected transient int sequenceId;
diff --git a/activemq-core/src/main/java/org/apache/activemq/command/NetworkBridgeFilter.java b/activemq-core/src/main/java/org/apache/activemq/command/NetworkBridgeFilter.java
index eeea643a6c..b1bd7082ec 100644
--- a/activemq-core/src/main/java/org/apache/activemq/command/NetworkBridgeFilter.java
+++ b/activemq-core/src/main/java/org/apache/activemq/command/NetworkBridgeFilter.java
@@ -24,8 +24,8 @@ import javax.jms.JMSException;
import org.apache.activemq.filter.BooleanExpression;
import org.apache.activemq.filter.MessageEvaluationContext;
import org.apache.activemq.util.JMSExceptionSupport;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
/**
* @openwire:marshaller code="91"
@@ -34,7 +34,7 @@ import org.apache.commons.logging.LogFactory;
public class NetworkBridgeFilter implements DataStructure, BooleanExpression {
public static final byte DATA_STRUCTURE_TYPE = CommandTypes.NETWORK_BRIDGE_FILTER;
- static final Log LOG = LogFactory.getLog(NetworkBridgeFilter.class);
+ static final Logger LOG = LoggerFactory.getLogger(NetworkBridgeFilter.class);
private BrokerId networkBrokerId;
private int networkTTL;
diff --git a/activemq-core/src/main/java/org/apache/activemq/filter/XPathExpression.java b/activemq-core/src/main/java/org/apache/activemq/filter/XPathExpression.java
index c3f1e0c381..ac723d6c58 100755
--- a/activemq-core/src/main/java/org/apache/activemq/filter/XPathExpression.java
+++ b/activemq-core/src/main/java/org/apache/activemq/filter/XPathExpression.java
@@ -24,15 +24,15 @@ import javax.jms.JMSException;
import org.apache.activemq.command.Message;
import org.apache.activemq.util.JMSExceptionSupport;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
/**
* Used to evaluate an XPath Expression in a JMS selector.
*/
public final class XPathExpression implements BooleanExpression {
- private static final Log LOG = LogFactory.getLog(XPathExpression.class);
+ private static final Logger LOG = LoggerFactory.getLogger(XPathExpression.class);
private static final String EVALUATOR_SYSTEM_PROPERTY = "org.apache.activemq.XPathEvaluatorClassName";
private static final String DEFAULT_EVALUATOR_CLASS_NAME = XalanXPathEvaluator.class.getName();
diff --git a/activemq-core/src/main/java/org/apache/activemq/jndi/JNDIReferenceFactory.java b/activemq-core/src/main/java/org/apache/activemq/jndi/JNDIReferenceFactory.java
index 0a0c14d840..9d7c11ed61 100644
--- a/activemq-core/src/main/java/org/apache/activemq/jndi/JNDIReferenceFactory.java
+++ b/activemq-core/src/main/java/org/apache/activemq/jndi/JNDIReferenceFactory.java
@@ -27,8 +27,8 @@ import javax.naming.Reference;
import javax.naming.StringRefAddr;
import javax.naming.spi.ObjectFactory;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
/**
* Converts objects implementing JNDIStorable into a property fields so they can
@@ -36,7 +36,7 @@ import org.apache.commons.logging.LogFactory;
*/
public class JNDIReferenceFactory implements ObjectFactory {
- static Log log = LogFactory.getLog(JNDIReferenceFactory.class);
+ static Logger log = LoggerFactory.getLogger(JNDIReferenceFactory.class);
/**
* This will be called by a JNDIprovider when a Reference is retrieved from
diff --git a/activemq-core/src/main/java/org/apache/activemq/jndi/ReadOnlyContext.java b/activemq-core/src/main/java/org/apache/activemq/jndi/ReadOnlyContext.java
index 6d5a9b7538..8a10ed2600 100755
--- a/activemq-core/src/main/java/org/apache/activemq/jndi/ReadOnlyContext.java
+++ b/activemq-core/src/main/java/org/apache/activemq/jndi/ReadOnlyContext.java
@@ -37,8 +37,8 @@ import javax.naming.NotContextException;
import javax.naming.OperationNotSupportedException;
import javax.naming.Reference;
import javax.naming.spi.NamingManager;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
/**
* A read-only Context This version assumes it and all its subcontext are
@@ -62,7 +62,7 @@ import org.apache.commons.logging.LogFactory;
*/
@SuppressWarnings("unchecked")
public class ReadOnlyContext implements Context, Serializable {
- private static final Log LOG = LogFactory.getLog(ReadOnlyContext.class);
+ private static final Logger LOG = LoggerFactory.getLogger(ReadOnlyContext.class);
public static final String SEPARATOR = "/";
protected static final NameParser NAME_PARSER = new NameParserImpl();
private static final long serialVersionUID = -5754338187296859149L;
diff --git a/activemq-core/src/main/java/org/apache/activemq/kaha/impl/IndexRootContainer.java b/activemq-core/src/main/java/org/apache/activemq/kaha/impl/IndexRootContainer.java
index ceca95d4fd..4bf2914d1c 100755
--- a/activemq-core/src/main/java/org/apache/activemq/kaha/impl/IndexRootContainer.java
+++ b/activemq-core/src/main/java/org/apache/activemq/kaha/impl/IndexRootContainer.java
@@ -30,8 +30,8 @@ import org.apache.activemq.kaha.StoreLocation;
import org.apache.activemq.kaha.impl.data.Item;
import org.apache.activemq.kaha.impl.index.IndexItem;
import org.apache.activemq.kaha.impl.index.IndexManager;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
/**
* A container of roots for other Containers
@@ -42,7 +42,7 @@ import org.apache.commons.logging.LogFactory;
class IndexRootContainer {
protected static final Marshaller ROOT_MARSHALLER = Store.OBJECT_MARSHALLER;
- private static final Log LOG = LogFactory.getLog(IndexRootContainer.class);
+ private static final Logger LOG = LoggerFactory.getLogger(IndexRootContainer.class);
protected IndexItem root;
protected IndexManager indexManager;
diff --git a/activemq-core/src/main/java/org/apache/activemq/kaha/impl/KahaStore.java b/activemq-core/src/main/java/org/apache/activemq/kaha/impl/KahaStore.java
index 215f927c0a..13a24e3b63 100644
--- a/activemq-core/src/main/java/org/apache/activemq/kaha/impl/KahaStore.java
+++ b/activemq-core/src/main/java/org/apache/activemq/kaha/impl/KahaStore.java
@@ -44,8 +44,8 @@ import org.apache.activemq.kaha.impl.index.IndexItem;
import org.apache.activemq.kaha.impl.index.IndexManager;
import org.apache.activemq.kaha.impl.index.RedoStoreIndexItem;
import org.apache.activemq.util.IOHelper;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
/**
* Store Implementation
@@ -64,7 +64,7 @@ public class KahaStore implements Store {
//according to the String javadoc, all constant strings are interned so this will be the same object throughout the vm
//and we can use it as a monitor for the lockset.
private final static String LOCKSET_MONITOR = PROPERTY_PREFIX + ".Lock.Monitor";
- private static final Log LOG = LogFactory.getLog(KahaStore.class);
+ private static final Logger LOG = LoggerFactory.getLogger(KahaStore.class);
private final File directory;
private final String mode;
diff --git a/activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/AsyncDataManager.java b/activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/AsyncDataManager.java
index ab9ca24c16..273563254d 100644
--- a/activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/AsyncDataManager.java
+++ b/activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/AsyncDataManager.java
@@ -40,8 +40,8 @@ import org.apache.activemq.kaha.impl.async.DataFileAppender.WriteKey;
import org.apache.activemq.thread.Scheduler;
import org.apache.activemq.util.ByteSequence;
import org.apache.activemq.util.IOHelper;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
@@ -73,7 +73,7 @@ public class AsyncDataManager {
public static final int DEFAULT_CLEANUP_INTERVAL = 1000 * 30;
public static final int PREFERED_DIFF = 1024 * 512;
- private static final Log LOG = LogFactory.getLog(AsyncDataManager.class);
+ private static final Logger LOG = LoggerFactory.getLogger(AsyncDataManager.class);
protected Scheduler scheduler;
protected final Map inflightWrites = new ConcurrentHashMap();
diff --git a/activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/ReadOnlyAsyncDataManager.java b/activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/ReadOnlyAsyncDataManager.java
index 5b67b70cd3..cbc167499c 100644
--- a/activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/ReadOnlyAsyncDataManager.java
+++ b/activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/ReadOnlyAsyncDataManager.java
@@ -25,8 +25,8 @@ import java.util.List;
import org.apache.activemq.thread.Scheduler;
import org.apache.activemq.util.ByteSequence;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
/**
* An AsyncDataManager that works in read only mode against multiple data directories.
@@ -34,7 +34,7 @@ import org.apache.commons.logging.LogFactory;
*/
public class ReadOnlyAsyncDataManager extends AsyncDataManager {
- private static final Log LOG = LogFactory.getLog(ReadOnlyAsyncDataManager.class);
+ private static final Logger LOG = LoggerFactory.getLogger(ReadOnlyAsyncDataManager.class);
private final ArrayList dirs;
public ReadOnlyAsyncDataManager(final ArrayList dirs) {
diff --git a/activemq-core/src/main/java/org/apache/activemq/kaha/impl/container/BaseContainerImpl.java b/activemq-core/src/main/java/org/apache/activemq/kaha/impl/container/BaseContainerImpl.java
index 1bbab91608..3ce8542584 100644
--- a/activemq-core/src/main/java/org/apache/activemq/kaha/impl/container/BaseContainerImpl.java
+++ b/activemq-core/src/main/java/org/apache/activemq/kaha/impl/container/BaseContainerImpl.java
@@ -30,8 +30,8 @@ import org.apache.activemq.kaha.impl.index.IndexItem;
import org.apache.activemq.kaha.impl.index.IndexLinkedList;
import org.apache.activemq.kaha.impl.index.IndexManager;
import org.apache.activemq.kaha.impl.index.VMIndexLinkedList;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
/**
* Implementation of a ListContainer
@@ -40,7 +40,7 @@ import org.apache.commons.logging.LogFactory;
*/
public abstract class BaseContainerImpl {
- private static final Log LOG = LogFactory.getLog(BaseContainerImpl.class);
+ private static final Logger LOG = LoggerFactory.getLogger(BaseContainerImpl.class);
protected IndexItem root;
protected IndexLinkedList indexList;
protected IndexManager indexManager;
diff --git a/activemq-core/src/main/java/org/apache/activemq/kaha/impl/container/ListContainerImpl.java b/activemq-core/src/main/java/org/apache/activemq/kaha/impl/container/ListContainerImpl.java
index fcaa268c11..0e77f083d2 100644
--- a/activemq-core/src/main/java/org/apache/activemq/kaha/impl/container/ListContainerImpl.java
+++ b/activemq-core/src/main/java/org/apache/activemq/kaha/impl/container/ListContainerImpl.java
@@ -34,8 +34,8 @@ import org.apache.activemq.kaha.impl.DataManager;
import org.apache.activemq.kaha.impl.data.Item;
import org.apache.activemq.kaha.impl.index.IndexItem;
import org.apache.activemq.kaha.impl.index.IndexManager;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
/**
* Implementation of a ListContainer
@@ -44,7 +44,7 @@ import org.apache.commons.logging.LogFactory;
*/
public class ListContainerImpl extends BaseContainerImpl implements ListContainer {
- private static final Log LOG = LogFactory.getLog(ListContainerImpl.class);
+ private static final Logger LOG = LoggerFactory.getLogger(ListContainerImpl.class);
protected Marshaller marshaller = Store.OBJECT_MARSHALLER;
public ListContainerImpl(ContainerId id, IndexItem root, IndexManager indexManager,
diff --git a/activemq-core/src/main/java/org/apache/activemq/kaha/impl/container/MapContainerImpl.java b/activemq-core/src/main/java/org/apache/activemq/kaha/impl/container/MapContainerImpl.java
index 0fd702123d..4caea04258 100755
--- a/activemq-core/src/main/java/org/apache/activemq/kaha/impl/container/MapContainerImpl.java
+++ b/activemq-core/src/main/java/org/apache/activemq/kaha/impl/container/MapContainerImpl.java
@@ -40,8 +40,8 @@ import org.apache.activemq.kaha.impl.index.IndexManager;
import org.apache.activemq.kaha.impl.index.VMIndex;
import org.apache.activemq.kaha.impl.index.hash.HashIndex;
import org.apache.activemq.util.IOHelper;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
/**
* Implementation of a MapContainer
@@ -50,7 +50,7 @@ import org.apache.commons.logging.LogFactory;
*/
public final class MapContainerImpl extends BaseContainerImpl implements MapContainer {
- private static final Log LOG = LogFactory.getLog(MapContainerImpl.class);
+ private static final Logger LOG = LoggerFactory.getLogger(MapContainerImpl.class);
protected Index index;
protected Marshaller keyMarshaller = Store.OBJECT_MARSHALLER;
protected Marshaller valueMarshaller = Store.OBJECT_MARSHALLER;
diff --git a/activemq-core/src/main/java/org/apache/activemq/kaha/impl/data/DataManagerImpl.java b/activemq-core/src/main/java/org/apache/activemq/kaha/impl/data/DataManagerImpl.java
index e6daae6e93..cffe1cbe88 100644
--- a/activemq-core/src/main/java/org/apache/activemq/kaha/impl/data/DataManagerImpl.java
+++ b/activemq-core/src/main/java/org/apache/activemq/kaha/impl/data/DataManagerImpl.java
@@ -32,8 +32,8 @@ import org.apache.activemq.kaha.impl.DataManager;
import org.apache.activemq.kaha.impl.index.RedoStoreIndexItem;
import org.apache.activemq.util.IOExceptionSupport;
import org.apache.activemq.util.IOHelper;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
/**
* Manages DataFiles
@@ -47,7 +47,7 @@ public final class DataManagerImpl implements DataManager {
public static final byte REDO_ITEM_TYPE = 2;
public static final long MAX_FILE_LENGTH = 1024 * 1024 * 32;
- private static final Log LOG = LogFactory.getLog(DataManagerImpl.class);
+ private static final Logger LOG = LoggerFactory.getLogger(DataManagerImpl.class);
private static final String NAME_PREFIX = "data-";
private final File directory;
diff --git a/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/IndexManager.java b/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/IndexManager.java
index 16c738820f..647cb8c3b7 100644
--- a/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/IndexManager.java
+++ b/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/IndexManager.java
@@ -24,8 +24,8 @@ import java.util.concurrent.atomic.AtomicLong;
import org.apache.activemq.kaha.impl.DataManager;
import org.apache.activemq.util.IOHelper;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
/**
* Optimized Store reader
@@ -35,7 +35,7 @@ import org.apache.commons.logging.LogFactory;
public final class IndexManager {
public static final String NAME_PREFIX = "index-";
- private static final Log LOG = LogFactory.getLog(IndexManager.class);
+ private static final Logger LOG = LoggerFactory.getLogger(IndexManager.class);
private final String name;
private File directory;
private File file;
diff --git a/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/VMIndex.java b/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/VMIndex.java
index aca8de8634..b1d6ff1cf1 100644
--- a/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/VMIndex.java
+++ b/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/VMIndex.java
@@ -23,8 +23,8 @@ import java.util.Map;
import org.apache.activemq.kaha.IndexMBean;
import org.apache.activemq.kaha.Marshaller;
import org.apache.activemq.kaha.StoreEntry;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
/**
* Index implementation using a HashMap
@@ -32,7 +32,7 @@ import org.apache.commons.logging.LogFactory;
* @version $Revision: 1.2 $
*/
public class VMIndex implements Index, IndexMBean {
- private static final Log LOG = LogFactory.getLog(VMIndex.class);
+ private static final Logger LOG = LoggerFactory.getLogger(VMIndex.class);
private IndexManager indexManager;
private Map