Examples of toJobParameters()

Examples of org.springframework.batch.core.JobParametersBuilder.toJobParameters()

54
55
56
57
58
59
60
61
62
63
64
        job.setRestartable(true);

        JobParametersBuilder builder = new JobParametersBuilder();
        builder.addString("stringKey", "stringValue").addLong("longKey", 1L).addDouble("doubleKey", 1.1).addDate(
                "dateKey", new Date(1L));
        JobParameters jobParams = builder.toJobParameters();

        JobExecution firstExecution = jobRepository.createJobExecution(job.getName(), jobParams);
        firstExecution.setStartTime(new Date());
        assertNotNull(firstExecution.getLastUpdated());
View Full Code Here

Examples of org.springframework.batch.core.JobParametersBuilder.toJobParameters()

64
65
66
67
68
69
70
71
72
            } else {
                // if the value is null we just put String with null value here to avoid the NPE
                parametersBuilder.addString(headerKey, null);
            }
        }
        return parametersBuilder.toJobParameters();
    }

}
View Full Code Here

Examples of org.springframework.batch.core.JobParametersBuilder.toJobParameters()

24
25
26
27
28
29
30
31
32
33
34
  @Transformer
  public Message<JobLaunchRequest> transform(Message<String> pidMessage) {
    JobParametersBuilder jobParametersBuilder = new JobParametersBuilder();
    jobParametersBuilder.addString(JOB_PARAM_PID_KEY,
        pidMessage.getPayload());
    JobParameters jobParameters = jobParametersBuilder.toJobParameters();

    Job job = null;
    try {
      job = jobLocator.getJob("generateDerivatives");
    } catch (NoSuchJobException e) {
View Full Code Here

Examples of org.springframework.batch.core.JobParametersBuilder.toJobParameters()

34
35
36
37
38
39
40
41
42
43
44
    Job derivativeGenerationJob = jobLocator.getJob("generateDerivatives");

    for (String pid : pids) {
      JobParametersBuilder jobParametersBuilder = new JobParametersBuilder();
      jobParametersBuilder.addString(JOB_PARAM_PID_KEY, pid);
      JobParameters jobParameters = jobParametersBuilder
          .toJobParameters();
      jobLauncher.run(derivativeGenerationJob, jobParameters);
    }
  }
View Full Code Here

Examples of org.springframework.batch.core.JobParametersBuilder.toJobParameters()

56
57
58
59
60
61
62
63
64
65
66
    }

    JobParametersBuilder jobParametersBuilder = new JobParametersBuilder();
    jobParametersBuilder.addString("GUID", guid);
    jobParametersBuilder.addString("URI", uri);
    JobParameters jobParameters = jobParametersBuilder.toJobParameters();
   
    Job job = null;
    try {
      job = jobLocator.getJob("batchIngestJob");
    } catch (NoSuchJobException e) {
View Full Code Here

Examples of org.springframework.batch.core.JobParametersBuilder.toJobParameters()

29
30
31
32
33
34
35
36
37
38
39
    JobParametersBuilder jobParametersBuilder = new JobParametersBuilder();
    jobParametersBuilder.addString(Sip.JOB_PARAM_GUID_KEY, sipMessage
        .getPayload().getGuid());
    jobParametersBuilder.addString(Sip.JOB_PARAM_URI_KEY, sipMessage
        .getPayload().getURI().toString());
    JobParameters jobParameters = jobParametersBuilder.toJobParameters();
   
    logger.info("Transforming job launch request {} / {}",
        sipMessage.getPayload().getGuid(),
        sipMessage.getPayload().getURI().toString()
        );
View Full Code Here

Examples of org.springframework.batch.core.JobParametersBuilder.toJobParameters()

59
60
61
62
63
64
65
66
67
68
69
    }

    JobParametersBuilder jobParametersBuilder = new JobParametersBuilder();
    jobParametersBuilder.addString("GUID", guid);
    jobParametersBuilder.addString("URI", uri);
    JobParameters jobParameters = jobParametersBuilder.toJobParameters();
   
    Job job = null;
    try {
      job = jobLocator.getJob("batchIngestJob");
    } catch (NoSuchJobException e) {
View Full Code Here

Examples of org.springframework.batch.core.JobParametersBuilder.toJobParameters()

104
105
106
107
108
109
110
111
112
      } else {
        log.debug("JobDataMap contains values which are not job parameters (ignoring).");
      }
    }

    return builder.toJobParameters();
  }

}
View Full Code Here

Examples of org.springframework.batch.core.JobParametersBuilder.toJobParameters()

69
70
71
72
73
74
75
76
77
78
79
                        logger.debug("Trigger a new job for a new email, type: " + addressGeolocMessageJms.getGeolocType());
                    }

                    JobParametersBuilder jobParametersBuilder = new JobParametersBuilder();
                    jobParametersBuilder.addDate("date", new Date());
                    JobParameters params = jobParametersBuilder.toJobParameters();
                    jobLauncher.run(gelocJob, params);
                }
            }
           
        } catch (JMSException e) {
View Full Code Here

Examples of org.springframework.batch.core.JobParametersBuilder.toJobParameters()

70
71
72
73
74
75
76
77
78
79
80
                        logger.debug("Trigger a new job for a new email, type: " + emailnotificationMessageJms.getEmailType());
                    }

                    JobParametersBuilder jobParametersBuilder = new JobParametersBuilder();
                    jobParametersBuilder.addDate("date", new Date());
                    JobParameters params = jobParametersBuilder.toJobParameters();
                    jobLauncher.run(emailSyncJob, params);
                }
            }
           
        } catch (JMSException e) {
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.