private void publishCheckpointEvent(String stepName, long jobInstanceId, long jobExecutionId, long stepExecutionId) {
        BatchEventsPublisher publisher = getBatchEventsPublisher();

        if (publisher != null) {
            String correlationId = runtimeWorkUnitExecution.getCorrelationId();
            publisher.publishCheckpointEvent(stepName, jobInstanceId, jobExecutionId, stepExecutionId, correlationId);
        }
    }
private void publishCheckpointEvent ( String stepName , long jobInstanceId , long jobExecutionId , long stepExecutionId ) { BatchEventsPublisher publisher = getBatchEventsPublisher ( ) ; if ( publisher != null ) { String correlationId = runtimeWorkUnitExecution . getCorrelationId ( ) ; publisher . publishCheckpointEvent ( stepName , jobInstanceId , jobExecutionId , stepExecutionId , correlationId ) ; } }
Helper method to publish checkpoint event

@param stepName
@param jobInstanceId
@param jobExecutionId