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);
}