public void start()

in src/main/java/com/googlesource/gerrit/plugins/websession/broker/BrokerBasedWebSessionCache.java [229:235]


  public void start() {
    if (brokerApi == null || brokerApi.get() == null) {
      throw new IllegalStateException("Cannot find binding for BrokerApi");
    }
    brokerApi.get().receiveAsync(webSessionTopicName, this::processMessage);
    brokerApi.get().replayAllEvents(webSessionTopicName);
  }