Repository: camel Updated Branches: refs/heads/master 0f393b668 -> 30e34e7bd
Updated Javadoc. Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/30e34e7b Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/30e34e7b Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/30e34e7b Branch: refs/heads/master Commit: 30e34e7bd5bc8c2eeaeee61239571ad14588ca1e Parents: 0f393b6 Author: Henryk Konsek <hekon...@gmail.com> Authored: Mon Oct 26 12:05:05 2015 +0100 Committer: Henryk Konsek <hekon...@gmail.com> Committed: Mon Oct 26 12:05:05 2015 +0100 ---------------------------------------------------------------------- .../java/org/apache/camel/component/paho/PahoComponent.java | 7 +++++++ 1 file changed, 7 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/30e34e7b/components/camel-paho/src/main/java/org/apache/camel/component/paho/PahoComponent.java ---------------------------------------------------------------------- diff --git a/components/camel-paho/src/main/java/org/apache/camel/component/paho/PahoComponent.java b/components/camel-paho/src/main/java/org/apache/camel/component/paho/PahoComponent.java index 3756a67..acc2d20 100644 --- a/components/camel-paho/src/main/java/org/apache/camel/component/paho/PahoComponent.java +++ b/components/camel-paho/src/main/java/org/apache/camel/component/paho/PahoComponent.java @@ -22,6 +22,9 @@ import org.apache.camel.Endpoint; import org.apache.camel.impl.UriEndpointComponent; import org.eclipse.paho.client.mqttv3.MqttConnectOptions; +/** + * Component to integrate with the Eclispe Paho MQTT library. + */ public class PahoComponent extends UriEndpointComponent { private String brokerUrl; @@ -32,6 +35,8 @@ public class PahoComponent extends UriEndpointComponent { super(PahoEndpoint.class); } + // Overridden + @Override protected Endpoint createEndpoint(String uri, String remaining, Map<String, Object> parameters) throws Exception { PahoEndpoint answer = new PahoEndpoint(uri, remaining, this); @@ -50,6 +55,8 @@ public class PahoComponent extends UriEndpointComponent { return answer; } + // Getters and setters + public String getBrokerUrl() { return brokerUrl; }
