private void connect()

in src/main/java/com/googlesource/gerrit/plugins/rabbitmq/message/MessagePublisher.java [187:193]


  private void connect() {
    if (!isConnected() && session.connect()) {
      synchronized (sessionMon) {
        sessionMon.notifyAll();
      }
    }
  }