Author: chirino
Date: Thu Mar 20 21:26:33 2008
New Revision: 639539
URL: http://svn.apache.org/viewvc?rev=639539&view=rev
Log:
Disable lazy dispatch. Was causing queue browser tests to fail.
Modified:
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/BaseDestination.java
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PolicyEntry.java
Modified:
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/BaseDestination.java
URL:
http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/BaseDestination.java?rev=639539&r1=639538&r2=639539&view=diff
==============================================================================
---
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/BaseDestination.java
(original)
+++
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/BaseDestination.java
Thu Mar 20 21:26:33 2008
@@ -43,7 +43,7 @@
private int maxPageSize=100;
private boolean useCache=true;
private int minimumMessageSize=1024;
- private boolean lazyDispatch=true;
+ private boolean lazyDispatch=false;
protected final DestinationStatistics destinationStatistics = new
DestinationStatistics();
protected final BrokerService brokerService;
Modified:
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PolicyEntry.java
URL:
http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PolicyEntry.java?rev=639539&r1=639538&r2=639539&view=diff
==============================================================================
---
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PolicyEntry.java
(original)
+++
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PolicyEntry.java
Thu Mar 20 21:26:33 2008
@@ -61,7 +61,7 @@
private long minimumMessageSize=1024;
private boolean useConsumerPriority=true;
private boolean strictOrderDispatch=false;
- private boolean lazyDispatch=true;
+ private boolean lazyDispatch=false;
public void configure(Broker broker,Queue queue) {
if (dispatchPolicy != null) {
