You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ra...@apache.org on 2007/03/21 10:37:40 UTC
svn commit: r520819 -
/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java
Author: rajdavies
Date: Wed Mar 21 02:37:39 2007
New Revision: 520819
URL: http://svn.apache.org/viewvc?view=rev&rev=520819
Log:
added soft bunny log message - so we don't scare folks when we delete all their messages on startup
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=520819&r1=520818&r2=520819
==============================================================================
--- 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 Wed Mar 21 02:37:39 2007
@@ -1048,12 +1048,14 @@
/**
* @return the tempDataStore
*/
- public synchronized Store getTempDataStore() {
- if (tempDataStore == null){
- String name = getTmpDataDirectory().getPath();
- try {
- StoreFactory.delete(name);
- tempDataStore = StoreFactory.open(name,"rw");
+ public synchronized Store getTempDataStore(){
+ if(tempDataStore==null){
+ String name=getTmpDataDirectory().getPath();
+ try{
+ log.info("About to delete any non-persistent messages that may have overflowed to disk ...");
+ StoreFactory.delete(name);
+ log.info("Successfully deleted temporary storage");
+ tempDataStore=StoreFactory.open(name,"rw");
}catch(IOException e){
throw new RuntimeException(e);
}