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/763b21d6 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/763b21d6 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/763b21d6 Branch: refs/heads/master Commit: 763b21d6e3c1d378d039b012319f6f28f39923f9 Parents: 143047f Author: Claus Ibsen <davscl...@apache.org> Authored: Mon Jan 5 14:11:18 2015 +0100 Committer: Claus Ibsen <davscl...@apache.org> Committed: Mon Jan 5 14:11:18 2015 +0100 ---------------------------------------------------------------------- .../camel/component/ahc/ws/WsComponent.java | 6 ------ .../apache/camel/component/ahc/ws/WsEndpoint.java | 18 ++++++++---------- 2 files changed, 8 insertions(+), 16 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/763b21d6/components/camel-ahc-ws/src/main/java/org/apache/camel/component/ahc/ws/WsComponent.java ---------------------------------------------------------------------- diff --git a/components/camel-ahc-ws/src/main/java/org/apache/camel/component/ahc/ws/WsComponent.java b/components/camel-ahc-ws/src/main/java/org/apache/camel/component/ahc/ws/WsComponent.java index eb29502..eebab4d 100644 --- a/components/camel-ahc-ws/src/main/java/org/apache/camel/component/ahc/ws/WsComponent.java +++ b/components/camel-ahc-ws/src/main/java/org/apache/camel/component/ahc/ws/WsComponent.java @@ -26,18 +26,12 @@ import org.apache.camel.component.ahc.AhcEndpoint; */ public class WsComponent extends AhcComponent { - /* (non-Javadoc) - * @see org.apache.camel.component.ahc.AhcComponent#createAddressUri(java.lang.String, java.lang.String) - */ @Override protected String createAddressUri(String uri, String remaining) { // remove "ahc-" return uri.substring(4); } - /* (non-Javadoc) - * @see org.apache.camel.component.ahc.AhcComponent#createAhcEndpoint(java.lang.String, org.apache.camel.component.ahc.AhcComponent, java.net.URI) - */ @Override protected AhcEndpoint createAhcEndpoint(String endpointUri, AhcComponent component, URI httpUri) { return new WsEndpoint(endpointUri, (WsComponent)component); http://git-wip-us.apache.org/repos/asf/camel/blob/763b21d6/components/camel-ahc-ws/src/main/java/org/apache/camel/component/ahc/ws/WsEndpoint.java ---------------------------------------------------------------------- diff --git a/components/camel-ahc-ws/src/main/java/org/apache/camel/component/ahc/ws/WsEndpoint.java b/components/camel-ahc-ws/src/main/java/org/apache/camel/component/ahc/ws/WsEndpoint.java index 589de49..79ca966 100644 --- a/components/camel-ahc-ws/src/main/java/org/apache/camel/component/ahc/ws/WsEndpoint.java +++ b/components/camel-ahc-ws/src/main/java/org/apache/camel/component/ahc/ws/WsEndpoint.java @@ -32,31 +32,32 @@ import com.ning.http.client.websocket.WebSocket; import com.ning.http.client.websocket.WebSocketByteListener; import com.ning.http.client.websocket.WebSocketTextListener; import com.ning.http.client.websocket.WebSocketUpgradeHandler; - import org.apache.camel.Consumer; import org.apache.camel.Processor; import org.apache.camel.Producer; import org.apache.camel.component.ahc.AhcEndpoint; +import org.apache.camel.spi.UriEndpoint; +import org.apache.camel.spi.UriParam; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -/** - * - */ +@UriEndpoint(scheme = "ahc-ws,ahc-wss", consumerClass = WsConsumer.class, label = "http,websocket") public class WsEndpoint extends AhcEndpoint { private static final transient Logger LOG = LoggerFactory.getLogger(WsEndpoint.class); // for using websocket streaming/fragments private static final boolean GRIZZLY_AVAILABLE = probeClass("com.ning.http.client.providers.grizzly.GrizzlyAsyncHttpProvider"); - + + private final Set<WsConsumer> consumers = new HashSet<WsConsumer>(); + + @UriParam private WebSocket websocket; - private Set<WsConsumer> consumers; + @UriParam private boolean useStreaming; public WsEndpoint(String endpointUri, WsComponent component) { super(endpointUri, component, null); - this.consumers = new HashSet<WsConsumer>(); } private static boolean probeClass(String name) { @@ -114,9 +115,6 @@ public class WsEndpoint extends AhcEndpoint { this.useStreaming = useStreaming; } - /* (non-Javadoc) - * @see org.apache.camel.component.ahc.AhcEndpoint#createClient(com.ning.http.client.AsyncHttpClientConfig) - */ @Override protected AsyncHttpClient createClient(AsyncHttpClientConfig config) { AsyncHttpClient client;
