You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by cl...@apache.org on 2017/12/21 08:28:41 UTC
activemq-artemis git commit: NO-JIRA Fixing SystemPropertyOverrideTest
Repository: activemq-artemis
Updated Branches:
refs/heads/master 2dda27e1b -> a6c55469b
NO-JIRA Fixing SystemPropertyOverrideTest
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/a6c55469
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/a6c55469
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/a6c55469
Branch: refs/heads/master
Commit: a6c55469b767c8974ee1bf7d3ea842b859f56a41
Parents: 2dda27e
Author: Clebert Suconic <cl...@apache.org>
Authored: Thu Dec 21 03:27:24 2017 -0500
Committer: Clebert Suconic <cl...@apache.org>
Committed: Thu Dec 21 03:27:40 2017 -0500
----------------------------------------------------------------------
.../core/server/group/impl/GroupingHandlerConfiguration.java | 7 +++++++
1 file changed, 7 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/a6c55469/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/group/impl/GroupingHandlerConfiguration.java
----------------------------------------------------------------------
diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/group/impl/GroupingHandlerConfiguration.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/group/impl/GroupingHandlerConfiguration.java
index 4ee8269..5b38455 100644
--- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/group/impl/GroupingHandlerConfiguration.java
+++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/group/impl/GroupingHandlerConfiguration.java
@@ -45,6 +45,13 @@ public final class GroupingHandlerConfiguration implements Serializable {
private long reaperPeriod = ActiveMQDefaultConfiguration.getDefaultGroupingHandlerReaperPeriod();
public GroupingHandlerConfiguration() {
+ if (System.getProperty(GROUP_TIMEOUT_PROP_NAME) != null) {
+ this.groupTimeout = Long.parseLong(System.getProperty(GROUP_TIMEOUT_PROP_NAME));
+ }
+
+ if (System.getProperty(REAPER_PERIOD_PROP_NAME) != null) {
+ this.reaperPeriod = Long.parseLong(System.getProperty(REAPER_PERIOD_PROP_NAME));
+ }
}
public SimpleString getName() {