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 2016/01/21 10:14:57 UTC
[4/9] camel git commit: Removed TO-DONE comment.
Removed TO-DONE comment.
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/cdceedf6
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/cdceedf6
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/cdceedf6
Branch: refs/heads/master
Commit: cdceedf69e8c7d5a9d4e8e369f42adc23ba94528
Parents: d097871
Author: Candle <ca...@candle.me.uk>
Authored: Mon Jan 18 15:55:32 2016 +0000
Committer: Claus Ibsen <da...@apache.org>
Committed: Thu Jan 21 10:10:25 2016 +0100
----------------------------------------------------------------------
.../camel/component/aws/ddbstream/DdbStreamEndpoint.java | 8 --------
1 file changed, 8 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/cdceedf6/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 b64ac9b..1b358cd 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
@@ -56,14 +56,6 @@ public class DdbStreamEndpoint extends ScheduledPollEndpoint {
+ " MUST be supplied.",
defaultValue = "LATEST")
private ShardIteratorType iteratorType = ShardIteratorType.LATEST;
- // TODO add the ability to use ShardIteratorType.{AT,AFTER}_SEQUENCE_NUMBER
- // by specifying either a sequence number itself or a bean to fetch the
- // sequence number from persistant storage or somewhere else.
- // This can be done by having the type of the parameter an interface
- // and supplying a default implementation and a converter from a long/String
- // to an instance of this interface.
- // Note that the shard list needs to have the ability to start at the shard
- // that includes the supplied sequence number
@UriParam(label = "consumer", description = "Provider for the sequence number when"
+ " using one of the two ShardIteratorType.{AT,AFTER}_SEQUENCE_NUMBER"