Update defaults to more sensible defaults.
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/fdadd159 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/fdadd159 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/fdadd159 Branch: refs/heads/master Commit: fdadd1594b26c63ca22c67044b2fb9fdadd58c5a Parents: 8f5136a Author: Candle <can...@candle.me.uk> Authored: Fri Dec 11 16:25:19 2015 +0000 Committer: Claus Ibsen <davscl...@apache.org> Committed: Wed Dec 16 14:19:12 2015 +0100 ---------------------------------------------------------------------- .../camel/component/aws/ddbstream/DdbStreamEndpoint.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/fdadd159/components/camel-aws/src/main/java/org/apache/camel/component/aws/ddbstream/DdbStreamEndpoint.java ---------------------------------------------------------------------- diff --git a/components/camel-aws/src/main/java/org/apache/camel/component/aws/ddbstream/DdbStreamEndpoint.java b/components/camel-aws/src/main/java/org/apache/camel/component/aws/ddbstream/DdbStreamEndpoint.java index 18c042d..35812ce 100644 --- a/components/camel-aws/src/main/java/org/apache/camel/component/aws/ddbstream/DdbStreamEndpoint.java +++ b/components/camel-aws/src/main/java/org/apache/camel/component/aws/ddbstream/DdbStreamEndpoint.java @@ -42,10 +42,10 @@ public class DdbStreamEndpoint extends ScheduledPollEndpoint { private AmazonDynamoDBStreams amazonDynamoDbStreamsClient; @UriParam(label = "consumer", description = "Maximum number of records that will be fetched in each poll") - private int maxResultsPerRequest = 1; + private int maxResultsPerRequest = 100; - @UriParam(label = "consumer", description = "Defines where in the DynaboDB stream to start getting records") - private ShardIteratorType iteratorType = ShardIteratorType.TRIM_HORIZON; + @UriParam(label = "consumer", description = "Defines where in the DynaboDB stream to start getting records", defaultValue = "LATEST") + private ShardIteratorType iteratorType = ShardIteratorType.LATEST; public DdbStreamEndpoint(String uri, String tableName, DdbStreamComponent component) { super(uri, component);
