docs: @Override
      public synchronized void eventWatermarkBreached() {
          if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
              SibTr.entry(tc, "eventWatermarkBreached");
  
          // Get the current message depth
          long currentDepth = getTotalMsgCount();
  
          // If we're monitoring the depth of the queue then we need to issue a message
          // informing that we've crossed an interval (if we have actually crissed one, and
          // we haven't just been notified by MsgStore due to a high/log breach) (510343)
          if (_destMsgInterval != 0)
          {
              // If we've exceeded the next depth interval we need to issue a message
              if (currentDepth >= _nextUpDepthInterval)
              {
                  // Issue message
                  issueDepthIntervalMessage(_nextUpDepthInterval);
  
                  // Update the next depth thresholds
                  _nextDownDepthInterval = _nextUpDepthInterval - _destMsgInterval;
                  _nextUpDepthInterval = _nextUpDepthInterval + _destMsgInterval;
              }
              else if (currentDepth <= _nextDownDepthInterval)
              {
                  // Issue message
                  issueDepthIntervalMessage(_nextDownDepthInterval);
  
                  _nextUpDepthInterval = _nextDownDepthInterval + _destMsgInterval;
                  _nextDownDepthInterval = _nextDownDepthInterval - _destMsgInterval;
              }
          }
  
          // Tell anyone who's interested in this event
          notifyClients();
  
          // If we're monitoring the depth of the queue then we need set up the next
          // up/down watermarks in MsgStore (510343)
          updateWatermarks(currentDepth);
  
          if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
              SibTr.exit(tc, "eventWatermarkBreached");
      }