Examples of toJobParameters()

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

109
110
111
112
113
114
115
116
117
118
119
    builder.addString("dontclash", "12");
    Map<String, Object> map = new HashMap<String, Object>();
    map.put(MessageHeaders.REPLY_CHANNEL, "response");
    MessageHeaders headers = new MessageHeaders(map);
    GenericMessage<JobLaunchRequest> trigger = new GenericMessage<JobLaunchRequest>(new JobLaunchRequest(job,
        builder.toJobParameters()), headers);
    requestChannel.send(trigger);
    Message<JobExecution> executionMessage = (Message<JobExecution>) responseChannel.receive(1000);

    assertNotNull("No response received", executionMessage);
    JobExecution execution = executionMessage.getPayload();
View Full Code Here

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

151
152
153
154
155
156
157
158
159
160
161
    builder.addString("dontclash", "12");
    Map<String, Object> map = new HashMap<String, Object>();
    map.put(MessageHeaders.REPLY_CHANNEL, "response");
    MessageHeaders headers = new MessageHeaders(map);
    GenericMessage<JobLaunchRequest> trigger = new GenericMessage<JobLaunchRequest>(new JobLaunchRequest(testJob,
        builder.toJobParameters()), headers);
    requestChannel.send(trigger);

    Message<JobExecution> executionMessage = (Message<JobExecution>) responseChannel.receive(1000);

    assertNotNull("No response received", executionMessage);
View Full Code Here

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

114
115
116
117
118
119
120
121
122
123
124
      this.jdbcTemplate.update("insert into FOO values (?,?,?)", 1, "one", 1);
      this.jdbcTemplate.update("insert into FOO values (?,?,?)", 2, "two", 2);
      this.jdbcTemplate.update("insert into FOO values (?,?,?)", 3, "three", 3);

      JobParametersBuilder builder = new JobParametersBuilder().addLong("min.id", 1L).addLong("max.id", 2L);
      JobExecution jobExecution = this.jobLauncher.run(this.job, builder.toJobParameters());
      assertEquals(BatchStatus.COMPLETED, jobExecution.getStatus());

      List<Foo> foos = fooStoringItemWriter.getFoos();
      assertEquals(2, foos.size());
      System.err.println(foos.get(0));
View Full Code Here

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

66
67
68
69
70
71
72
73
74
75
76
    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()

126
127
128
129
130
131
132
133
134
135
136
        else if (jobParameters.containsKey(key)) {
          builder.addString(key, jobParameters.get(key).getValue().toString());
        }
      }
    }
    return builder.toJobParameters();
  }

  /**
   * setter to support switching off all parent parameters
   * @param useAllParentParameters
View Full Code Here

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

69
70
71
72
73
74
75
76
77
78
79
    if (start) {

      Calendar c = Calendar.getInstance();
      JobParametersBuilder builder = new JobParametersBuilder();
      builder.addDate("TIMESTAMP", c.getTime());
      JobParameters jobParameters = builder.toJobParameters();

      return jobLauncher.run(job, jobParameters);

    } else {
View Full Code Here

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

34
35
36
37
38
39
40
41
42
43
44
          builder.addString(curParameter.getKey().toString(), curParameter.getValue().toString(), false);
        }
      }
    }

    return builder.toJobParameters();
  }

  /* (non-Javadoc)
   * @see org.springframework.batch.core.converter.JobParametersConverter#getProperties(org.springframework.batch.core.JobParameters)
   */
 
View Full Code Here

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

64
65
66
67
68
69
70
71
72
73
74
      } else {
        propertiesBuilder.addString(entry.getKey().toString(), entry.getValue().toString());
      }
    }

    return propertiesBuilder.toJobParameters();
  }

  /**
   * Convert schedule date to Date, and assume all other parameters can be represented by their default string value.
   *
 
View Full Code Here

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

118
119
120
121
122
123
124
125
126
127
128
        builder.addDate(key, (Date) value);
      } else {
        logger.debug("JobDataMap contains values which are not job parameters (ignoring).");
      }
    }
    return builder.toJobParameters();
  }

  /**
   * Public setter for the {@link JobLocator}.
   *
 
View Full Code Here

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

101
102
103
104
105
106
107
108
109
110
111
    if(!runIdFound) {
      builder.addLong(JOB_RUN_ID, incremeter.nextLongValue());
    }

    return builder.toJobParameters();
  }

  /* (non-Javadoc)
   * @see org.springframework.batch.core.converter.JobParametersConverter#getProperties(org.springframework.batch.core.JobParameters)
   */
 
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.