Fixed test after PR #953.
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/2bd185e9 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/2bd185e9 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/2bd185e9 Branch: refs/heads/master Commit: 2bd185e929a7242db3ad481bd05e8dcf998dca0f Parents: 5e1423f Author: Claus Ibsen <davscl...@apache.org> Authored: Fri Apr 22 07:35:50 2016 +0200 Committer: Claus Ibsen <davscl...@apache.org> Committed: Fri Apr 22 07:35:50 2016 +0200 ---------------------------------------------------------------------- .../aws/kinesis/KinesisEndpointTest.java | 19 +++++++++++++++++-- 1 file changed, 17 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/2bd185e9/components/camel-aws/src/test/java/org/apache/camel/component/aws/kinesis/KinesisEndpointTest.java ---------------------------------------------------------------------- diff --git a/components/camel-aws/src/test/java/org/apache/camel/component/aws/kinesis/KinesisEndpointTest.java b/components/camel-aws/src/test/java/org/apache/camel/component/aws/kinesis/KinesisEndpointTest.java index c6910bc..48c0058 100644 --- a/components/camel-aws/src/test/java/org/apache/camel/component/aws/kinesis/KinesisEndpointTest.java +++ b/components/camel-aws/src/test/java/org/apache/camel/component/aws/kinesis/KinesisEndpointTest.java @@ -76,20 +76,35 @@ public class KinesisEndpointTest { assertThat(endpoint.getMaxResultsPerRequest(), is(1)); } - @Test(expected = ResolveEndpointFailedException.class) + @Test public void afterSequenceNumberRequiresSequenceNumber() throws Exception { KinesisEndpoint endpoint = (KinesisEndpoint) camelContext.getEndpoint("aws-kinesis://some_stream_name" + "?amazonKinesisClient=#kinesisClient" + "&iteratorType=AFTER_SEQUENCE_NUMBER" + + "&shardId=abc" + + "&sequenceNumber=123" ); + assertThat(endpoint.getClient(), is(amazonKinesisClient)); + assertThat(endpoint.getStreamName(), is("some_stream_name")); + assertThat(endpoint.getIteratorType(), is(ShardIteratorType.AFTER_SEQUENCE_NUMBER)); + assertThat(endpoint.getShardId(), is("abc")); + assertThat(endpoint.getSequenceNumber(), is("123")); } - @Test(expected = ResolveEndpointFailedException.class) + @Test public void atSequenceNumberRequiresSequenceNumber() throws Exception { KinesisEndpoint endpoint = (KinesisEndpoint) camelContext.getEndpoint("aws-kinesis://some_stream_name" + "?amazonKinesisClient=#kinesisClient" + "&iteratorType=AT_SEQUENCE_NUMBER" + + "&shardId=abc" + + "&sequenceNumber=123" ); + + assertThat(endpoint.getClient(), is(amazonKinesisClient)); + assertThat(endpoint.getStreamName(), is("some_stream_name")); + assertThat(endpoint.getIteratorType(), is(ShardIteratorType.AT_SEQUENCE_NUMBER)); + assertThat(endpoint.getShardId(), is("abc")); + assertThat(endpoint.getSequenceNumber(), is("123")); } } \ No newline at end of file
