Author: chirino
Date: Thu Jun 21 17:09:04 2012
New Revision: 1352621
URL: http://svn.apache.org/viewvc?rev=1352621&view=rev
Log:
Fixes APLO-214: Typo in Router.scala
Modified:
activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/Router.scala
Modified:
activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/Router.scala
URL:
http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/Router.scala?rev=1352621&r1=1352620&r2=1352621&view=diff
==============================================================================
---
activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/Router.scala
(original)
+++
activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/Router.scala
Thu Jun 21 17:09:04 2012
@@ -226,7 +226,7 @@ abstract class DeliveryProducerRoute(rou
consumers.foreach(_.retain)
dispatch_queue {
consumers.foreach{ x=>
- debug("producer route attaching to conusmer.")
+ debug("producer route attaching to consumer.")
val target = connect(x);
target.refiller = drainer
targets ::= target
@@ -240,7 +240,7 @@ abstract class DeliveryProducerRoute(rou
this.targets = this.targets.filterNot { x=>
val rc = targets.contains(x.consumer)
if( rc ) {
- debug("producer route detaching from conusmer.")
+ debug("producer route detaching from consumer.")
if( !overflowSessions.isEmpty ) {
overflowSessions = overflowSessions.filterNot( _ == x )
if( overflowSessions.isEmpty ) {
@@ -256,7 +256,7 @@ abstract class DeliveryProducerRoute(rou
def disconnected() = dispatch_queue {
this.targets.foreach { x=>
- debug("producer route detaching from conusmer.")
+ debug("producer route detaching from consumer.")
x.close
}
}
