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 15:00:12 UTC
[1/2] activemq-artemis git commit: This closes #1488
Repository: activemq-artemis
Updated Branches:
refs/heads/master 9021e0301 -> fccf14640
This closes #1488
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/fccf1464
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/fccf1464
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/fccf1464
Branch: refs/heads/master
Commit: fccf1464005a4b80f1388df8b55f730ee589196f
Parents: 9021e03 9ff5741
Author: Clebert Suconic <cl...@apache.org>
Authored: Wed Aug 23 11:00:04 2017 -0400
Committer: Clebert Suconic <cl...@apache.org>
Committed: Wed Aug 23 11:00:04 2017 -0400
----------------------------------------------------------------------
.../artemis/cli/commands/messages/ConnectionAbstract.java | 8 ++++++++
1 file changed, 8 insertions(+)
----------------------------------------------------------------------
[2/2] activemq-artemis git commit: ARTEMIS-1370 consumer command,
does not offer a ClientID command line arg
Posted by cl...@apache.org.
ARTEMIS-1370 consumer command, does not offer a ClientID command line arg
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/9ff5741f
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/9ff5741f
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/9ff5741f
Branch: refs/heads/master
Commit: 9ff5741f62ca4b223437c0b81dbbc277cbca1048
Parents: 9021e03
Author: Pat Fox <pa...@gmail.com>
Authored: Wed Aug 23 12:02:26 2017 +0200
Committer: Clebert Suconic <cl...@apache.org>
Committed: Wed Aug 23 11:00:04 2017 -0400
----------------------------------------------------------------------
.../artemis/cli/commands/messages/ConnectionAbstract.java | 8 ++++++++
1 file changed, 8 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/9ff5741f/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 03bc075..bf466c6 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
@@ -35,9 +35,17 @@ public class ConnectionAbstract extends InputAbstract {
@Option(name = "--password", description = "Password used to connect")
protected String password;
+ @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){
+ System.out.println("Consumer:: clientID = " + clientID);
+ cf.setClientID(clientID);
+ }
try {
Connection connection = cf.createConnection();
connection.close();