Author: ceposta
Date: Tue May 14 03:37:39 2013
New Revision: 1482180
URL: http://svn.apache.org/r1482180
Log:
Fix for https://issues.apache.org/jira/browse/AMQ-4534 When using
ElectingLevelDBStore cannot delete all messages on startup
Modified:
activemq/trunk/activemq-leveldb-store/src/main/scala/org/apache/activemq/leveldb/replicated/ElectingLevelDBStore.scala
Modified:
activemq/trunk/activemq-leveldb-store/src/main/scala/org/apache/activemq/leveldb/replicated/ElectingLevelDBStore.scala
URL:
http://svn.apache.org/viewvc/activemq/trunk/activemq-leveldb-store/src/main/scala/org/apache/activemq/leveldb/replicated/ElectingLevelDBStore.scala?rev=1482180&r1=1482179&r2=1482180&view=diff
==============================================================================
---
activemq/trunk/activemq-leveldb-store/src/main/scala/org/apache/activemq/leveldb/replicated/ElectingLevelDBStore.scala
(original)
+++
activemq/trunk/activemq-leveldb-store/src/main/scala/org/apache/activemq/leveldb/replicated/ElectingLevelDBStore.scala
Tue May 14 03:37:39 2013
@@ -264,6 +264,15 @@ class ElectingLevelDBStore extends Proxy
this.brokerName = brokerName
}
+
+ override def deleteAllMessages {
+ if(proxy_target != null) proxy_target.deleteAllMessages
+ else {
+ info("You instructed the broker to delete all messages (on startup?). " +
+ "Cannot delete all messages from an ElectingLevelDBStore because we
need to decide who the master is first")
+ }
+ }
+
def configure(store: ReplicatedLevelDBStoreTrait) {
store.directory = directory
store.indexFactory = indexFactory
