activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r1291475 - /activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/Queue.scala
Date Mon, 20 Feb 2012 21:59:34 GMT
Author: chirino
Date: Mon Feb 20 21:59:34 2012
New Revision: 1291475

URL: http://svn.apache.org/viewvc?rev=1291475&view=rev
Log:
Change the label for a subscription that is blocking from waiting on "ack" to waiting on "consumer",
since ack's are not necessarily related to the subscription flow control.

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=1291475&r1=1291474&r2=1291475&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
Mon Feb 20 21:59:34 2012
@@ -358,7 +358,7 @@ class Queue(val router: LocalRouter, val
       link.acquired_size = sub.acquired_size
       link.acquired_count = sub.acquired_count
       link.waiting_on = if( sub.full ) {
-        "ack"
+        "consumer"
       } else if( sub.pos.is_tail ) {
         "producer"
       } else if( !sub.pos.is_loaded ) {



Mime
View raw message