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 <[email protected]> Authored: Tue Jan 7 16:54:18 2014 +0000 Committer: gtully <[email protected]> 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) = {
