diff options
2 files changed, 4 insertions, 2 deletions
diff --git a/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/BDBConfigurationStore.java b/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/BDBConfigurationStore.java index ca32ffaa73..6ff4072d20 100644 --- a/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/BDBConfigurationStore.java +++ b/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/BDBConfigurationStore.java @@ -712,7 +712,7 @@ public class BDBConfigurationStore implements MessageStoreProvider, DurableConfi { if (_committer != null) { - _committer.stop(); + _committer.close(); } } finally diff --git a/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/CoalescingCommiter.java b/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/CoalescingCommiter.java index cf76d13f2a..c76f4ff2db 100644 --- a/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/CoalescingCommiter.java +++ b/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/CoalescingCommiter.java @@ -50,7 +50,9 @@ public class CoalescingCommiter implements Committer @Override public Thread newThread(Runnable r) { - return new Thread(r, "Commit-Thread-" + name); + Thread t = new Thread(r, "Commit-Thread-" + name); + t.setDaemon(true); + return t; } }); } |