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/08/23 20:12:33 UTC
[2/2] activemq-artemis git commit: ARTEMIS-1370 fixing checkstyle
ARTEMIS-1370 fixing checkstyle
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/16eca68b
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/16eca68b
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/16eca68b
Branch: refs/heads/master
Commit: 16eca68bffbba1b232b5ddfbd6150cd3ecd1e089
Parents: 7832166
Author: Clebert Suconic <cl...@apache.org>
Authored: Wed Aug 23 16:08:45 2017 -0400
Committer: Clebert Suconic <cl...@apache.org>
Committed: Wed Aug 23 16:08:45 2017 -0400
----------------------------------------------------------------------
.../artemis/cli/commands/messages/ConnectionAbstract.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/16eca68b/artemis-cli/src/main/java/org/apache/activemq/artemis/cli/commands/messages/ConnectionAbstract.java
----------------------------------------------------------------------
diff --git a/artemis-cli/src/main/java/org/apache/activemq/artemis/cli/commands/messages/ConnectionAbstract.java b/artemis-cli/src/main/java/org/apache/activemq/artemis/cli/commands/messages/ConnectionAbstract.java
index bf466c6..41443c4 100644
--- a/artemis-cli/src/main/java/org/apache/activemq/artemis/cli/commands/messages/ConnectionAbstract.java
+++ b/artemis-cli/src/main/java/org/apache/activemq/artemis/cli/commands/messages/ConnectionAbstract.java
@@ -26,6 +26,7 @@ import org.apache.activemq.artemis.cli.commands.InputAbstract;
import org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory;
public class ConnectionAbstract extends InputAbstract {
+
@Option(name = "--url", description = "URL towards the broker. (default: tcp://localhost:61616)")
protected String brokerURL = "tcp://localhost:61616";
@@ -38,11 +39,10 @@ public class ConnectionAbstract extends InputAbstract {
@Option(name = "--clientID", description = "ClientID to be associated with connection")
String clientID;
-
protected ActiveMQConnectionFactory createConnectionFactory() throws Exception {
ActiveMQConnectionFactory cf = new ActiveMQConnectionFactory(brokerURL, user, password);
- if(clientID!=null){
+ if (clientID != null) {
System.out.println("Consumer:: clientID = " + clientID);
cf.setClientID(clientID);
}
@@ -58,7 +58,7 @@ public class ConnectionAbstract extends InputAbstract {
} catch (JMSException e) {
// if a connection exception will ask for the URL, user and password
context.err.println("Connection failed::" + e.getMessage());
- brokerURL = input("--url", "Type in the broker URL for a retry (e.g. tcp://localhost:61616)", brokerURL);
+ brokerURL = input("--url", "Type in the broker URL for a retry (e.g. tcp://localhost:61616)", brokerURL);
userPassword();
return new ActiveMQConnectionFactory(brokerURL, user, password);
}