Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id 35617200BD9 for ; Fri, 9 Dec 2016 20:48:54 +0100 (CET) Received: by cust-asf.ponee.io (Postfix) id 34368160B2D; Fri, 9 Dec 2016 19:48:54 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id B3EF6160B1E for ; Fri, 9 Dec 2016 20:48:52 +0100 (CET) Received: (qmail 92192 invoked by uid 500); 9 Dec 2016 19:48:48 -0000 Mailing-List: contact commits-help@activemq.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@activemq.apache.org Delivered-To: mailing list commits@activemq.apache.org Received: (qmail 89313 invoked by uid 99); 9 Dec 2016 19:48:46 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 09 Dec 2016 19:48:46 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 914B6F1712; Fri, 9 Dec 2016 19:48:46 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: clebertsuconic@apache.org To: commits@activemq.apache.org Date: Fri, 09 Dec 2016 19:49:23 -0000 Message-Id: <7e9ddb3d495342f88ec2883294a3ff1a@git.apache.org> In-Reply-To: References: X-Mailer: ASF-Git Admin Mailer Subject: [39/50] [abbrv] activemq-artemis git commit: ARTEMIS-878 Use Strings in CLI JMX interaction archived-at: Fri, 09 Dec 2016 19:48:54 -0000 ARTEMIS-878 Use Strings in CLI JMX interaction Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/8057ec4b Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/8057ec4b Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/8057ec4b Branch: refs/heads/master Commit: 8057ec4b27fca60ccfe7d83e5b19e23e37169cc3 Parents: 1339c93 Author: jbertram Authored: Fri Dec 9 18:00:53 2016 +0000 Committer: Martyn Taylor Committed: Fri Dec 9 18:43:15 2016 +0000 ---------------------------------------------------------------------- .../artemis/cli/commands/address/CreateAddress.java | 16 ++++++++-------- 1 file changed, 8 insertions(+), 8 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/8057ec4b/artemis-cli/src/main/java/org/apache/activemq/artemis/cli/commands/address/CreateAddress.java ---------------------------------------------------------------------- diff --git a/artemis-cli/src/main/java/org/apache/activemq/artemis/cli/commands/address/CreateAddress.java b/artemis-cli/src/main/java/org/apache/activemq/artemis/cli/commands/address/CreateAddress.java index ac1a9a9..42f721a 100644 --- a/artemis-cli/src/main/java/org/apache/activemq/artemis/cli/commands/address/CreateAddress.java +++ b/artemis-cli/src/main/java/org/apache/activemq/artemis/cli/commands/address/CreateAddress.java @@ -17,9 +17,6 @@ package org.apache.activemq.artemis.cli.commands.address; -import java.util.HashSet; -import java.util.Set; - import io.airlift.airline.Command; import io.airlift.airline.Option; import org.apache.activemq.artemis.api.core.client.ClientMessage; @@ -35,7 +32,7 @@ public class CreateAddress extends AbstractAction { String name; @Option(name = "--routingTypes", description = "The routing types supported by this address, options are 'anycast' or 'multicast', enter comma separated list, defaults to 'multicast' only") - Set routingTypes = new HashSet<>(); + String[] routingTypes = new String[] {RoutingType.MULTICAST.toString()}; @Option(name = "--defaultMaxConsumers", description = "Sets the default max consumers for any queues created under this address, default = -1 (no limit)") int defaultMaxConsumers = -1; @@ -54,7 +51,7 @@ public class CreateAddress extends AbstractAction { performCoreManagement(new ManagementCallback() { @Override public void setUpInvocation(ClientMessage message) throws Exception { - ManagementHelper.putOperationInvocation(message, "broker", "createAddress", getName(), routingTypes, defaultDeleteOnNoConsumers, defaultMaxConsumers); + ManagementHelper.putOperationInvocation(message, "broker", "createAddress", getName(), routingTypes); } @Override @@ -78,13 +75,16 @@ public class CreateAddress extends AbstractAction { return name; } - public Set getRoutingTypes() { + public String[] getRoutingTypes() { return routingTypes; } public void setRoutingTypes(String routingTypes) { - for (String s : routingTypes.split(",")) { - this.routingTypes.add(RoutingType.valueOf(s.trim())); + String[] split = routingTypes.split(","); + this.routingTypes = new String[split.length]; + for (int i = 0; i < split.length; i++) { + RoutingType.valueOf(split[i].trim()); + this.routingTypes[i] = split[i].trim(); } }