mirror of https://github.com/apache/activemq.git
fix leveldb version of org.apache.activemq.bugs.AMQ2870Test#testSize
This commit is contained in:
parent
f92d45bec1
commit
0f0c0d676a
|
@ -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) = {
|
||||
|
|
Loading…
Reference in New Issue