Updated Versions for this build
This commit is contained in:
@@ -74,7 +74,7 @@ public PartitionHandler partitionHandler(TaskLauncher taskLauncher,
|
||||
MavenResource.parse(String.format("%s:%s:%s",
|
||||
"io.spring.cloud",
|
||||
"partitioned-batch-job",
|
||||
"1.1.0.BUILD-SNAPSHOT"), mavenProperties);
|
||||
"1.1.0.M1"), mavenProperties);
|
||||
|
||||
DeployerPartitionHandler partitionHandler =
|
||||
new DeployerPartitionHandler(taskLauncher, jobExplorer, resource, "workerStep");
|
||||
|
||||
@@ -65,7 +65,7 @@ public class TaskLauncherSinkTests {
|
||||
private final static int WAIT_INTERVAL = 500;
|
||||
private final static int MAX_WAIT_TIME = 5000;
|
||||
private final static String URL = "maven://io.spring.cloud:"
|
||||
+ "timestamp-task:jar:1.1.0.BUILD-SNAPSHOT";
|
||||
+ "timestamp-task:jar:1.1.0.M1";
|
||||
private final static String DATASOURCE_URL;
|
||||
private final static String DATASOURCE_USER_NAME = "SA";
|
||||
private final static String DATASOURCE_USER_PASSWORD = "";
|
||||
|
||||
@@ -27,7 +27,7 @@ $ ./mvnw clean install
|
||||
|
||||
[source,shell,indent=2]
|
||||
----
|
||||
$ java -jar target/batch-events-1.1.0.BUILD-SNAPSHOT.jar --spring.cloud.stream.bindings.batch-events.contentType=application/json
|
||||
$ java -jar target/batch-events-1.1.0.M1.jar --spring.cloud.stream.bindings.batch-events.contentType=application/json
|
||||
----
|
||||
|
||||
For example you can listen for specific job execution events on a specified channel with a Spring Cloud Stream Sink
|
||||
|
||||
@@ -22,5 +22,5 @@ $ mvn clean package
|
||||
|
||||
[source,shell,indent=2]
|
||||
----
|
||||
$ java -jar target/batch-job-1.1.0.BUILD-SNAPSHOT.jar
|
||||
$ java -jar target/batch-job-1.1.0.M1.jar
|
||||
----
|
||||
|
||||
@@ -22,7 +22,7 @@ $ export spring_datasource_url=jdbc:mysql://localhost:3306/<your database>
|
||||
$ export spring_datasource_username=<your username>
|
||||
$ export spring_datasource_password=<your password>
|
||||
$ export spring_datasource_driverClassName=org.mariadb.jdbc.Driver
|
||||
$ java -jar target/partitioned-batch-job-1.1.0.BUILD-SNAPSHOT.jar
|
||||
$ java -jar target/partitioned-batch-job-1.1.0.M1.jar
|
||||
----
|
||||
|
||||
NOTE: This example will use require a MySql RDBMS repository and currently uses the mariadb jdbc driver to connect.
|
||||
|
||||
@@ -93,7 +93,7 @@ public class JobConfiguration {
|
||||
|
||||
@Bean
|
||||
public PartitionHandler partitionHandler(TaskLauncher taskLauncher, JobExplorer jobExplorer) throws Exception {
|
||||
Resource resource = resourceLoader.getResource("maven://io.spring.cloud:partitioned-batch-job:1.1.0.BUILD-SNAPSHOT");
|
||||
Resource resource = resourceLoader.getResource("maven://io.spring.cloud:partitioned-batch-job:1.1.0.M1");
|
||||
|
||||
DeployerPartitionHandler partitionHandler = new DeployerPartitionHandler(taskLauncher, jobExplorer, resource, "workerStep");
|
||||
|
||||
|
||||
@@ -17,7 +17,7 @@ $ ./mvnw clean install
|
||||
|
||||
[source,shell,indent=2]
|
||||
----
|
||||
$ java -jar target/task-events-1.1.0.BUILD-SNAPSHOT.jar --spring.cloud.stream.bindings.task-events.contentType=application/json
|
||||
$ java -jar target/task-events-1.1.0.M1.jar --spring.cloud.stream.bindings.task-events.contentType=application/json
|
||||
----
|
||||
|
||||
You can listen for the events on the task-events channel with a Spring Cloud Stream Sink
|
||||
|
||||
@@ -25,7 +25,7 @@ import org.springframework.boot.context.properties.ConfigurationProperties;
|
||||
public class TaskProcessorProperties {
|
||||
|
||||
private static final String DEFAULT_URI = "maven://org.springframework.cloud.task.app:"
|
||||
+ "timestamp-task:jar:1.0.0.BUILD-SNAPSHOT";
|
||||
+ "timestamp-task:jar:1.0.1.RELEASE";
|
||||
|
||||
|
||||
private String uri = DEFAULT_URI;
|
||||
|
||||
@@ -59,7 +59,7 @@ public class TaskProcessorApplicationTests {
|
||||
Map<String, String> properties = new HashMap();
|
||||
properties.put("payload", DEFAULT_PAYLOAD);
|
||||
TaskLaunchRequest expectedRequest = new TaskLaunchRequest("maven://org.springframework.cloud.task.app:"
|
||||
+ "timestamp-task:jar:1.0.0.BUILD-SNAPSHOT", null, properties, null);
|
||||
+ "timestamp-task:jar:1.0.1.RELEASE", null, properties, null);
|
||||
assertThat(collector.forChannel(channels.output()), receivesPayloadThat(is(expectedRequest)));
|
||||
}
|
||||
|
||||
|
||||
@@ -63,7 +63,7 @@ public class TaskSinkApplicationTests {
|
||||
Map<String, String> properties = new HashMap();
|
||||
properties.put("server.port", "0");
|
||||
TaskLaunchRequest request = new TaskLaunchRequest("maven://org.springframework.cloud.task.app:"
|
||||
+ "timestamp-task:jar:1.0.0.BUILD-SNAPSHOT", null, properties, null);
|
||||
+ "timestamp-task:jar:1.0.1.RELEASE", null, properties, null);
|
||||
GenericMessage<TaskLaunchRequest> message = new GenericMessage<TaskLaunchRequest>(request);
|
||||
this.sink.input().send(message);
|
||||
assertEquals(LaunchState.complete, testTaskLauncher.status("TESTSTATUS").getState());
|
||||
|
||||
@@ -22,5 +22,5 @@ $ mvn clean package
|
||||
|
||||
[source,shell,indent=2]
|
||||
----
|
||||
$ java -jar target/timestamp-task-1.1.0.BUILD-SNAPSHOT.jar
|
||||
$ java -jar target/timestamp-task-1.1.0.M1.jar
|
||||
----
|
||||
|
||||
@@ -50,7 +50,7 @@ public class TaskLauncherSinkTests {
|
||||
private final static String PARAM2 = "BAR";
|
||||
|
||||
private final static String VALID_URL = "maven://org.springframework.cloud.task.app:"
|
||||
+ "timestamp-task:jar:1.0.0.BUILD-SNAPSHOT";
|
||||
+ "timestamp-task:jar:1.0.1.RELEASE";
|
||||
|
||||
private final static String INVALID_URL = "maven://not.real.group:"
|
||||
+ "invalid:jar:1.0.0.BUILD-SNAPSHOT";
|
||||
|
||||
Reference in New Issue
Block a user