activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From gtu...@apache.org
Subject svn commit: r1207239 - in /activemq/trunk/activemq-core/src: main/java/org/apache/activemq/broker/BrokerService.java test/java/org/apache/activemq/usecases/RequestReplyNoAdvisoryNetworkTest.java
Date Mon, 28 Nov 2011 14:44:57 GMT
Author: gtully
Date: Mon Nov 28 14:44:56 2011
New Revision: 1207239

URL: http://svn.apache.org/viewvc?rev=1207239&view=rev
Log:
https://issues.apache.org/jira/browse/AMQ-3609 - Turn inactivity monitor thread off by default,
new default 0

Modified:
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/usecases/RequestReplyNoAdvisoryNetworkTest.java

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java?rev=1207239&r1=1207238&r2=1207239&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java
(original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java
Mon Nov 28 14:44:56 2011
@@ -195,7 +195,7 @@ public class BrokerService implements Se
     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;

Modified: activemq/trunk/activemq-core/src/test/java/org/apache/activemq/usecases/RequestReplyNoAdvisoryNetworkTest.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/usecases/RequestReplyNoAdvisoryNetworkTest.java?rev=1207239&r1=1207238&r2=1207239&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/test/java/org/apache/activemq/usecases/RequestReplyNoAdvisoryNetworkTest.java
(original)
+++ activemq/trunk/activemq-core/src/test/java/org/apache/activemq/usecases/RequestReplyNoAdvisoryNetworkTest.java
Mon Nov 28 14:44:56 2011
@@ -259,6 +259,7 @@ public class RequestReplyNoAdvisoryNetwo
         broker.setAdvisorySupport(false);
         broker.setPersistent(false);
         broker.setUseJmx(false);
+        broker.setSchedulePeriodForDestinationPurge(1000);
 
         PolicyMap map = new PolicyMap();
         PolicyEntry tempReplyQPolicy = new PolicyEntry();



Mime
View raw message