public class SpringBatchEndpoint
extends org.apache.camel.impl.DefaultEndpoint
| Constructor and Description |
|---|
SpringBatchEndpoint(String endpointUri,
org.apache.camel.Component component,
org.springframework.batch.core.launch.JobLauncher jobLauncher,
org.springframework.batch.core.launch.JobLauncher defaultResolvedJobLauncher,
Map<String,org.springframework.batch.core.launch.JobLauncher> allResolvedJobLaunchers,
org.springframework.batch.core.Job job) |
| Modifier and Type | Method and Description |
|---|---|
org.apache.camel.Consumer |
createConsumer(org.apache.camel.Processor processor) |
org.apache.camel.Producer |
createProducer() |
protected void |
doStart() |
boolean |
isSingleton() |
void |
setJobLauncher(org.springframework.batch.core.launch.JobLauncher jobLauncher) |
void |
setJobLauncherRef(String jobLauncherRef) |
configureConsumer, configurePollingConsumer, configureProperties, createEndpointConfiguration, createEndpointUri, createExchange, createExchange, createExchange, createPollingConsumer, doStop, equals, getCamelContext, getComponent, getConsumerProperties, getEndpointConfiguration, getEndpointKey, getEndpointUri, getExchangePattern, getId, hashCode, isLenientProperties, isSynchronous, setCamelContext, setConsumerProperties, setEndpointConfiguration, setEndpointUri, setEndpointUriIfNotSpecified, setExchangePattern, setProperties, setSynchronous, toStringdoResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, resume, shutdown, start, stop, suspendpublic SpringBatchEndpoint(String endpointUri, org.apache.camel.Component component, org.springframework.batch.core.launch.JobLauncher jobLauncher, org.springframework.batch.core.launch.JobLauncher defaultResolvedJobLauncher, Map<String,org.springframework.batch.core.launch.JobLauncher> allResolvedJobLaunchers, org.springframework.batch.core.Job job)
public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor)
throws Exception
Exceptionpublic boolean isSingleton()
protected void doStart()
throws Exception
doStart in class org.apache.camel.impl.DefaultEndpointExceptionpublic void setJobLauncherRef(String jobLauncherRef)
public void setJobLauncher(org.springframework.batch.core.launch.JobLauncher jobLauncher)
Apache Camel