code: public synchronized void checkAndWaitForSyslogSynchronized(Object sourceAttribute, String schema, MithraDatabaseObject databaseObject)
      {
          long now = System.currentTimeMillis();
          if (now > nextTimeToCheck)
          {
              this.checkAndWaitForSyslog(sourceAttribute, schema, databaseObject);
          }
      }
docs: synchronized so it does one check for all involved threads.