activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From gtu...@apache.org
Subject svn commit: r1097069 - /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java
Date Wed, 27 Apr 2011 10:29:32 GMT
Author: gtully
Date: Wed Apr 27 10:29:32 2011
New Revision: 1097069

URL: http://svn.apache.org/viewvc?rev=1097069&view=rev
Log:
Ensure provided temp data store is started

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?rev=1097069&r1=1097068&r2=1097069&view=diff
==============================================================================
--- 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 Apr 27 10:29:32 2011
@@ -1465,6 +1465,13 @@ public class BrokerService implements Se
      */
     public void setTempDataStore(PListStore tempDataStore) {
         this.tempDataStore = tempDataStore;
+        try {
+            tempDataStore.start();
+        } catch (Exception e) {
+            RuntimeException exception = new RuntimeException("Failed to start provided temp
data store: " + tempDataStore, e);
+            LOG.error(exception.getLocalizedMessage(), e);
+            throw exception;
+        }
     }
 
     public int getPersistenceThreadPriority() {



Mime
View raw message