Repository: camel Updated Branches: refs/heads/master b0c7e793d -> 72ed9cfe5
CAMEL-9603: Polished Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/e64aee42 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/e64aee42 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/e64aee42 Branch: refs/heads/master Commit: e64aee428b0801bc2d0ae1058ec5b6259d39e8b4 Parents: b0c7e79 Author: Claus Ibsen <davscl...@apache.org> Authored: Mon Feb 15 09:49:09 2016 +0100 Committer: Claus Ibsen <davscl...@apache.org> Committed: Mon Feb 15 09:49:09 2016 +0100 ---------------------------------------------------------------------- .../apache/camel/component/aws/kinesis/KinesisEndpoint.java | 8 ++------ 1 file changed, 2 insertions(+), 6 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/e64aee42/components/camel-aws/src/main/java/org/apache/camel/component/aws/kinesis/KinesisEndpoint.java ---------------------------------------------------------------------- diff --git a/components/camel-aws/src/main/java/org/apache/camel/component/aws/kinesis/KinesisEndpoint.java b/components/camel-aws/src/main/java/org/apache/camel/component/aws/kinesis/KinesisEndpoint.java index 871c992..4e79926 100644 --- a/components/camel-aws/src/main/java/org/apache/camel/component/aws/kinesis/KinesisEndpoint.java +++ b/components/camel-aws/src/main/java/org/apache/camel/component/aws/kinesis/KinesisEndpoint.java @@ -35,18 +35,14 @@ import org.apache.camel.spi.UriPath; @UriEndpoint(scheme = "aws-kinesis", title = "AWS Kinesis", syntax = "aws-kinesis:streamName", consumerClass = KinesisConsumer.class, label = "cloud,messaging") public class KinesisEndpoint extends ScheduledPollEndpoint { - @UriPath(label = "consumer", description = "Name of the stream") + @UriPath(description = "Name of the stream") @Metadata(required = "true") private String streamName; - - // For now, always assume that we've been supplied a client in the Camel registry. - @UriParam(label = "consumer", description = "Amazon Kinesis client to use for all requests for this endpoint") + @UriParam(description = "Amazon Kinesis client to use for all requests for this endpoint") @Metadata(required = "true") private AmazonKinesis amazonKinesisClient; - @UriParam(label = "consumer", description = "Maximum number of records that will be fetched in each poll", defaultValue = "1") private int maxResultsPerRequest = 1; - @UriParam(label = "consumer", description = "Defines where in the Kinesis stream to start getting records") private ShardIteratorType iteratorType = ShardIteratorType.TRIM_HORIZON;
