activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r1352621 - /activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/Router.scala
Date Thu, 21 Jun 2012 17:09:05 GMT
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
     }
   }



Mime
View raw message