activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r1294424 - /activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/Sink.scala
Date Tue, 28 Feb 2012 00:43:06 GMT
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
     }



Mime
View raw message