activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r1294385 - /activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/Sink.scala
Date Mon, 27 Feb 2012 23:06:21 GMT
Author: chirino
Date: Mon Feb 27 23:06:21 2012
New Revision: 1294385

URL: http://svn.apache.org/viewvc?rev=1294385&view=rev
Log:
Small perf tweak

Modified:
    activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/Sink.scala

Modified: activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/Sink.scala
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/Sink.scala?rev=1294385&r1=1294384&r2=1294385&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/Sink.scala
(original)
+++ activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/Sink.scala
Mon Feb 27 23:06:21 2012
@@ -342,20 +342,9 @@ class SessionSinkMux[T](val downstream:S
       // overflow sinks can always accept more values.
       val f1 = overflow.full
       overflow.offer(event)
-      if( !f1 && overflow.full ) {
-        // once we fill, we stop the credit adder sources
-        // this should stop them from sending us more messages.
-        sessions.foreach(_.credit_adder.suspend)
-      }
     }
   }
 
-  overflow.refiller = ^{
-    consumer_queue.assertExecuting()
-    // overflow is not full anymore.. lets release those credits so we can get more messages.
-    sessions.foreach(_.credit_adder.resume)
-  }
-
   def open(producer_queue:DispatchQueue, credits:Int=SessionSinkMux.default_session_max_credits):SessionSink[T]
= {
     val session = new Session[T](producer_queue, 0, this)
     consumer_queue <<| ^{



Mime
View raw message