private void validateNotDestroyed ( ) throws PipelineRuntimeException { if ( destroyed . get ( ) ) { throw new PipelineRuntimeException ( ContainerError . CONTAINER_0803 , queue . size ( ) , runtimeStats . getTotalRunners ( ) ) ; } }
Throw an exception if the runner was already destroyed .