public long getRejectTimeout ( ) { if ( TraceComponent . isAnyTracingEnabled ( ) && tc . isEntryEnabled ( ) ) SibTr . entry ( tc , "getRejectTimeout" ) ; boolean localCardinalityOne ; synchronized ( consumerPoints ) { localCardinalityOne = _cardinalityOne ; } if ( localCardinalityOne ) { if ( TraceComponent . isAnyTracingEnabled ( ) && tc . isEntryEnabled ( ) ) SibTr . exit ( tc , "getRejectTimeout" , new Long ( AbstractItem . NEVER_EXPIRES ) ) ; // there is no one else to starve return AbstractItem . NEVER_EXPIRES ; } if ( TraceComponent . isAnyTracingEnabled ( ) && tc . isEntryEnabled ( ) ) SibTr . exit ( tc , "getRejectTimeout" , new Long ( _messageProcessor . getCustomProperties ( ) . get_unlocked_reject_interval ( ) ) ) ; return _messageProcessor . getCustomProperties ( ) . get_unlocked_reject_interval ( ) ; }
The timeperiod after which a message that was added to the itemStream and is still in unlocked state should be rejected . This is important to not starve other remote MEs