Date timeReceived = new Date(); req.setTimeReceived(timeReceived); HbReqResponse response = (HbReqResponse)hbReq.getResponse(); req.setStatus(response.getStatus()); req.setRoundTripTime(timeReceived.getTime() - req.getTimeSent().getTime()); if (log.isDebugEnabled()) log.debug("updateHeartbeatRequest: publishChange HeartbeatRequest = " + req); bb.publishChange(req);
if (req != null) { Date timeReceived = new Date(); req.setTimeReceived(timeReceived); HbReqResponse response = (HbReqResponse)hbReq.getResponse(); req.setStatus(response.getStatus()); req.setRoundTripTime(timeReceived.getTime() - req.getTimeSent().getTime()); if (log.isDebugEnabled()) log.debug("updateHeartbeatRequest: publishChange HeartbeatRequest = " + req); bb.publishChange(req); }
  private void updateHeartbeatRequest (HbReq hbReq) {    HbReqContent content = (HbReqContent)hbReq.getContent();    UID reqUID = content.getHeartbeatRequestUID();    HeartbeatRequest req = (HeartbeatRequest)reqTable.findUniqueObject(reqUID);    Date timeReceived = new Date();    req.setTimeReceived(timeReceived);    HbReqResponse response = (HbReqResponse)hbReq.getResponse();    req.setStatus(response.getStatus());    req.setRoundTripTime(timeReceived.getTime() - req.getTimeSent().getTime());    if (log.isDebugEnabled())        log.debug("updateHeartbeatRequest: publishChange HeartbeatRequest = " + req);    bb.publishChange(req);  }