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/04/22 07:36:05 UTC
[6/6] camel git commit: Fixed test after PR #953.
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 <da...@apache.org>
Authored: Fri Apr 22 07:35:50 2016 +0200
Committer: Claus Ibsen <da...@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