Author: chirino
Date: Wed Dec 8 21:38:37 2010
New Revision: 1043689
URL: http://svn.apache.org/viewvc?rev=1043689&view=rev
Log:
default to block.. it performs better.
Modified:
activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/Router.scala
Modified:
activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/Router.scala
URL:
http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/Router.scala?rev=1043689&r1=1043688&r2=1043689&view=diff
==============================================================================
---
activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/Router.scala
(original)
+++
activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/Router.scala
Wed Dec 8 21:38:37 2010
@@ -356,7 +356,7 @@ class RoutingNode(val router:Router, val
}
def unified = config.unified.getOrElse(false)
- def slow_consumer_policy = config.slow_consumer_policy.getOrElse("queue")
+ def slow_consumer_policy = config.slow_consumer_policy.getOrElse("block")
var consumer_proxies = Map[DeliveryConsumer, DeliveryConsumer]()