activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r1443060 - /activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/store/DelayingStoreSupport.scala
Date Wed, 06 Feb 2013 16:46:09 GMT
Author: chirino
Date: Wed Feb  6 16:46:09 2013
New Revision: 1443060

URL: http://svn.apache.org/viewvc?rev=1443060&view=rev
Log:
Assert that we are executing on the expected dispatch queue.

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

Modified: activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/store/DelayingStoreSupport.scala
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/store/DelayingStoreSupport.scala?rev=1443060&r1=1443059&r2=1443060&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/store/DelayingStoreSupport.scala
(original)
+++ activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/store/DelayingStoreSupport.scala
Wed Feb  6 16:46:09 2013
@@ -513,8 +513,9 @@ trait DelayingStoreSupport extends Store
       flush_latency_counter.start { end=>
         flush_source.suspend
         store(uows) {
-          store_completed(uows)
+          assert_executing
           flush_source.resume
+          store_completed(uows)
           dispatch_queue.assertExecuting()
           uows.foreach { uow=>
             uow.actions.foreach { case (msg, action) =>



Mime
View raw message