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