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 2017/03/14 13:50:49 UTC
activemq-artemis git commit: NO-JIRA: logger on Exception
Repository: activemq-artemis
Updated Branches:
refs/heads/master b58381f20 -> 75a4162a3
NO-JIRA: logger on Exception
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/75a4162a
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/75a4162a
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/75a4162a
Branch: refs/heads/master
Commit: 75a4162a36a32d0247f29860c2d74c9fb03d91a4
Parents: b58381f
Author: Clebert Suconic <cl...@apache.org>
Authored: Tue Mar 14 09:50:19 2017 -0400
Committer: Clebert Suconic <cl...@apache.org>
Committed: Tue Mar 14 09:50:19 2017 -0400
----------------------------------------------------------------------
.../activemq/artemis/core/journal/impl/JournalCompactor.java | 4 ++++
1 file changed, 4 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/75a4162a/artemis-journal/src/main/java/org/apache/activemq/artemis/core/journal/impl/JournalCompactor.java
----------------------------------------------------------------------
diff --git a/artemis-journal/src/main/java/org/apache/activemq/artemis/core/journal/impl/JournalCompactor.java b/artemis-journal/src/main/java/org/apache/activemq/artemis/core/journal/impl/JournalCompactor.java
index c62b27b..1ac5676 100644
--- a/artemis-journal/src/main/java/org/apache/activemq/artemis/core/journal/impl/JournalCompactor.java
+++ b/artemis-journal/src/main/java/org/apache/activemq/artemis/core/journal/impl/JournalCompactor.java
@@ -40,9 +40,12 @@ import org.apache.activemq.artemis.core.journal.impl.dataformat.JournalDeleteRec
import org.apache.activemq.artemis.core.journal.impl.dataformat.JournalInternalRecord;
import org.apache.activemq.artemis.core.journal.impl.dataformat.JournalRollbackRecordTX;
import org.apache.activemq.artemis.journal.ActiveMQJournalLogger;
+import org.jboss.logging.Logger;
public class JournalCompactor extends AbstractJournalUpdateTask implements JournalRecordProvider {
+ private static final Logger logger = Logger.getLogger(JournalCompactor.class);
+
// We try to separate old record from new ones when doing the compacting
// this is a split line
// We will force a moveNextFiles when the compactCount is bellow than COMPACT_SPLIT_LINE
@@ -241,6 +244,7 @@ public class JournalCompactor extends AbstractJournalUpdateTask implements Journ
try {
command.execute();
} catch (Exception e) {
+ logger.warn(e.getMessage(), e);
ActiveMQJournalLogger.LOGGER.errorReplayingCommands(e);
}
}