57e9d4dcae
Created a Spring Boot starter that can be used to configure Spring Cloud Task and it's related functionality. Updates per code review Removed autowiring of app context Refactored DeployerPartitionHandler to correctly use environment variables Exposed deployment properties of TaskLauncher Exposed deployment properties via the TaskLaunchRequest Updated based on code review
45 lines
1.1 KiB
Plaintext
45 lines
1.1 KiB
Plaintext
= Task Events
|
|
|
|
This is a task application that emits batch job events to the following channels:
|
|
|
|
* job-execution-events
|
|
* step-execution-events
|
|
* chunk-events
|
|
* item-read-events
|
|
* item-process-events
|
|
* item-write-events
|
|
* skip-events
|
|
|
|
Note: More information on this topic is available https://docs.spring.io/spring-cloud-task/current-SNAPSHOT/reference/htmlsingle/#stream-integration-batch-events[here].
|
|
|
|
== Requirements:
|
|
|
|
* Java 7 or Above
|
|
|
|
== Build:
|
|
|
|
[source,shell,indent=2]
|
|
----
|
|
$ ./mvnw clean install
|
|
----
|
|
|
|
== Execution:
|
|
|
|
[source,shell,indent=2]
|
|
----
|
|
$ java -jar target/batch-events-1.0.1.BUILD-SNAPSHOT.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
|
|
like the log sink using the following:
|
|
|
|
[source,shell,indent=2]
|
|
----
|
|
$ java -jar <PATH_TO_LOG_SINK_JAR>/log-sink-rabbit-1.0.1.BUILD-SNAPSHOT.jar --server.port=9090
|
|
--spring.cloud.stream.bindings.input.destination=job-execution-events
|
|
----
|
|
|
|
== Dependencies:
|
|
|
|
The batch-events sample requires an instance of RabbitMQ to be running.
|