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 <davscl...@apache.org> Authored: Tue Apr 28 07:45:54 2015 +0200 Committer: Claus Ibsen <davscl...@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; }