Class TCKPollingExecutionWaiterFactory

  • All Implemented Interfaces:
    JobExecutionWaiterFactory

    public class TCKPollingExecutionWaiterFactory
    extends Object
    implements JobExecutionWaiterFactory
    Default implementation of the TCK "porting package" JobExecutionWaiterFactory SPI.

    Uses polling to repeatedly check execution results, thereby waiting for completion. Uses private inner class TCKPollingExecutionWaiter to perform this.

    • Constructor Detail

      • TCKPollingExecutionWaiterFactory

        public TCKPollingExecutionWaiterFactory()
    • Method Detail

      • createWaiter

        public JobExecutionWaiter createWaiter​(long executionId,
                                               jakarta.batch.operations.JobOperator jobOp,
                                               long timeout)
        This implementation does no pooling of any kind, it just creates a new instance with new thread each time.
        Specified by:
        createWaiter in interface JobExecutionWaiterFactory
        Parameters:
        executionId - job execution id
        jobOp - JobOperator
        timeout - In milliseconds
        Returns:
        JobExecutionWaiter