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/cc119b46 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/cc119b46 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/cc119b46 Branch: refs/heads/master Commit: cc119b46b11cdb6f9c8ba329a40c3e5ee493ee29 Parents: be25326 Author: Claus Ibsen <davscl...@apache.org> Authored: Sun Jan 4 11:18:05 2015 +0100 Committer: Claus Ibsen <davscl...@apache.org> Committed: Sun Jan 4 11:18:05 2015 +0100 ---------------------------------------------------------------------- .../camel/component/redis/RedisComponent.java | 8 ++++++-- .../camel/component/redis/RedisConfiguration.java | 18 ++++++++++++++++-- .../camel/component/redis/RedisEndpoint.java | 5 +++++ 3 files changed, 27 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/cc119b46/components/camel-spring-redis/src/main/java/org/apache/camel/component/redis/RedisComponent.java ---------------------------------------------------------------------- diff --git a/components/camel-spring-redis/src/main/java/org/apache/camel/component/redis/RedisComponent.java b/components/camel-spring-redis/src/main/java/org/apache/camel/component/redis/RedisComponent.java index e250117..568dda3 100755 --- a/components/camel-spring-redis/src/main/java/org/apache/camel/component/redis/RedisComponent.java +++ b/components/camel-spring-redis/src/main/java/org/apache/camel/component/redis/RedisComponent.java @@ -19,12 +19,16 @@ package org.apache.camel.component.redis; import java.util.Map; import org.apache.camel.Endpoint; -import org.apache.camel.impl.DefaultComponent; +import org.apache.camel.impl.UriEndpointComponent; /** * Represents the component that manages {@link RedisEndpoint}. */ -public class RedisComponent extends DefaultComponent { +public class RedisComponent extends UriEndpointComponent { + + public RedisComponent() { + super(RedisEndpoint.class); + } protected Endpoint createEndpoint(String uri, String remaining, Map<String, Object> parameters) throws Exception { http://git-wip-us.apache.org/repos/asf/camel/blob/cc119b46/components/camel-spring-redis/src/main/java/org/apache/camel/component/redis/RedisConfiguration.java ---------------------------------------------------------------------- diff --git a/components/camel-spring-redis/src/main/java/org/apache/camel/component/redis/RedisConfiguration.java b/components/camel-spring-redis/src/main/java/org/apache/camel/component/redis/RedisConfiguration.java index 7068404..4576a82 100755 --- a/components/camel-spring-redis/src/main/java/org/apache/camel/component/redis/RedisConfiguration.java +++ b/components/camel-spring-redis/src/main/java/org/apache/camel/component/redis/RedisConfiguration.java @@ -16,6 +16,9 @@ */ package org.apache.camel.component.redis; +import org.apache.camel.spi.UriParam; +import org.apache.camel.spi.UriParams; +import org.apache.camel.spi.UriPath; import org.springframework.data.redis.connection.RedisConnectionFactory; import org.springframework.data.redis.connection.jedis.JedisConnectionFactory; import org.springframework.data.redis.core.RedisTemplate; @@ -23,16 +26,27 @@ import org.springframework.data.redis.listener.RedisMessageListenerContainer; import org.springframework.data.redis.serializer.JdkSerializationRedisSerializer; import org.springframework.data.redis.serializer.RedisSerializer; +@UriParams public class RedisConfiguration { - private String command; - private String channels; + @UriPath private String host; + @UriPath private Integer port; + @UriParam + private String command; + @UriParam + private String channels; + @UriParam private RedisTemplate redisTemplate; + @UriParam private RedisMessageListenerContainer listenerContainer; + @UriParam private RedisConnectionFactory connectionFactory; + @UriParam private RedisSerializer serializer; + @UriParam(defaultValue = "false") private boolean managedListenerContainer; + @UriParam(defaultValue = "false") private boolean managedConnectionFactory; public String getCommand() { http://git-wip-us.apache.org/repos/asf/camel/blob/cc119b46/components/camel-spring-redis/src/main/java/org/apache/camel/component/redis/RedisEndpoint.java ---------------------------------------------------------------------- diff --git a/components/camel-spring-redis/src/main/java/org/apache/camel/component/redis/RedisEndpoint.java b/components/camel-spring-redis/src/main/java/org/apache/camel/component/redis/RedisEndpoint.java index 0452e1e..67ed9ec 100755 --- a/components/camel-spring-redis/src/main/java/org/apache/camel/component/redis/RedisEndpoint.java +++ b/components/camel-spring-redis/src/main/java/org/apache/camel/component/redis/RedisEndpoint.java @@ -20,11 +20,16 @@ import org.apache.camel.Consumer; import org.apache.camel.Processor; import org.apache.camel.Producer; import org.apache.camel.component.direct.DirectEndpoint; +import org.apache.camel.spi.UriEndpoint; +import org.apache.camel.spi.UriParam; /** * Represents a Redis endpoint. */ +@UriEndpoint(scheme = "spring-redis", consumerClass = RedisConsumer.class, label = "spring,nosql") public class RedisEndpoint extends DirectEndpoint { + + @UriParam private RedisConfiguration configuration; public RedisEndpoint(String uri, RedisComponent component, RedisConfiguration configuration) {
