@Test public void testNoRegisterIfConsumerArnSet() throws Exception { FanOutConfig config = new TestingConfig(kinesisClient).consumerArn(TEST_CONSUMER_ARN); RetrievalFactory retrievalFactory = config.retrievalFactory(); assertThat(retrievalFactory, not(nullValue())); verify(consumerRegistration, never()).getOrCreateStreamConsumerArn(); }
@Override public RetrievalFactory retrievalFactory() { return new FanOutRetrievalFactory(kinesisClient, streamName, consumerArn, this::getOrCreateConsumerArn); }
FanOutConfig implements RetrievalSpecificConfig { @Override public RetrievalFactory retrievalFactory() { return new FanOutRetrievalFactory(kinesisClient, streamName, consumerArn, this::getOrCreateConsumerArn); } }
FanOutConfig implements RetrievalSpecificConfig { @Override public RetrievalFactory retrievalFactory() { return new FanOutRetrievalFactory(kinesisClient, streamName, consumerArn, this::getOrCreateConsumerArn); }  }
FanOutConfig implements RetrievalSpecificConfig { @Override public RetrievalFactory retrievalFactory() { return new FanOutRetrievalFactory(kinesisClient, streamName, consumerArn, this::getOrCreateConsumerArn); }  @Override RetrievalFactory retrievalFactory(); }
FanOutConfig implements RetrievalSpecificConfig { @Override public RetrievalFactory retrievalFactory() { return new FanOutRetrievalFactory(kinesisClient, streamName, consumerArn, this::getOrCreateConsumerArn); }  @Override RetrievalFactory retrievalFactory();  }