activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rajdav...@apache.org
Subject svn commit: r520819 - /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java
Date Wed, 21 Mar 2007 09:37:40 GMT
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);
             }



Mime
View raw message