public final void drainerFailed ( Throwable t ) { if ( t == null ) { throw new NullPointerException ( "ConcurrentConveyor.drainerFailed(null)" ) ; } drainer = null ; drainerDepartureCause = t ; }
Called by the drainer thread to signal that it has failed and will drain no more items from the queue .