Camel jolokia commands should allow to use existing j4pclient
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/4404144a Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/4404144a Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/4404144a Branch: refs/heads/camel-2.16.x Commit: 4404144ae25d377788da055b9a015af98df889be Parents: 6640c13 Author: Claus Ibsen <davscl...@apache.org> Authored: Tue Nov 10 11:58:24 2015 +0100 Committer: Claus Ibsen <davscl...@apache.org> Committed: Tue Nov 10 11:58:45 2015 +0100 ---------------------------------------------------------------------- .../commands/jolokia/DefaultJolokiaCamelController.java | 6 ++++++ .../camel/commands/jolokia/JolokiaCamelController.java | 10 +++++++++- 2 files changed, 15 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/4404144a/platforms/commands/commands-jolokia/src/main/java/org/apache/camel/commands/jolokia/DefaultJolokiaCamelController.java ---------------------------------------------------------------------- diff --git a/platforms/commands/commands-jolokia/src/main/java/org/apache/camel/commands/jolokia/DefaultJolokiaCamelController.java b/platforms/commands/commands-jolokia/src/main/java/org/apache/camel/commands/jolokia/DefaultJolokiaCamelController.java index 21fd022..aabda83 100644 --- a/platforms/commands/commands-jolokia/src/main/java/org/apache/camel/commands/jolokia/DefaultJolokiaCamelController.java +++ b/platforms/commands/commands-jolokia/src/main/java/org/apache/camel/commands/jolokia/DefaultJolokiaCamelController.java @@ -77,6 +77,12 @@ public class DefaultJolokiaCamelController extends AbstractCamelController imple } @Override + public void using(J4pClient client) { + this.jolokia = client; + this.url = null; + } + + @Override public void connect(String url, String username, String password) throws Exception { this.jolokia = JolokiaClientFactory.createJolokiaClient(url, username, password); this.url = url; http://git-wip-us.apache.org/repos/asf/camel/blob/4404144a/platforms/commands/commands-jolokia/src/main/java/org/apache/camel/commands/jolokia/JolokiaCamelController.java ---------------------------------------------------------------------- diff --git a/platforms/commands/commands-jolokia/src/main/java/org/apache/camel/commands/jolokia/JolokiaCamelController.java b/platforms/commands/commands-jolokia/src/main/java/org/apache/camel/commands/jolokia/JolokiaCamelController.java index 7f993e1..974cbcc 100644 --- a/platforms/commands/commands-jolokia/src/main/java/org/apache/camel/commands/jolokia/JolokiaCamelController.java +++ b/platforms/commands/commands-jolokia/src/main/java/org/apache/camel/commands/jolokia/JolokiaCamelController.java @@ -17,11 +17,19 @@ package org.apache.camel.commands.jolokia; import org.apache.camel.commands.CamelController; +import org.jolokia.client.J4pClient; public interface JolokiaCamelController extends CamelController { /** - * Connects to the remote JVM using the given url to the remote jolokia agent + * To use the existing {@link org.jolokia.client.J4pClient} with this controller. + * + * @param client the client to use + */ + void using(J4pClient client); + + /** + * Connects to the remote JVM using the given url to the remote Jolokia agent * * @param url the url for the remote jolokia agent * @param username optional username
