Author: chirino
Date: Fri Jan 20 16:53:42 2012
New Revision: 1233999

URL: http://svn.apache.org/viewvc?rev=1233999&view=rev
Log:
Error would occur if you tried to delete a dsub from the web admin screen.

Modified:
    activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/LocalRouter.scala

Modified: activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/LocalRouter.scala
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/LocalRouter.scala?rev=1233999&r1=1233998&r2=1233999&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/LocalRouter.scala (original)
+++ activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/LocalRouter.scala Fri Jan 20 16:53:42 2012
@@ -569,7 +569,7 @@ class LocalRouter(val virtual_host:Virtu
         matches.foreach( _.unbind_durable_subscription(destination, queue) )
       }
 
-      val path = destination_parser.decode_path(destination.path)
+      val path = Path(destination.subscription_id)
       remove_destination(path, queue)
     }
 
@@ -1264,6 +1264,10 @@ class LocalRouter(val virtual_host:Virtu
     val config = binding.config(virtual_host)
 
     val queue = new Queue(this, qid, binding, config)
+    if( queue.tune_persistent && id == -1) {
+      val record = QueueRecord(queue.store_id, binding.binding_kind, binding.binding_data)
+      virtual_host.store.add_queue(record) { rc => Unit }
+    }
 
     queue.start
     queues_by_binding.put(binding, queue)