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
     }