You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2014/12/18 10:59:24 UTC
[6/8] camel git commit: CAMEL-7999: More components include
documentation
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/6955d5ca
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/6955d5ca
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/6955d5ca
Branch: refs/heads/master
Commit: 6955d5ca6523e7b0f34e5827bc2808021c47536e
Parents: fb7c4be
Author: Claus Ibsen <da...@apache.org>
Authored: Thu Dec 18 10:26:08 2014 +0100
Committer: Claus Ibsen <da...@apache.org>
Committed: Thu Dec 18 10:58:55 2014 +0100
----------------------------------------------------------------------
.../camel/component/stream/StreamComponent.java | 12 ++++++++---
.../camel/component/stream/StreamEndpoint.java | 21 ++++++++++++++++++--
2 files changed, 28 insertions(+), 5 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/6955d5ca/components/camel-stream/src/main/java/org/apache/camel/component/stream/StreamComponent.java
----------------------------------------------------------------------
diff --git a/components/camel-stream/src/main/java/org/apache/camel/component/stream/StreamComponent.java b/components/camel-stream/src/main/java/org/apache/camel/component/stream/StreamComponent.java
index 6ade49f..2688d5a 100644
--- a/components/camel-stream/src/main/java/org/apache/camel/component/stream/StreamComponent.java
+++ b/components/camel-stream/src/main/java/org/apache/camel/component/stream/StreamComponent.java
@@ -19,15 +19,21 @@ package org.apache.camel.component.stream;
import java.util.Map;
import org.apache.camel.Endpoint;
-import org.apache.camel.impl.DefaultComponent;
+import org.apache.camel.impl.UriEndpointComponent;
/**
* Component providing streams connectivity
*/
-public class StreamComponent extends DefaultComponent {
+public class StreamComponent extends UriEndpointComponent {
+
+ public StreamComponent() {
+ super(StreamEndpoint.class);
+ }
@Override
protected Endpoint createEndpoint(String uri, String remaining, Map<String, Object> parameters) throws Exception {
- return new StreamEndpoint(uri, this);
+ StreamEndpoint answer = new StreamEndpoint(uri, this);
+ setProperties(answer, parameters);
+ return answer;
}
}
http://git-wip-us.apache.org/repos/asf/camel/blob/6955d5ca/components/camel-stream/src/main/java/org/apache/camel/component/stream/StreamEndpoint.java
----------------------------------------------------------------------
diff --git a/components/camel-stream/src/main/java/org/apache/camel/component/stream/StreamEndpoint.java b/components/camel-stream/src/main/java/org/apache/camel/component/stream/StreamEndpoint.java
index 9fc46f3..cff9cfc 100644
--- a/components/camel-stream/src/main/java/org/apache/camel/component/stream/StreamEndpoint.java
+++ b/components/camel-stream/src/main/java/org/apache/camel/component/stream/StreamEndpoint.java
@@ -24,28 +24,45 @@ import org.apache.camel.Exchange;
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.slf4j.Logger;
import org.slf4j.LoggerFactory;
+@UriEndpoint(scheme = "stream", consumerClass = StreamConsumer.class, label = "file,system")
public class StreamEndpoint extends DefaultEndpoint {
private static final Logger LOG = LoggerFactory.getLogger(StreamEndpoint.class);
+ @UriPath
private String url;
-
+ @UriParam
private String fileName;
+ @UriParam(defaultValue = "false")
private boolean scanStream;
+ @UriParam(defaultValue = "false")
private boolean retry;
+ @UriParam(defaultValue = "false")
private boolean closeOnDone;
+ @UriParam
private long scanStreamDelay;
+ @UriParam(defaultValue = "false")
private long delay;
+ @UriParam
private String encoding;
+ @UriParam
private String promptMessage;
+ @UriParam
private long promptDelay;
+ @UriParam(defaultValue = "2000")
private long initialPromptDelay = 2000;
+ @UriParam
private int groupLines;
+ @UriParam
private int autoCloseCount;
-
+ @UriParam
private Charset charset;
+ @UriParam
private GroupStrategy groupStrategy = new DefaultGroupStrategy();
public StreamEndpoint(String endpointUri, Component component) throws Exception {