You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ch...@apache.org on 2010/07/07 06:14:13 UTC

svn commit: r961178 - /activemq/sandbox/activemq-apollo-actor/activemq-stomp/src/main/scala/org/apache/activemq/apollo/stomp/StompBroker.scala

Author: chirino
Date: Wed Jul  7 04:14:12 2010
New Revision: 961178

URL: http://svn.apache.org/viewvc?rev=961178&view=rev
Log:
add an option to purge the store

Modified:
    activemq/sandbox/activemq-apollo-actor/activemq-stomp/src/main/scala/org/apache/activemq/apollo/stomp/StompBroker.scala

Modified: activemq/sandbox/activemq-apollo-actor/activemq-stomp/src/main/scala/org/apache/activemq/apollo/stomp/StompBroker.scala
URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/activemq-stomp/src/main/scala/org/apache/activemq/apollo/stomp/StompBroker.scala?rev=961178&r1=961177&r2=961178&view=diff
==============================================================================
--- activemq/sandbox/activemq-apollo-actor/activemq-stomp/src/main/scala/org/apache/activemq/apollo/stomp/StompBroker.scala (original)
+++ activemq/sandbox/activemq-apollo-actor/activemq-stomp/src/main/scala/org/apache/activemq/apollo/stomp/StompBroker.scala Wed Jul  7 04:14:12 2010
@@ -28,6 +28,7 @@ object StompBroker {
   var address = "0.0.0.0"
   var port = 61613
   var storeType = "hawtdb"
+  var purge = true
 
   def main(args:Array[String]) = run
 
@@ -61,6 +62,7 @@ object StompBroker {
         rc
     }
     broker.config.virtualHosts.get(0).store = store
+    broker.config.virtualHosts.get(0).purgeOnStartup = purge
 
 
 
@@ -89,6 +91,7 @@ object StompBroker {
     "address          = "+address+"\n"+
     "port             = "+port+"\n"+
     "storeType        = "+storeType+"\n" +
+    "purge            = "+purge+"\n"+
     ""
   }  
 }
\ No newline at end of file