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 2014/01/08 13:48:58 UTC
[2/2] git commit: fix leveldb version of
org.apache.activemq.bugs.AMQ2870Test#testSize
fix leveldb version of org.apache.activemq.bugs.AMQ2870Test#testSize
Project: http://git-wip-us.apache.org/repos/asf/activemq/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/0f0c0d67
Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/0f0c0d67
Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/0f0c0d67
Branch: refs/heads/trunk
Commit: 0f0c0d676a852db0d5dae5863d3464ea23a3085d
Parents: f92d45b
Author: gtully <ga...@gmail.com>
Authored: Tue Jan 7 16:54:18 2014 +0000
Committer: gtully <ga...@gmail.com>
Committed: Tue Jan 7 16:54:18 2014 +0000
----------------------------------------------------------------------
.../src/main/scala/org/apache/activemq/leveldb/DBManager.scala | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/activemq/blob/0f0c0d67/activemq-leveldb-store/src/main/scala/org/apache/activemq/leveldb/DBManager.scala
----------------------------------------------------------------------
diff --git a/activemq-leveldb-store/src/main/scala/org/apache/activemq/leveldb/DBManager.scala b/activemq-leveldb-store/src/main/scala/org/apache/activemq/leveldb/DBManager.scala
index cfcce78..b02cf0f 100644
--- a/activemq-leveldb-store/src/main/scala/org/apache/activemq/leveldb/DBManager.scala
+++ b/activemq-leveldb-store/src/main/scala/org/apache/activemq/leveldb/DBManager.scala
@@ -777,7 +777,9 @@ class DBManager(val parent:LevelDBStore) {
}
def removeSubscription(sub:DurableSubscription) {
- client.removeCollection(sub.subKey)
+ writeExecutor.sync {
+ client.removeCollection(sub.subKey)
+ }
}
def createTopicStore(dest:ActiveMQTopic) = {