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/06/21 19:09:05 UTC
svn commit: r1352621 -
/activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/Router.scala
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
}
}