activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r1036318 - /activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/Queue.scala
Date Thu, 18 Nov 2010 02:54:04 GMT
Author: chirino
Date: Thu Nov 18 02:54:03 2010
New Revision: 1036318

URL: http://svn.apache.org/viewvc?rev=1036318&view=rev
Log:
Switch back to the dispatchQueue context after a the store access.

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

Modified: activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/Queue.scala
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/Queue.scala?rev=1036318&r1=1036317&r2=1036318&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/Queue.scala
(original)
+++ activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/Queue.scala
Thu Nov 18 02:54:03 2010
@@ -176,7 +176,9 @@ class Queue(val host: VirtualHost, var i
         record.binding_kind = binding.binding_kind
 
         host.store.addQueue(record) { rc =>
-          completed
+          dispatchQueue {
+            completed
+          }
         }
 
       } else {



Mime
View raw message