luciano/amazon-kinesis-client
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Adding unit test case

Browse source
This commit is contained in:
Ashwin Giridharan 2020-06-07 21:17:24 -07:00
parent b5d0301b31
commit 700c7a563a
1 changed files with 12 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
amazon-kinesis-client/src/test/java/software/amazon/kinesis/retrieval/fanout/FanOutConfigTest.java
View file

@ -95,6 +95,18 @@ public class FanOutConfigTest {
verify(consumerRegistration, never()).getOrCreateStreamConsumerArn(); verify(consumerRegistration, never()).getOrCreateStreamConsumerArn();
} }
@Test
public void testRegisterCalledWhenConsumerArnNotSetInMultiStreamMode() throws Exception {
FanOutConfig config = new TestingConfig(kinesisClient).applicationName(TEST_APPLICATION_NAME)
.streamName(TEST_STREAM_NAME);
RetrievalFactory retrievalFactory = config.retrievalFactory();
ShardInfo shardInfo = mock(ShardInfo.class);
doReturn(Optional.of("account:stream:12345")).when(shardInfo).streamIdentifierSerOpt();
retrievalFactory.createGetRecordsCache(shardInfo, streamConfig, mock(MetricsFactory.class));
assertThat(retrievalFactory, not(nullValue()));
verify(consumerRegistration).getOrCreateStreamConsumerArn();
}
@Test @Test
public void testDependencyExceptionInConsumerCreation() throws Exception { public void testDependencyExceptionInConsumerCreation() throws Exception {
FanOutConfig config = new TestingConfig(kinesisClient).applicationName(TEST_APPLICATION_NAME) FanOutConfig config = new TestingConfig(kinesisClient).applicationName(TEST_APPLICATION_NAME)