You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by gt...@apache.org on 2016/10/07 15:26:25 UTC

activemq git commit: NO-JIRA - ensure stack trace in incuded with exception that terminates data file appender thread

Repository: activemq
Updated Branches:
  refs/heads/master 8493f6b4d -> 538ed7451


NO-JIRA - ensure stack trace in incuded with exception that terminates data file appender thread


Project: http://git-wip-us.apache.org/repos/asf/activemq/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/538ed745
Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/538ed745
Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/538ed745

Branch: refs/heads/master
Commit: 538ed745106887545d6de0210c2f4929f6b2a20c
Parents: 8493f6b
Author: gtully <ga...@gmail.com>
Authored: Fri Oct 7 16:26:07 2016 +0100
Committer: gtully <ga...@gmail.com>
Committed: Fri Oct 7 16:26:07 2016 +0100

----------------------------------------------------------------------
 .../activemq/store/kahadb/disk/journal/DataFileAppender.java       | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/activemq/blob/538ed745/activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/disk/journal/DataFileAppender.java
----------------------------------------------------------------------
diff --git a/activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/disk/journal/DataFileAppender.java b/activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/disk/journal/DataFileAppender.java
index 1e87331..a799803 100644
--- a/activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/disk/journal/DataFileAppender.java
+++ b/activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/disk/journal/DataFileAppender.java
@@ -356,7 +356,7 @@ class DataFileAppender implements FileAppender {
                 signalDone(wb);
             }
         } catch (IOException e) {
-            logger.info("Journal failed while writing at: " + wb.offset);
+            logger.warn("Journal failed while writing at: " + wb.dataFile.getDataFileId() + ":" + wb.offset, e);
             synchronized (enqueueMutex) {
                 firstAsyncException = e;
                 if (wb != null) {