public void add(@NotNull T listener) {
    SimpleMessageBusConnection connection = myMessageBus.simpleConnect();
    connection.subscribe(myTopic, listener);
    myListenerToConnectionMap.put(listener, connection);
  }
public void add(@NotNull T listener)