diff --git a/activemq-core/src/main/java/org/apache/activemq/broker/region/BaseDestination.java b/activemq-core/src/main/java/org/apache/activemq/broker/region/BaseDestination.java index 011006994a..6e0befd743 100755 --- a/activemq-core/src/main/java/org/apache/activemq/broker/region/BaseDestination.java +++ b/activemq-core/src/main/java/org/apache/activemq/broker/region/BaseDestination.java @@ -43,7 +43,7 @@ public abstract class BaseDestination implements Destination { 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; diff --git a/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PolicyEntry.java b/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PolicyEntry.java index 67f06998ed..8943556325 100644 --- a/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PolicyEntry.java +++ b/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PolicyEntry.java @@ -61,7 +61,7 @@ public class PolicyEntry extends DestinationMapEntry { 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) {