Package javax.batch.operations

Examples of javax.batch.operations.JobOperator.start()

19
20
21
22
23
24
25
26
27
28
29
    @PersistenceUnit EntityManagerFactory em;
   
    public void runJob() {
        try {
            JobOperator jo = BatchRuntime.getJobOperator();
            long jobId = jo.start("eod-sales", new Properties());
            System.out.println("Started job: with id: " + jobId);
        } catch (JobStartException ex) {
            ex.printStackTrace();
        }
    }
View Full Code Here
48
49
50
51
52
53
54
55
56
57
58
   * </p>
   */
  @Test
  public void inlineConfigSampleTest() {
    JobOperator jobOperator = BatchRuntime.getJobOperator();
    Long executionId = jobOperator.start("inlineConfigSample", properties);

    BatchStatus batchStatus = waitForJobComplete(jobOperator, executionId);
    assertTrue(BatchStatus.COMPLETED.equals(batchStatus));
  }

View Full Code Here
62
63
64
65
66
67
68
69
70
71
72
   * </p>
   */
  @Test
  public void batchXmlConfigSampleTest() {
    JobOperator jobOperator = BatchRuntime.getJobOperator();
    Long executionId = jobOperator.start("batchXmlConfigSample", properties);

    BatchStatus batchStatus = waitForJobComplete(jobOperator, executionId);
    assertTrue(BatchStatus.COMPLETED.equals(batchStatus));
  }

View Full Code Here
76
77
78
79
80
81
82
83
84
85
86
   * </p>
   */
  @Test
  public void springConfigSampleTest() {
    JobOperator jobOperator = BatchRuntime.getJobOperator();
    Long executionId = jobOperator.start("springConfigSampleContext", properties);

    BatchStatus batchStatus = waitForJobComplete(jobOperator, executionId);
    assertTrue(BatchStatus.COMPLETED.equals(batchStatus));
  }

View Full Code Here
36
37
38
39
40
41
42
43
44
45
46
        JobOperator jobOperator = BatchRuntime.getJobOperator();
        long jobExecutionId;
        long timeout = Long.getLong(JobExecutionImpl.JOB_EXECUTION_TIMEOUT_SECONDS_KEY, JobExecutionImpl.JOB_EXECUTION_TIMEOUT_SECONDS_DEFAULT);
        try {
            jobExecutionId = jobOperator.start(jobXml, null);
            JobExecutionImpl jobExecution = (JobExecutionImpl) jobOperator.getJobExecution(jobExecutionId);
            jobExecution.awaitTerminatioin(timeout, TimeUnit.SECONDS);

            if (!jobExecution.getBatchStatus().equals(BatchStatus.COMPLETED)) {
                throw new BatchRuntimeException(String.format("The job did not complete: %s%n", jobXml));
View Full Code Here
46
47
48
49
50
51
52
53
54
55
56
        }

        final JobOperator jobOperator = BatchRuntime.getJobOperator();
        final long jobExecutionId;
        try {
            jobExecutionId = jobOperator.start(jobXml, jobParameters);
            final JobExecutionImpl jobExecution = (JobExecutionImpl) jobOperator.getJobExecution(jobExecutionId);
            jobExecution.awaitTermination(0, TimeUnit.SECONDS);  //no timeout

            if (!jobExecution.getBatchStatus().equals(BatchStatus.COMPLETED)) {
                throw new BatchRuntimeException(String.format("The job did not complete: %s%n", jobXml));
View Full Code Here
83
84
85
86
87
88
89
90
91
92
93
            out.println("<h1>Servlet TestServlet at " + request.getContextPath() + "</h1>");
            out.println("About to start the job<br>");
            JobOperator jo = BatchRuntime.getJobOperator();
            out.println("Got the job operator: " + jo + "<br>");
            try {
                jo.start("myJob", new Properties());
            } catch (JobSecurityException ex) {
                Logger.getLogger(TestServlet.class.getName()).log(Level.SEVERE, null, ex);
            }
            out.println("Job submitted<br>");
            out.println("<br><br>Check server.log for output, also look at \"myJob.xml\" for Job XML.");
View Full Code Here
83
84
85
86
87
88
89
90
91
92
93
            out.println("<title>Servlet TestServlet</title>");
            out.println("</head>");
            out.println("<body>");
            out.println("<h1>Running the job</h1>");
            JobOperator jo = BatchRuntime.getJobOperator();
            long jid = jo.start("myJob", new Properties());
            out.println("Job submitted: " + jid + "<br>");
            out.println("<br><br>Check server.log for output, also look at \"myJob.xml\" for Job XML.");
            out.println("</body>");
            out.println("</html>");
        } catch (JobStartException | JobSecurityException ex) {
View Full Code Here
81
82
83
84
85
86
87
88
89
90
91
            out.println("<body>");
            out.println("<h1>Batch Flow</h1>");
            out.println("About to start the job<br>");
            JobOperator jo = BatchRuntime.getJobOperator();
            out.println("Got the job operator: " + jo + "<br>");
            long jid = jo.start("myJob", new Properties());
            out.println("Job submitted: " + jid + "<br>");
            out.println(jo.getJobInstanceCount("myJob") + " job instance found<br/>");
            out.println("<br><br>Check server.log for output");
            out.println("</body>");
            out.println("</html>");
View Full Code Here
80
81
82
83
84
85
86
87
88
89
90
            out.println("<body>");
            out.println("<h1>Starting a Batchlet</h1>");
            out.println("About to start the job<br>");
            JobOperator jo = BatchRuntime.getJobOperator();
            out.println("Got the job operator: " + jo + "<br>");
            jo.start("myJob", new Properties());
            out.println("Job submitted<br>");
            out.println("<br><br>Check server.log for output, also look at \"myJob.xml\" for Job XML.");
            out.println("</body>");
            out.println("</html>");
        } catch (JobStartException ex) {
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.