use a long for grouping-handler's group-timeout

GEBIT · Nov 7, 2013 · 7f7ea2b · 7f7ea2b
1 parent a71f6cb
commit 7f7ea2b
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/hornetq-server/src/main/java/org/hornetq/core/deployers/impl/FileConfigurationParser.java b/hornetq-server/src/main/java/org/hornetq/core/deployers/impl/FileConfigurationParser.java
@@ -1172,7 +1172,7 @@ private void parseGroupingHandlerConfiguration(final Element node, final Configu
       String type = getString(node, "type", null, Validators.NOT_NULL_OR_EMPTY);
       String address = getString(node, "address", null, Validators.NOT_NULL_OR_EMPTY);
       Integer timeout = getInteger(node, "timeout", GroupingHandlerConfiguration.DEFAULT_TIMEOUT, Validators.GT_ZERO);
-      Integer groupTimeout = getInteger(node, "group-timeout", GroupingHandlerConfiguration.DEFAULT_GROUP_TIMEOUT, Validators.MINUS_ONE_OR_GT_ZERO);
+      Long groupTimeout = getLong(node, "group-timeout", GroupingHandlerConfiguration.DEFAULT_GROUP_TIMEOUT, Validators.MINUS_ONE_OR_GT_ZERO);
       Long reaperPeriod = getLong(node, "reaper-period", GroupingHandlerConfiguration.DEFAULT_REAPER_PERIOD, Validators.GT_ZERO);
       mainConfiguration.setGroupingHandlerConfiguration(new GroupingHandlerConfiguration(new SimpleString(name),
                                                                                          type.equals(GroupingHandlerConfiguration.TYPE.LOCAL.getType())

diff --git a/...server/src/main/java/org/hornetq/core/server/group/impl/GroupingHandlerConfiguration.java b/...server/src/main/java/org/hornetq/core/server/group/impl/GroupingHandlerConfiguration.java
@@ -27,7 +27,7 @@ public final class GroupingHandlerConfiguration implements Serializable
 
    public static final int DEFAULT_TIMEOUT = 5000;
 
-   public static final int DEFAULT_GROUP_TIMEOUT = -1;
+   public static final long DEFAULT_GROUP_TIMEOUT = -1;
 
    public static final long DEFAULT_REAPER_PERIOD = 30000;