From 6813691a3d8e8443b3841175893d265188932f5b Mon Sep 17 00:00:00 2001 From: Gary Tully Date: Mon, 28 Nov 2011 14:44:56 +0000 Subject: [PATCH] https://issues.apache.org/jira/browse/AMQ-3609 - Turn inactivity monitor thread off by default, new default 0 git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1207239 13f79535-47bb-0310-9956-ffa450edef68 --- .../src/main/java/org/apache/activemq/broker/BrokerService.java | 2 +- .../activemq/usecases/RequestReplyNoAdvisoryNetworkTest.java | 1 + 2 files changed, 2 insertions(+), 1 deletion(-) diff --git a/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java b/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java index 92c0a59034..7a37b10d39 100644 --- a/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java +++ b/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java @@ -195,7 +195,7 @@ public class BrokerService implements Service { private Scheduler scheduler; private ThreadPoolExecutor executor; private boolean slave = true; - private int schedulePeriodForDestinationPurge=5000; + private int schedulePeriodForDestinationPurge= 0; private int maxPurgedDestinationsPerSweep = 0; private BrokerContext brokerContext; private boolean networkConnectorStartAsync = false; diff --git a/activemq-core/src/test/java/org/apache/activemq/usecases/RequestReplyNoAdvisoryNetworkTest.java b/activemq-core/src/test/java/org/apache/activemq/usecases/RequestReplyNoAdvisoryNetworkTest.java index dc3432514e..720dba5b43 100644 --- a/activemq-core/src/test/java/org/apache/activemq/usecases/RequestReplyNoAdvisoryNetworkTest.java +++ b/activemq-core/src/test/java/org/apache/activemq/usecases/RequestReplyNoAdvisoryNetworkTest.java @@ -259,6 +259,7 @@ public class RequestReplyNoAdvisoryNetworkTest extends JmsMultipleBrokersTestSup broker.setAdvisorySupport(false); broker.setPersistent(false); broker.setUseJmx(false); + broker.setSchedulePeriodForDestinationPurge(1000); PolicyMap map = new PolicyMap(); PolicyEntry tempReplyQPolicy = new PolicyEntry();