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 ) {
