activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rajdav...@apache.org
Subject svn commit: r513467 - /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java
Date Thu, 01 Mar 2007 19:43:12 GMT
Author: rajdavies
Date: Thu Mar  1 11:43:12 2007
New Revision: 513467

URL: http://svn.apache.org/viewvc?view=rev&rev=513467
Log:
ensure deleteAllMessages gets passed to the persistence adapter whilst it still makes sense

Modified:
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java?view=diff&rev=513467&r1=513466&r2=513467
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java
(original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java
Thu Mar  1 11:43:12 2007
@@ -1332,6 +1332,9 @@
         // we must start the persistence adaptor before we can create the region
         // broker
         getPersistenceAdapter().setUsageManager(getProducerUsageManager());
+        if(this.deleteAllMessagesOnStartup){
+            getPersistenceAdapter().deleteAllMessages();
+        }
         getPersistenceAdapter().start();
         
         DestinationInterceptor destinationInterceptor = null;



Mime
View raw message