spelling.
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/81c5a19f Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/81c5a19f Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/81c5a19f Branch: refs/heads/master Commit: 81c5a19f218365d621bf080b99aad0c1a75f0f09 Parents: e23bf83 Author: Candle <[email protected]> Authored: Mon Jan 18 09:14:58 2016 +0000 Committer: Claus Ibsen <[email protected]> Committed: Thu Jan 21 10:10:24 2016 +0100 ---------------------------------------------------------------------- .../apache/camel/component/aws/ddbstream/DdbStreamConsumer.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/81c5a19f/components/camel-aws/src/main/java/org/apache/camel/component/aws/ddbstream/DdbStreamConsumer.java ---------------------------------------------------------------------- diff --git a/components/camel-aws/src/main/java/org/apache/camel/component/aws/ddbstream/DdbStreamConsumer.java b/components/camel-aws/src/main/java/org/apache/camel/component/aws/ddbstream/DdbStreamConsumer.java index aa8224f..aad6550 100644 --- a/components/camel-aws/src/main/java/org/apache/camel/component/aws/ddbstream/DdbStreamConsumer.java +++ b/components/camel-aws/src/main/java/org/apache/camel/component/aws/ddbstream/DdbStreamConsumer.java @@ -56,7 +56,7 @@ public class DdbStreamConsumer extends ScheduledBatchPollingConsumer { @Override protected int poll() throws Exception { GetRecordsRequest req = new GetRecordsRequest() - .withShardIterator(getShardItertor()) + .withShardIterator(getShardIterator()) .withLimit(getEndpoint().getMaxResultsPerRequest()); GetRecordsResult result = getClient().getRecords(req); @@ -95,7 +95,7 @@ public class DdbStreamConsumer extends ScheduledBatchPollingConsumer { return (DdbStreamEndpoint) super.getEndpoint(); } - private String getShardItertor() { + private String getShardIterator() { // either return a cached one or get a new one via a GetShardIterator request. if (currentShardIterator == null) { ListStreamsRequest req0 = new ListStreamsRequest()
