Repository: activemq-artemis Updated Branches: refs/heads/1.x 6f96b057d -> 655f6beb0
NO-JIRA: logger on Exception (cherry picked from commit 75a4162a36a32d0247f29860c2d74c9fb03d91a4) Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/655f6beb Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/655f6beb Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/655f6beb Branch: refs/heads/1.x Commit: 655f6beb040068759bcff0b93e042ef50e6326ca Parents: 6f96b05 Author: Clebert Suconic <[email protected]> Authored: Tue Mar 14 09:50:19 2017 -0400 Committer: Clebert Suconic <[email protected]> Committed: Tue Mar 14 09:51:10 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/655f6beb/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 b95d641..9e12aa4 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 @@ -39,9 +39,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 @@ -240,6 +243,7 @@ public class JournalCompactor extends AbstractJournalUpdateTask implements Journ try { command.execute(); } catch (Exception e) { + logger.warn(e.getMessage(), e); ActiveMQJournalLogger.LOGGER.errorReplayingCommands(e); } }
