diff options
| author | Alex Rudyy <orudyy@apache.org> | 2015-01-20 18:03:19 +0000 |
|---|---|---|
| committer | Alex Rudyy <orudyy@apache.org> | 2015-01-20 18:03:19 +0000 |
| commit | 6c2d47111003763d0f81cab83e1e7d24544dd852 (patch) | |
| tree | 9cf31b4221f759bf433fe30d87e47c94cb668bd8 /qpid/java | |
| parent | b5df74c2a2b4b62783f05b8801a5d0233dda5791 (diff) | |
| download | qpid-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.java | 17 |
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); + } } } |
