processHeartbeatsSub = (IncrementalSubscription)bb.subscribe(processHeartbeatsPred);
  protected void setupSubscriptions() {    synchronized (lock) {      log =  (LoggingService) getServiceBroker().        getService(this, LoggingService.class, null);      bb = getBlackboardService();      sub = (IncrementalSubscription)bb.subscribe(hbReqPred);      processHeartbeats();    }  }