activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From gtu...@apache.org
Subject activemq git commit: https://issues.apache.org/jira/browse/AMQ-5603 - catch interrupted on chunked zeros case
Date Tue, 03 May 2016 16:25:42 GMT
Repository: activemq
Updated Branches:
  refs/heads/master 2e0089182 -> 555cd2b6b


https://issues.apache.org/jira/browse/AMQ-5603 - catch interrupted on chunked zeros case


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

Branch: refs/heads/master
Commit: 555cd2b6bb7f25db318e26482e4ed11cd9da7d07
Parents: 2e00891
Author: gtully <gary.tully@gmail.com>
Authored: Tue May 3 17:25:05 2016 +0100
Committer: gtully <gary.tully@gmail.com>
Committed: Tue May 3 17:25:14 2016 +0100

----------------------------------------------------------------------
 .../org/apache/activemq/store/kahadb/disk/journal/Journal.java     | 2 ++
 1 file changed, 2 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/activemq/blob/555cd2b6/activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/disk/journal/Journal.java
----------------------------------------------------------------------
diff --git a/activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/disk/journal/Journal.java
b/activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/disk/journal/Journal.java
index 182a3d7..a48f8dd 100644
--- a/activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/disk/journal/Journal.java
+++ b/activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/disk/journal/Journal.java
@@ -408,6 +408,8 @@ public class Journal {
 
             channel.force(false);
             channel.position(0);
+        } catch (ClosedByInterruptException ignored) {
+            LOG.trace("Could not preallocate journal file with zeros", ignored);
         } catch (IOException e) {
             LOG.error("Could not preallocate journal file with zeros! Will continue without
preallocation", e);
         }


Mime
View raw message