Repository: activemq-artemis Updated Branches: refs/heads/master 505b73284 -> 5792fca9c
ARTEMIS-713 Possible integer overflow in SubscriptionsResource.recreateTopicConsumer Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/78409ae5 Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/78409ae5 Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/78409ae5 Branch: refs/heads/master Commit: 78409ae5e92804d3638eac918d567e96988be03d Parents: 505b732 Author: Martin Styk <[email protected]> Authored: Wed Sep 7 09:25:57 2016 +0200 Committer: Martin Styk <[email protected]> Committed: Wed Sep 7 09:25:57 2016 +0200 ---------------------------------------------------------------------- .../apache/activemq/artemis/rest/topic/SubscriptionsResource.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/78409ae5/artemis-rest/src/main/java/org/apache/activemq/artemis/rest/topic/SubscriptionsResource.java ---------------------------------------------------------------------- diff --git a/artemis-rest/src/main/java/org/apache/activemq/artemis/rest/topic/SubscriptionsResource.java b/artemis-rest/src/main/java/org/apache/activemq/artemis/rest/topic/SubscriptionsResource.java index 2fcbdd5..2f5156a 100644 --- a/artemis-rest/src/main/java/org/apache/activemq/artemis/rest/topic/SubscriptionsResource.java +++ b/artemis-rest/src/main/java/org/apache/activemq/artemis/rest/topic/SubscriptionsResource.java @@ -376,7 +376,7 @@ public class SubscriptionsResource implements TimeoutTask.Callback { if (subscriptionExists(subscriptionId)) { QueueConsumer tmp = null; try { - tmp = createConsumer(true, autoAck, subscriptionId, null, consumerTimeoutSeconds * 1000, false); + tmp = createConsumer(true, autoAck, subscriptionId, null, consumerTimeoutSeconds * 1000l, false); } catch (ActiveMQException e) { throw new RuntimeException(e);
