Repository: camel Updated Branches: refs/heads/master e6aefecef -> e49c560a6
CAMEL-7999: More components include documentation Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/64b4babc Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/64b4babc Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/64b4babc Branch: refs/heads/master Commit: 64b4babca5b3d593800203020d213dcb046792c5 Parents: e6aefec Author: Claus Ibsen <davscl...@apache.org> Authored: Sun Jan 4 14:57:31 2015 +0100 Committer: Claus Ibsen <davscl...@apache.org> Committed: Sun Jan 4 14:57:31 2015 +0100 ---------------------------------------------------------------------- .../org/apache/camel/component/stomp/StompComponent.java | 7 ++++++- .../apache/camel/component/stomp/StompConfiguration.java | 6 ++++++ .../org/apache/camel/component/stomp/StompEndpoint.java | 10 ++++++++-- 3 files changed, 20 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/64b4babc/components/camel-stomp/src/main/java/org/apache/camel/component/stomp/StompComponent.java ---------------------------------------------------------------------- diff --git a/components/camel-stomp/src/main/java/org/apache/camel/component/stomp/StompComponent.java b/components/camel-stomp/src/main/java/org/apache/camel/component/stomp/StompComponent.java index a7ac94b..f8468e4 100644 --- a/components/camel-stomp/src/main/java/org/apache/camel/component/stomp/StompComponent.java +++ b/components/camel-stomp/src/main/java/org/apache/camel/component/stomp/StompComponent.java @@ -20,11 +20,16 @@ import java.util.Map; import org.apache.camel.Endpoint; import org.apache.camel.impl.DefaultComponent; +import org.apache.camel.impl.UriEndpointComponent; -public class StompComponent extends DefaultComponent { +public class StompComponent extends UriEndpointComponent { private StompConfiguration configuration = new StompConfiguration(); + public StompComponent() { + super(StompEndpoint.class); + } + @Override protected Endpoint createEndpoint(String uri, String remaining, Map<String, Object> parameters) throws Exception { String destination = "/" + remaining.replaceAll(":", "/"); http://git-wip-us.apache.org/repos/asf/camel/blob/64b4babc/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 091c2f7..00b7fc8 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 @@ -17,11 +17,17 @@ package org.apache.camel.component.stomp; import org.apache.camel.RuntimeCamelException; +import org.apache.camel.spi.UriParam; +import org.apache.camel.spi.UriParams; +@UriParams public class StompConfiguration implements Cloneable { + @UriParam(defaultValue = "tcp://localhost:61613") private String brokerURL = "tcp://localhost:61613"; + @UriParam private String login; + @UriParam private String passcode; /** http://git-wip-us.apache.org/repos/asf/camel/blob/64b4babc/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 d2fbb0e..76741df 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 @@ -25,6 +25,9 @@ import org.apache.camel.Message; import org.apache.camel.Processor; import org.apache.camel.Producer; import org.apache.camel.impl.DefaultEndpoint; +import org.apache.camel.spi.UriEndpoint; +import org.apache.camel.spi.UriParam; +import org.apache.camel.spi.UriPath; import org.fusesource.hawtbuf.AsciiBuffer; import org.fusesource.hawtdispatch.Task; import org.fusesource.stomp.client.Callback; @@ -41,11 +44,14 @@ import static org.fusesource.stomp.client.Constants.SEND; import static org.fusesource.stomp.client.Constants.SUBSCRIBE; import static org.fusesource.stomp.client.Constants.UNSUBSCRIBE; +@UriEndpoint(scheme = "stomp", consumerClass = StompConsumer.class, label = "messaging") public class StompEndpoint extends DefaultEndpoint { - private CallbackConnection connection; - private StompConfiguration configuration; + @UriPath private String destination; + @UriParam + private StompConfiguration configuration; + private CallbackConnection connection; private Stomp stomp; private final List<StompConsumer> consumers = new CopyOnWriteArrayList<StompConsumer>();
