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/12/16 14:22:50 UTC
[5/7] camel git commit: Update defaults to more sensible defaults.
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 <ca...@candle.me.uk>
Authored: Fri Dec 11 16:25:19 2015 +0000
Committer: Claus Ibsen <da...@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);