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 2015/04/28 08:07:43 UTC
[3/5] camel git commit: Component docs
Component docs
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/7f28a1e5
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/7f28a1e5
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/7f28a1e5
Branch: refs/heads/master
Commit: 7f28a1e5c63b664e7f656f87b9b87bd7bc5722b3
Parents: be2e819
Author: Claus Ibsen <da...@apache.org>
Authored: Tue Apr 28 07:45:54 2015 +0200
Committer: Claus Ibsen <da...@apache.org>
Committed: Tue Apr 28 07:45:54 2015 +0200
----------------------------------------------------------------------
.../integration/SpringIntegrationEndpoint.java | 24 +++++++++++++++++---
1 file changed, 21 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/7f28a1e5/components/camel-spring-integration/src/main/java/org/apache/camel/component/spring/integration/SpringIntegrationEndpoint.java
----------------------------------------------------------------------
diff --git a/components/camel-spring-integration/src/main/java/org/apache/camel/component/spring/integration/SpringIntegrationEndpoint.java b/components/camel-spring-integration/src/main/java/org/apache/camel/component/spring/integration/SpringIntegrationEndpoint.java
index d8d1239..f3f816a 100644
--- a/components/camel-spring-integration/src/main/java/org/apache/camel/component/spring/integration/SpringIntegrationEndpoint.java
+++ b/components/camel-spring-integration/src/main/java/org/apache/camel/component/spring/integration/SpringIntegrationEndpoint.java
@@ -36,13 +36,13 @@ import org.springframework.integration.MessageChannel;
@UriEndpoint(scheme = "spring-integration", title = "Spring Integration", syntax = "spring-integration:defaultChannel",
consumerClass = SpringIntegrationConsumer.class, label = "spring,eventbus")
public class SpringIntegrationEndpoint extends DefaultEndpoint {
+ private MessageChannel messageChannel;
@UriPath @Metadata(required = "true")
private String defaultChannel;
- @UriParam
+ @UriParam(label = "consumer")
private String inputChannel;
- @UriParam
+ @UriParam(label = "producer")
private String outputChannel;
- private MessageChannel messageChannel;
@UriParam
private boolean inOut;
@@ -73,6 +73,9 @@ public class SpringIntegrationEndpoint extends DefaultEndpoint {
return answer;
}
+ /**
+ * The Spring integration input channel name that this endpoint wants to consume from Spring integration.
+ */
public void setInputChannel(String input) {
inputChannel = input;
}
@@ -81,6 +84,9 @@ public class SpringIntegrationEndpoint extends DefaultEndpoint {
return inputChannel;
}
+ /**
+ * The Spring integration output channel name that is used to send messages to Spring integration.
+ */
public void setOutputChannel(String output) {
outputChannel = output;
}
@@ -89,6 +95,14 @@ public class SpringIntegrationEndpoint extends DefaultEndpoint {
return outputChannel;
}
+ /**
+ * The default channel name which is used by the Spring Integration Spring context.
+ * It will equal to the inputChannel name for the Spring Integration consumer and the outputChannel name for the Spring Integration provider.
+ */
+ public void setDefaultChannel(String defaultChannel) {
+ this.defaultChannel = defaultChannel;
+ }
+
public String getDefaultChannel() {
return defaultChannel;
}
@@ -102,6 +116,10 @@ public class SpringIntegrationEndpoint extends DefaultEndpoint {
return false;
}
+ /**
+ * The exchange pattern that the Spring integration endpoint should use.
+ * If inOut=true then a reply channel is expected, either from the Spring Integration Message header or configured on the endpoint.
+ */
public void setInOut(boolean inOut) {
this.inOut = inOut;
}