summaryrefslogtreecommitdiff
path: root/qpid/java
diff options
context:
space:
mode:
authorAlex Rudyy <orudyy@apache.org>2015-01-20 18:03:19 +0000
committerAlex Rudyy <orudyy@apache.org>2015-01-20 18:03:19 +0000
commit6c2d47111003763d0f81cab83e1e7d24544dd852 (patch)
tree9cf31b4221f759bf433fe30d87e47c94cb668bd8 /qpid/java
parentb5df74c2a2b4b62783f05b8801a5d0233dda5791 (diff)
downloadqpid-python-6c2d47111003763d0f81cab83e1e7d24544dd852.tar.gz
QPID-6259: Fix stopping of BDB committer from committer thread
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1653320 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java')
-rw-r--r--qpid/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/CoalescingCommiter.java17
1 files changed, 10 insertions, 7 deletions
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 ff383ecf97..964335869d 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,14 +50,17 @@ public class CoalescingCommiter implements Committer
public void stop()
{
_commitThread.close();
- try
+ if (Thread.currentThread() != _commitThread)
{
- _commitThread.join();
- }
- catch (InterruptedException ie)
- {
- Thread.currentThread().interrupt();
- throw new RuntimeException("Commit thread has not shutdown", ie);
+ try
+ {
+ _commitThread.join();
+ }
+ catch (InterruptedException ie)
+ {
+ Thread.currentThread().interrupt();
+ throw new RuntimeException("Commit thread has not shutdown", ie);
+ }
}
}