private void submitCompressJob(Map<String, String> parameters) {
        String jobName = String.format("%s_single_%s", CompressData.JOB_NAME, parameters.get(CompressData.TARGET_TIME));
        // Blocking to ensure it is actually scheduled..
        scheduler.scheduleJob(CompressData.JOB_NAME, jobName, parameters,
                new SingleExecutionTrigger.Builder().withDelay(1, TimeUnit.MINUTES).build())
                .toBlocking().value();
    }
private void submitCompressJob(Map<String, String> parameters) {
        String jobName = String.format("%s_single_%s", CompressData.JOB_NAME, parameters.get(CompressData.TARGET_TIME));
        
        scheduler.scheduleJob(CompressData.JOB_NAME, jobName, parameters,
                new SingleExecutionTrigger.Builder().withDelay(1, TimeUnit.MINUTES).build())
                .toBlocking().value();
    }
private void submitCompressJob ( Map < String , String > parameters ) { String jobName = String . format ( "%s_single_%s" , CompressData . JOB_NAME , parameters . get ( CompressData . TARGET_TIME ) ) ; // Blocking to ensure it is actually scheduled.. scheduler . scheduleJob ( CompressData . JOB_NAME , jobName , parameters , new SingleExecutionTrigger . Builder ( ) . withDelay ( 1 , TimeUnit . MINUTES ) . build ( ) ) . toBlocking ( ) . value ( ) ; }
JMX management
JMX management