@ Override public final int compareTo ( Delayed t ) { RPC < ? > dt = ( RPC < ? > ) t ; long nextTime = _started + _retry , dtNextTime = dt . _started + dt . _retry ; return nextTime == dtNextTime ? 0 : ( nextTime > dtNextTime ? 1 : - 1 ) ; }
Needed for the DelayQueue API