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/02/28 01:43:06 UTC
svn commit: r1294424 -
/activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/Sink.scala
Author: chirino
Date: Tue Feb 28 00:43:06 2012
New Revision: 1294424
URL: http://svn.apache.org/viewvc?rev=1294424&view=rev
Log:
Fixes failing test case that was introduced in last commit.
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=1294424&r1=1294423&r2=1294424&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 Tue Feb 28 00:43:06 2012
@@ -348,9 +348,6 @@ class SessionSinkMux[T](val downstream:S
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 <<| ^{
- if( overflow.full ) {
- session.credit_adder.suspend
- }
session.credit_adder.merge(credits);
sessions += session
}