@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");
    }
@ Override public synchronized void eventWatermarkBreached ( ) { if ( TraceComponent . isAnyTracingEnabled ( ) && tc . isEntryEnabled ( ) ) SibTr . entry ( tc , "eventWatermarkBreached" ) ; long currentDepth = getTotalMsgCount ( ) ; if ( _destMsgInterval != 0 ) { if ( currentDepth >= _nextUpDepthInterval ) { issueDepthIntervalMessage ( _nextUpDepthInterval ) ; _nextDownDepthInterval = _nextUpDepthInterval - _destMsgInterval ; _nextUpDepthInterval = _nextUpDepthInterval + _destMsgInterval ; } else if ( currentDepth <= _nextDownDepthInterval ) { issueDepthIntervalMessage ( _nextDownDepthInterval ) ; _nextUpDepthInterval = _nextDownDepthInterval + _destMsgInterval ; _nextDownDepthInterval = _nextDownDepthInterval - _destMsgInterval ; } } notifyClients ( ) ; updateWatermarks ( currentDepth ) ; if ( TraceComponent . isAnyTracingEnabled ( ) && tc . isEntryEnabled ( ) ) SibTr . exit ( tc , "eventWatermarkBreached" ) ; }
/*
(non-Javadoc)

@see com.ibm.ws.sib.msgstore.ItemStream#eventWatermarkBreached()