public void subscribe()

in src/main/java/com/googlesource/gerrit/plugins/kinesis/KinesisConsumer.java [55:61]

• 6 lines of code
• 1 McCabe index (conditional complexity)

  public void subscribe(String streamName, java.util.function.Consumer<Event> messageProcessor) {
    this.streamName = streamName;
    this.messageProcessor = messageProcessor;

    logger.atInfo().log("Subscribe kinesis consumer to stream [%s]", streamName);
    runReceiver(messageProcessor);
  }