activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r639539 - in /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region: BaseDestination.java policy/PolicyEntry.java
Date Fri, 21 Mar 2008 04:26:43 GMT
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) {



Mime
View raw message