Class SpringBatchProducer
- java.lang.Object
-
- org.apache.camel.support.service.BaseService
-
- org.apache.camel.support.service.ServiceSupport
-
- org.apache.camel.support.DefaultProducer
-
- org.apache.camel.component.spring.batch.SpringBatchProducer
-
- All Implemented Interfaces:
AutoCloseable
,org.apache.camel.EndpointAware
,org.apache.camel.IsSingleton
,org.apache.camel.Processor
,org.apache.camel.Producer
,org.apache.camel.Service
,org.apache.camel.ShutdownableService
,org.apache.camel.StatefulService
,org.apache.camel.SuspendableService
public class SpringBatchProducer extends org.apache.camel.support.DefaultProducer
Spring Batch Producer triggering the execution of the jobs.
-
-
Constructor Summary
Constructors Constructor Description SpringBatchProducer(SpringBatchEndpoint endpoint, org.springframework.batch.core.launch.JobLauncher jobLauncher, org.springframework.batch.core.Job job, org.springframework.batch.core.configuration.JobRegistry jobRegistry)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected org.springframework.batch.core.JobParameters
prepareJobParameters(Map<String,Object> headers)
Helper method converting the Camel message headers into the Spring Batch parameters map.void
process(org.apache.camel.Exchange exchange)
-
Methods inherited from class org.apache.camel.support.DefaultProducer
createExchange, doStart, doStop, getEndpoint, isSingleton, toString
-
Methods inherited from class org.apache.camel.support.service.BaseService
build, doBuild, doFail, doInit, doLifecycleChange, doResume, doShutdown, doSuspend, fail, getStatus, init, isBuild, isInit, isNew, isRunAllowed, isShutdown, isStarted, isStarting, isStartingOrStarted, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
-
-
-
-
Constructor Detail
-
SpringBatchProducer
public SpringBatchProducer(SpringBatchEndpoint endpoint, org.springframework.batch.core.launch.JobLauncher jobLauncher, org.springframework.batch.core.Job job, org.springframework.batch.core.configuration.JobRegistry jobRegistry)
-
-
Method Detail
-
prepareJobParameters
protected org.springframework.batch.core.JobParameters prepareJobParameters(Map<String,Object> headers)
Helper method converting the Camel message headers into the Spring Batch parameters map. Date, Long and Double header values are converted to the appropriate types. All the other header values are converted to string representation.- Parameters:
headers
- Camel message header to be converted- Returns:
- Camel message headers converted into the Spring Batch parameters map
-
-