Repository: camel Updated Branches: refs/heads/camel-2.15.x 95ace4f1d -> 6d05e4390
added stomp support for virtual host in Apache Apollo by adding a host option Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/aaf52c04 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/aaf52c04 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/aaf52c04 Branch: refs/heads/camel-2.15.x Commit: aaf52c0410aedae7b6cfda33d000d60b93bb9d76 Parents: 95ace4f Author: David Vilaverde <[email protected]> Authored: Wed May 27 19:15:55 2015 -0400 Committer: Claus Ibsen <[email protected]> Committed: Thu May 28 14:14:29 2015 +0200 ---------------------------------------------------------------------- .../org/apache/camel/component/stomp/StompConfiguration.java | 6 ++++++ .../java/org/apache/camel/component/stomp/StompEndpoint.java | 3 +++ 2 files changed, 9 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/aaf52c04/components/camel-stomp/src/main/java/org/apache/camel/component/stomp/StompConfiguration.java ---------------------------------------------------------------------- diff --git a/components/camel-stomp/src/main/java/org/apache/camel/component/stomp/StompConfiguration.java b/components/camel-stomp/src/main/java/org/apache/camel/component/stomp/StompConfiguration.java index 00b7fc8..e76cec7 100644 --- a/components/camel-stomp/src/main/java/org/apache/camel/component/stomp/StompConfiguration.java +++ b/components/camel-stomp/src/main/java/org/apache/camel/component/stomp/StompConfiguration.java @@ -29,6 +29,8 @@ public class StompConfiguration implements Cloneable { private String login; @UriParam private String passcode; + @UriParam + private String host; /** * Returns a copy of this configuration @@ -45,6 +47,10 @@ public class StompConfiguration implements Cloneable { public String getBrokerURL() { return brokerURL; } + + public String getHost() { + return host; + } public void setBrokerURL(String brokerURL) { this.brokerURL = brokerURL; http://git-wip-us.apache.org/repos/asf/camel/blob/aaf52c04/components/camel-stomp/src/main/java/org/apache/camel/component/stomp/StompEndpoint.java ---------------------------------------------------------------------- diff --git a/components/camel-stomp/src/main/java/org/apache/camel/component/stomp/StompEndpoint.java b/components/camel-stomp/src/main/java/org/apache/camel/component/stomp/StompEndpoint.java index 17600e4..2b4d8f3 100644 --- a/components/camel-stomp/src/main/java/org/apache/camel/component/stomp/StompEndpoint.java +++ b/components/camel-stomp/src/main/java/org/apache/camel/component/stomp/StompEndpoint.java @@ -83,6 +83,9 @@ public class StompEndpoint extends DefaultEndpoint { stomp.setLogin(configuration.getLogin()); stomp.setPasscode(configuration.getPasscode()); stomp.connectCallback(promise); + if (configuration.getHost() != null && !configuration.getHost().isEmpty()){ + stomp.setHost(configuration.getHost()); + } connection = promise.await();
