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 <[email protected]> Authored: Tue Mar 14 09:50:19 2017 -0400 Committer: Clebert Suconic <[email protected]> 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); } }
