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 2012/02/20 22:59:34 UTC
svn commit: r1291475 -
/activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/Queue.scala
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 ) {