You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by cl...@apache.org on 2016/11/23 16:16:44 UTC
[1/2] activemq-artemis git commit: ARTEMIS-865 Remove
e.printStackTrace() from code
Repository: activemq-artemis
Updated Branches:
refs/heads/master a43c92a68 -> 5f7f0785c
ARTEMIS-865 Remove e.printStackTrace() from code
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/3995319d
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/3995319d
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/3995319d
Branch: refs/heads/master
Commit: 3995319dcad02fec32f8307bd017e02a59b4d513
Parents: a43c92a
Author: Dmitrii Tikhomirov <dt...@redhat.com>
Authored: Mon Nov 21 15:32:22 2016 +0100
Committer: Clebert Suconic <cl...@apache.org>
Committed: Wed Nov 23 11:15:54 2016 -0500
----------------------------------------------------------------------
.../org/apache/activemq/artemis/boot/Artemis.java | 6 +++++-
.../org/apache/activemq/artemis/utils/Base64.java | 15 ++++++++-------
.../artemis/jdbc/store/file/JDBCSequentialFile.java | 4 ++--
.../artemis/jdbc/store/journal/JDBCJournalImpl.java | 2 +-
.../jms/management/impl/JMSTopicControlImpl.java | 5 ++++-
.../jms/server/impl/JMSServerManagerImpl.java | 5 ++++-
.../artemis/core/journal/impl/JournalFileImpl.java | 5 ++++-
.../artemis/core/journal/impl/JournalImpl.java | 3 +--
.../protocol/amqp/broker/AMQPConnectionCallback.java | 5 +++--
.../core/protocol/mqtt/MQTTPublishManager.java | 3 +--
.../core/protocol/mqtt/MQTTSessionCallback.java | 1 -
.../core/protocol/openwire/OpenWireConnection.java | 12 +++++-------
.../core/protocol/openwire/amq/AMQConsumer.java | 5 +++--
.../artemis/rest/queue/push/UriStrategy.java | 3 +--
.../artemis/rest/util/HttpMessageHelper.java | 2 +-
.../server/impl/LegacyLDAPSecuritySettingPlugin.java | 4 ++--
.../management/impl/ManagementServiceImpl.java | 2 +-
17 files changed, 46 insertions(+), 36 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3995319d/artemis-boot/src/main/java/org/apache/activemq/artemis/boot/Artemis.java
----------------------------------------------------------------------
diff --git a/artemis-boot/src/main/java/org/apache/activemq/artemis/boot/Artemis.java b/artemis-boot/src/main/java/org/apache/activemq/artemis/boot/Artemis.java
index 5847a8b..bbe1574 100644
--- a/artemis-boot/src/main/java/org/apache/activemq/artemis/boot/Artemis.java
+++ b/artemis-boot/src/main/java/org/apache/activemq/artemis/boot/Artemis.java
@@ -26,6 +26,8 @@ import java.util.ArrayList;
import java.util.Collections;
import java.util.Comparator;
import java.util.List;
+import java.util.logging.Level;
+import java.util.logging.Logger;
/**
* <p>
@@ -35,6 +37,8 @@ import java.util.List;
*/
public class Artemis {
+ private static final Logger logger = Logger.getLogger(Artemis.class.getName());
+
public static void main(String[] args) throws Throwable {
String home = System.getProperty("artemis.home");
@@ -143,7 +147,7 @@ public class Artemis {
try {
urls.add(file.toURI().toURL());
} catch (MalformedURLException e) {
- e.printStackTrace();
+ logger.log(Level.WARNING, e.getMessage(), e);
}
}
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3995319d/artemis-commons/src/main/java/org/apache/activemq/artemis/utils/Base64.java
----------------------------------------------------------------------
diff --git a/artemis-commons/src/main/java/org/apache/activemq/artemis/utils/Base64.java b/artemis-commons/src/main/java/org/apache/activemq/artemis/utils/Base64.java
index dbcc8a5..ebe18ec 100644
--- a/artemis-commons/src/main/java/org/apache/activemq/artemis/utils/Base64.java
+++ b/artemis-commons/src/main/java/org/apache/activemq/artemis/utils/Base64.java
@@ -10,6 +10,8 @@
*/
package org.apache.activemq.artemis.utils;
+import org.jboss.logging.Logger;
+
import java.nio.charset.Charset;
import java.nio.charset.StandardCharsets;
@@ -149,6 +151,8 @@ public class Base64 {
*/
private static final byte NEW_LINE = (byte) '\n';
+ private static final Logger logger = Logger.getLogger(Base64.class);
+
/**
* Preferred encoding.
*/
@@ -539,7 +543,7 @@ public class Base64 {
oos.writeObject(serializableObject);
} catch (java.io.IOException e) {
- e.printStackTrace();
+ logger.warn("Object cannot be serialized", e.getMessage(), e);
return null;
} finally {
try {
@@ -657,7 +661,7 @@ public class Base64 {
gzos.write(source, off, len);
gzos.close();
} catch (java.io.IOException e) {
- e.printStackTrace();
+ logger.warn("Unable to encode byte array into Base64 notation", e.getMessage(), e);
return null;
} finally {
try {
@@ -945,11 +949,8 @@ public class Base64 {
ois = new java.io.ObjectInputStream(bais);
obj = ois.readObject();
- } catch (java.io.IOException e) {
- e.printStackTrace();
- obj = null;
- } catch (java.lang.ClassNotFoundException e) {
- e.printStackTrace();
+ } catch (java.io.IOException | java.lang.ClassNotFoundException e) {
+ logger.warn("Unable to deserialize object", e.getMessage(), e);
obj = null;
} finally {
try {
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3995319d/artemis-jdbc-store/src/main/java/org/apache/activemq/artemis/jdbc/store/file/JDBCSequentialFile.java
----------------------------------------------------------------------
diff --git a/artemis-jdbc-store/src/main/java/org/apache/activemq/artemis/jdbc/store/file/JDBCSequentialFile.java b/artemis-jdbc-store/src/main/java/org/apache/activemq/artemis/jdbc/store/file/JDBCSequentialFile.java
index f3215c0..34b6a4f 100644
--- a/artemis-jdbc-store/src/main/java/org/apache/activemq/artemis/jdbc/store/file/JDBCSequentialFile.java
+++ b/artemis-jdbc-store/src/main/java/org/apache/activemq/artemis/jdbc/store/file/JDBCSequentialFile.java
@@ -155,7 +155,7 @@ public class JDBCSequentialFile implements SequentialFile {
return noBytes;
}
} catch (Exception e) {
- e.printStackTrace();
+ logger.warn("Failed to write to file", e.getMessage(), e);
if (callback != null)
callback.onError(-1, e.getMessage());
}
@@ -251,7 +251,7 @@ public class JDBCSequentialFile implements SequentialFile {
} catch (Exception e) {
if (callback != null)
callback.onError(-1, e.getMessage());
- e.printStackTrace();
+ logger.warn("Failed to read from file", e.getMessage(), e);
return 0;
}
}
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3995319d/artemis-jdbc-store/src/main/java/org/apache/activemq/artemis/jdbc/store/journal/JDBCJournalImpl.java
----------------------------------------------------------------------
diff --git a/artemis-jdbc-store/src/main/java/org/apache/activemq/artemis/jdbc/store/journal/JDBCJournalImpl.java b/artemis-jdbc-store/src/main/java/org/apache/activemq/artemis/jdbc/store/journal/JDBCJournalImpl.java
index e112dbc..ba3dd0d 100644
--- a/artemis-jdbc-store/src/main/java/org/apache/activemq/artemis/jdbc/store/journal/JDBCJournalImpl.java
+++ b/artemis-jdbc-store/src/main/java/org/apache/activemq/artemis/jdbc/store/journal/JDBCJournalImpl.java
@@ -223,7 +223,7 @@ public class JDBCJournalImpl extends AbstractJDBCDriver implements Journal {
if (success)
cleanupTxRecords(deletedRecords, committedTransactions);
} catch (SQLException e) {
- e.printStackTrace();
+ logger.warn("Failed to remove the Tx Records", e.getMessage(), e);
}
executeCallbacks(recordRef, success);
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3995319d/artemis-jms-server/src/main/java/org/apache/activemq/artemis/jms/management/impl/JMSTopicControlImpl.java
----------------------------------------------------------------------
diff --git a/artemis-jms-server/src/main/java/org/apache/activemq/artemis/jms/management/impl/JMSTopicControlImpl.java b/artemis-jms-server/src/main/java/org/apache/activemq/artemis/jms/management/impl/JMSTopicControlImpl.java
index cd8e4e0..d81de51 100644
--- a/artemis-jms-server/src/main/java/org/apache/activemq/artemis/jms/management/impl/JMSTopicControlImpl.java
+++ b/artemis-jms-server/src/main/java/org/apache/activemq/artemis/jms/management/impl/JMSTopicControlImpl.java
@@ -39,6 +39,7 @@ import org.apache.activemq.artemis.jms.client.ActiveMQMessage;
import org.apache.activemq.artemis.jms.server.JMSServerManager;
import org.apache.activemq.artemis.utils.JsonLoader;
import org.apache.activemq.artemis.utils.SelectorTranslator;
+import org.jboss.logging.Logger;
import static org.apache.activemq.artemis.api.core.JsonUtil.nullSafe;
@@ -52,6 +53,8 @@ public class JMSTopicControlImpl extends StandardMBean implements TopicControl {
private final JMSServerManager jmsServerManager;
+ private static final Logger logger = Logger.getLogger(JMSTopicControlImpl.class);
+
// Static --------------------------------------------------------
public static String createFilterFromJMSSelector(final String selectorStr) throws ActiveMQException {
@@ -318,7 +321,7 @@ public class JMSTopicControlImpl extends StandardMBean implements TopicControl {
return array.build().toString();
} catch (Exception e) {
- e.printStackTrace();
+ logger.warn("Unable to list subscribers as JSON", e.getMessage(), e);
return e.toString();
}
}
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3995319d/artemis-jms-server/src/main/java/org/apache/activemq/artemis/jms/server/impl/JMSServerManagerImpl.java
----------------------------------------------------------------------
diff --git a/artemis-jms-server/src/main/java/org/apache/activemq/artemis/jms/server/impl/JMSServerManagerImpl.java b/artemis-jms-server/src/main/java/org/apache/activemq/artemis/jms/server/impl/JMSServerManagerImpl.java
index 456bb58..36b4d8b 100644
--- a/artemis-jms-server/src/main/java/org/apache/activemq/artemis/jms/server/impl/JMSServerManagerImpl.java
+++ b/artemis-jms-server/src/main/java/org/apache/activemq/artemis/jms/server/impl/JMSServerManagerImpl.java
@@ -100,6 +100,7 @@ import org.apache.activemq.artemis.utils.SelectorTranslator;
import org.apache.activemq.artemis.utils.TimeAndCounterIDGenerator;
import org.apache.activemq.artemis.utils.TypedProperties;
import org.apache.activemq.artemis.utils.XMLUtil;
+import org.jboss.logging.Logger;
import org.w3c.dom.Element;
/**
@@ -151,6 +152,8 @@ public class JMSServerManagerImpl implements JMSServerManager, ActivateCallback
private final Map<String, List<String>> unRecoveredBindings = new HashMap<>();
+ private static final Logger logger = Logger.getLogger(JMSServerManagerImpl.class);
+
public JMSServerManagerImpl(final ActiveMQServer server) throws Exception {
this.server = server;
@@ -265,7 +268,7 @@ public class JMSServerManagerImpl implements JMSServerManager, ActivateCallback
active = false;
}
} catch (Exception e) {
- e.printStackTrace();
+ logger.warn("Unable to deactivate server", e.getMessage(), e);
}
}
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3995319d/artemis-journal/src/main/java/org/apache/activemq/artemis/core/journal/impl/JournalFileImpl.java
----------------------------------------------------------------------
diff --git a/artemis-journal/src/main/java/org/apache/activemq/artemis/core/journal/impl/JournalFileImpl.java b/artemis-journal/src/main/java/org/apache/activemq/artemis/core/journal/impl/JournalFileImpl.java
index 45d33cc..7b3b7bf 100644
--- a/artemis-journal/src/main/java/org/apache/activemq/artemis/core/journal/impl/JournalFileImpl.java
+++ b/artemis-journal/src/main/java/org/apache/activemq/artemis/core/journal/impl/JournalFileImpl.java
@@ -22,6 +22,7 @@ import java.util.concurrent.ConcurrentMap;
import java.util.concurrent.atomic.AtomicInteger;
import org.apache.activemq.artemis.core.io.SequentialFile;
+import org.jboss.logging.Logger;
public class JournalFileImpl implements JournalFile {
@@ -47,6 +48,8 @@ public class JournalFileImpl implements JournalFile {
private final ConcurrentMap<JournalFile, AtomicInteger> negCounts = new ConcurrentHashMap<>();
+ private static final Logger logger = Logger.getLogger(JournalFileImpl.class);
+
public JournalFileImpl(final SequentialFile file, final long fileID, final int version) {
this.file = file;
@@ -152,7 +155,7 @@ public class JournalFileImpl implements JournalFile {
try {
return "JournalFileImpl: (" + file.getFileName() + " id = " + fileID + ", recordID = " + recordID + ")";
} catch (Exception e) {
- e.printStackTrace();
+ logger.warn("Error during method invocation", e.getMessage(), e);
return "Error:" + e.toString();
}
}
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3995319d/artemis-journal/src/main/java/org/apache/activemq/artemis/core/journal/impl/JournalImpl.java
----------------------------------------------------------------------
diff --git a/artemis-journal/src/main/java/org/apache/activemq/artemis/core/journal/impl/JournalImpl.java b/artemis-journal/src/main/java/org/apache/activemq/artemis/core/journal/impl/JournalImpl.java
index b1093ed..1a5b2b9 100644
--- a/artemis-journal/src/main/java/org/apache/activemq/artemis/core/journal/impl/JournalImpl.java
+++ b/artemis-journal/src/main/java/org/apache/activemq/artemis/core/journal/impl/JournalImpl.java
@@ -1351,7 +1351,6 @@ public class JournalImpl extends JournalBase implements TestableJournal, Journal
} catch (Throwable e) {
errors.incrementAndGet();
ActiveMQJournalLogger.LOGGER.errorCompacting(e);
- e.printStackTrace();
} finally {
latch.countDown();
}
@@ -2911,7 +2910,7 @@ public class JournalImpl extends JournalBase implements TestableJournal, Journal
try {
scheduleCompactAndBlock(60);
} catch (Exception e) {
- e.printStackTrace();
+ logger.warn("Error during compact", e.getMessage(), e);
throw new RuntimeException(e);
}
}
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3995319d/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/broker/AMQPConnectionCallback.java
----------------------------------------------------------------------
diff --git a/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/broker/AMQPConnectionCallback.java b/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/broker/AMQPConnectionCallback.java
index 24c625c..9021272 100644
--- a/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/broker/AMQPConnectionCallback.java
+++ b/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/broker/AMQPConnectionCallback.java
@@ -33,6 +33,7 @@ import org.apache.activemq.artemis.core.buffers.impl.ChannelBufferWrapper;
import org.apache.activemq.artemis.core.remoting.CloseListener;
import org.apache.activemq.artemis.core.remoting.FailureListener;
import org.apache.activemq.artemis.core.server.ActiveMQServer;
+import org.apache.activemq.artemis.core.server.ActiveMQServerLogger;
import org.apache.activemq.artemis.core.transaction.Transaction;
import org.apache.activemq.artemis.core.transaction.impl.TransactionImpl;
import org.apache.activemq.artemis.core.transaction.impl.XidImpl;
@@ -168,8 +169,8 @@ public class AMQPConnectionCallback implements FailureListener, CloseListener {
if (amqpConnection.isSyncOnFlush()) {
try {
latch.await(5, TimeUnit.SECONDS);
- } catch (Exception e) {
- e.printStackTrace();
+ } catch (InterruptedException e) {
+ ActiveMQServerLogger.LOGGER.warn("Error during await invocation", e);
}
}
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3995319d/artemis-protocols/artemis-mqtt-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/mqtt/MQTTPublishManager.java
----------------------------------------------------------------------
diff --git a/artemis-protocols/artemis-mqtt-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/mqtt/MQTTPublishManager.java b/artemis-protocols/artemis-mqtt-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/mqtt/MQTTPublishManager.java
index fb3363f..3a2ad7e 100644
--- a/artemis-protocols/artemis-mqtt-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/mqtt/MQTTPublishManager.java
+++ b/artemis-protocols/artemis-mqtt-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/mqtt/MQTTPublishManager.java
@@ -221,8 +221,7 @@ public class MQTTPublishManager {
payload.writeBytes(stringPayload);
break;
} catch (UnsupportedEncodingException e) {
- e.printStackTrace();
- // Do nothing default to sending raw bytes.
+ log.warn("Unable to send message: " + message.getMessageID() + " Cause: " + e.getMessage());
}
default:
payload = message.getBodyBufferDuplicate().byteBuf();
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3995319d/artemis-protocols/artemis-mqtt-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/mqtt/MQTTSessionCallback.java
----------------------------------------------------------------------
diff --git a/artemis-protocols/artemis-mqtt-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/mqtt/MQTTSessionCallback.java b/artemis-protocols/artemis-mqtt-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/mqtt/MQTTSessionCallback.java
index fa282d4..d580804 100644
--- a/artemis-protocols/artemis-mqtt-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/mqtt/MQTTSessionCallback.java
+++ b/artemis-protocols/artemis-mqtt-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/mqtt/MQTTSessionCallback.java
@@ -49,7 +49,6 @@ public class MQTTSessionCallback implements SessionCallback {
try {
session.getMqttPublishManager().sendMessage(message, consumer, deliveryCount);
} catch (Exception e) {
- e.printStackTrace();
log.warn("Unable to send message: " + message.getMessageID() + " Cause: " + e.getMessage());
}
return 1;
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3995319d/artemis-protocols/artemis-openwire-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/openwire/OpenWireConnection.java
----------------------------------------------------------------------
diff --git a/artemis-protocols/artemis-openwire-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/openwire/OpenWireConnection.java b/artemis-protocols/artemis-openwire-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/openwire/OpenWireConnection.java
index a984a1c..93c9bde 100644
--- a/artemis-protocols/artemis-openwire-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/openwire/OpenWireConnection.java
+++ b/artemis-protocols/artemis-openwire-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/openwire/OpenWireConnection.java
@@ -262,8 +262,7 @@ public class OpenWireConnection extends AbstractRemotingConnection implements Se
setLastCommand(command);
response = command.visit(commandProcessorInstance);
} catch (Exception e) {
- // TODO: logging
- e.printStackTrace();
+ ActiveMQServerLogger.LOGGER.warn("Errors occurred during the buffering operation ", e);
if (responseRequired) {
response = convertException(e);
}
@@ -821,8 +820,7 @@ public class OpenWireConnection extends AbstractRemotingConnection implements Se
advisoryMessage.setStringProperty(AdvisorySupport.MSG_PROPERTY_CONSUMER_ID, amqConsumer.getId().toString());
protocolManager.fireAdvisory(context, topic, advisoryMessage, amqConsumer.getId());
} catch (Exception e) {
- // TODO-NOW: LOGGING
- e.printStackTrace();
+ ActiveMQServerLogger.LOGGER.warn("Error during method invocation", e);
}
}
}
@@ -1184,7 +1182,7 @@ public class OpenWireConnection extends AbstractRemotingConnection implements Se
Xid xid = OpenWireUtil.toXID(info.getTransactionId());
internalSession.xaForget(xid);
} catch (Exception e) {
- e.printStackTrace();
+ ActiveMQServerLogger.LOGGER.warn("Error during method invocation", e);
throw e;
}
} else {
@@ -1204,7 +1202,7 @@ public class OpenWireConnection extends AbstractRemotingConnection implements Se
Xid xid = OpenWireUtil.toXID(info.getTransactionId());
internalSession.xaPrepare(xid);
} catch (Exception e) {
- e.printStackTrace();
+ ActiveMQServerLogger.LOGGER.warn("Error during method invocation", e);
throw e;
}
} else {
@@ -1233,7 +1231,7 @@ public class OpenWireConnection extends AbstractRemotingConnection implements Se
internalSession.resetTX(null);
}
} catch (Exception e) {
- e.printStackTrace();
+ ActiveMQServerLogger.LOGGER.warn("Error during method invocation", e);
throw e;
}
} else {
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3995319d/artemis-protocols/artemis-openwire-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/openwire/amq/AMQConsumer.java
----------------------------------------------------------------------
diff --git a/artemis-protocols/artemis-openwire-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/openwire/amq/AMQConsumer.java b/artemis-protocols/artemis-openwire-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/openwire/amq/AMQConsumer.java
index e53b962..8b80bde 100644
--- a/artemis-protocols/artemis-openwire-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/openwire/amq/AMQConsumer.java
+++ b/artemis-protocols/artemis-openwire-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/openwire/amq/AMQConsumer.java
@@ -29,6 +29,7 @@ import org.apache.activemq.artemis.api.core.SimpleString;
import org.apache.activemq.artemis.core.client.impl.ClientConsumerImpl;
import org.apache.activemq.artemis.core.protocol.openwire.OpenWireMessageConverter;
import org.apache.activemq.artemis.core.protocol.openwire.util.OpenWireUtil;
+import org.apache.activemq.artemis.core.server.ActiveMQServerLogger;
import org.apache.activemq.artemis.core.server.MessageReference;
import org.apache.activemq.artemis.core.server.QueueQueryResult;
import org.apache.activemq.artemis.core.server.ServerConsumer;
@@ -198,10 +199,10 @@ public class AMQConsumer {
currentWindow.decrementAndGet();
return size;
} catch (IOException e) {
- e.printStackTrace();
+ ActiveMQServerLogger.LOGGER.warn("Error during message dispatch", e);
return 0;
} catch (Throwable t) {
- t.printStackTrace();
+ ActiveMQServerLogger.LOGGER.warn("Error during message dispatch", t);
return 0;
}
}
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3995319d/artemis-rest/src/main/java/org/apache/activemq/artemis/rest/queue/push/UriStrategy.java
----------------------------------------------------------------------
diff --git a/artemis-rest/src/main/java/org/apache/activemq/artemis/rest/queue/push/UriStrategy.java b/artemis-rest/src/main/java/org/apache/activemq/artemis/rest/queue/push/UriStrategy.java
index 727743a..10c01d6 100644
--- a/artemis-rest/src/main/java/org/apache/activemq/artemis/rest/queue/push/UriStrategy.java
+++ b/artemis-rest/src/main/java/org/apache/activemq/artemis/rest/queue/push/UriStrategy.java
@@ -175,8 +175,7 @@ public class UriStrategy implements PushStrategy {
}
}
} catch (Exception e) {
- ActiveMQRestLogger.LOGGER.debug("failed to push message to " + uri, e);
- e.printStackTrace();
+ ActiveMQRestLogger.LOGGER.warn("failed to push message to " + uri, e);
return false;
} finally {
if (res != null)
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3995319d/artemis-rest/src/main/java/org/apache/activemq/artemis/rest/util/HttpMessageHelper.java
----------------------------------------------------------------------
diff --git a/artemis-rest/src/main/java/org/apache/activemq/artemis/rest/util/HttpMessageHelper.java b/artemis-rest/src/main/java/org/apache/activemq/artemis/rest/util/HttpMessageHelper.java
index a1e14bd..a6e4c8e 100644
--- a/artemis-rest/src/main/java/org/apache/activemq/artemis/rest/util/HttpMessageHelper.java
+++ b/artemis-rest/src/main/java/org/apache/activemq/artemis/rest/util/HttpMessageHelper.java
@@ -83,7 +83,7 @@ public class HttpMessageHelper {
ActiveMQRestLogger.LOGGER.debug("**** Building Message from object: " + obj.toString());
request.body(contentType, obj);
} catch (Exception e) {
- e.printStackTrace();
+ ActiveMQRestLogger.LOGGER.warn("Building Message from object", e.getMessage(), e);
throw new RuntimeException(e);
}
}
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3995319d/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/LegacyLDAPSecuritySettingPlugin.java
----------------------------------------------------------------------
diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/LegacyLDAPSecuritySettingPlugin.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/LegacyLDAPSecuritySettingPlugin.java
index 8468115..9c78c38 100644
--- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/LegacyLDAPSecuritySettingPlugin.java
+++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/LegacyLDAPSecuritySettingPlugin.java
@@ -412,7 +412,7 @@ public class LegacyLDAPSecuritySettingPlugin implements SecuritySettingPlugin {
}
}
} catch (NamingException e) {
- e.printStackTrace();
+ logger.warn("Failed to process an event", e.getMessage(), e);
}
}
@@ -464,7 +464,7 @@ public class LegacyLDAPSecuritySettingPlugin implements SecuritySettingPlugin {
}
}
} catch (NamingException e) {
- e.printStackTrace();
+ logger.warn("Failed to process an event", e.getMessage(), e);
}
}
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3995319d/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/management/impl/ManagementServiceImpl.java
----------------------------------------------------------------------
diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/management/impl/ManagementServiceImpl.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/management/impl/ManagementServiceImpl.java
index 73248f0..44da08a 100644
--- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/management/impl/ManagementServiceImpl.java
+++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/management/impl/ManagementServiceImpl.java
@@ -302,7 +302,7 @@ public class ManagementServiceImpl implements ManagementService {
try {
unregisterAcceptor(name);
} catch (Exception e) {
- e.printStackTrace();
+ logger.warn("Failed to unregister acceptors", e.getMessage(), e);
}
}
}
[2/2] activemq-artemis git commit: This closes #896
Posted by cl...@apache.org.
This closes #896
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/5f7f0785
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/5f7f0785
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/5f7f0785
Branch: refs/heads/master
Commit: 5f7f0785c96bdb29b92c7443965d382ca2b8398d
Parents: a43c92a 3995319
Author: Clebert Suconic <cl...@apache.org>
Authored: Wed Nov 23 11:16:09 2016 -0500
Committer: Clebert Suconic <cl...@apache.org>
Committed: Wed Nov 23 11:16:09 2016 -0500
----------------------------------------------------------------------
.../org/apache/activemq/artemis/boot/Artemis.java | 6 +++++-
.../org/apache/activemq/artemis/utils/Base64.java | 15 ++++++++-------
.../artemis/jdbc/store/file/JDBCSequentialFile.java | 4 ++--
.../artemis/jdbc/store/journal/JDBCJournalImpl.java | 2 +-
.../jms/management/impl/JMSTopicControlImpl.java | 5 ++++-
.../jms/server/impl/JMSServerManagerImpl.java | 5 ++++-
.../artemis/core/journal/impl/JournalFileImpl.java | 5 ++++-
.../artemis/core/journal/impl/JournalImpl.java | 3 +--
.../protocol/amqp/broker/AMQPConnectionCallback.java | 5 +++--
.../core/protocol/mqtt/MQTTPublishManager.java | 3 +--
.../core/protocol/mqtt/MQTTSessionCallback.java | 1 -
.../core/protocol/openwire/OpenWireConnection.java | 12 +++++-------
.../core/protocol/openwire/amq/AMQConsumer.java | 5 +++--
.../artemis/rest/queue/push/UriStrategy.java | 3 +--
.../artemis/rest/util/HttpMessageHelper.java | 2 +-
.../server/impl/LegacyLDAPSecuritySettingPlugin.java | 4 ++--
.../management/impl/ManagementServiceImpl.java | 2 +-
17 files changed, 46 insertions(+), 36 deletions(-)
----------------------------------------------------------------------