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