@UriEndpoint(scheme="spring-batch",
title="Spring Batch",
syntax="spring-batch:jobName",
producerOnly=true,
label="spring,batch,scheduling")
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,
String jobName) |
Modifier and Type | Method and Description |
---|---|
org.apache.camel.Consumer |
createConsumer(org.apache.camel.Processor processor) |
org.apache.camel.Producer |
createProducer() |
protected void |
doStart() |
org.springframework.batch.core.launch.JobLauncher |
getJobLauncher() |
String |
getJobLauncherRef()
Deprecated.
|
String |
getJobName() |
boolean |
isSingleton() |
void |
setJobLauncher(org.springframework.batch.core.launch.JobLauncher jobLauncher)
Explicitly specifies a JobLauncher to be used.
|
void |
setJobLauncherRef(String jobLauncherRef)
Deprecated.
|
void |
setJobName(String jobName)
The name of the Spring Batch job located in the registry.
|
configureConsumer, configurePollingConsumer, configureProperties, createEndpointConfiguration, createEndpointUri, createExchange, createExchange, createExchange, createPollingConsumer, doStop, equals, getCamelContext, getComponent, getConsumerProperties, getEndpointConfiguration, getEndpointKey, getEndpointUri, getExceptionHandler, getExchangePattern, getId, getPollingConsumerBlockTimeout, getPollingConsumerQueueSize, hashCode, isBridgeErrorHandler, isLenientProperties, isPollingConsumerBlockWhenFull, isSynchronous, setBridgeErrorHandler, setCamelContext, setConsumerProperties, setEndpointConfiguration, setEndpointUri, setEndpointUriIfNotSpecified, setExceptionHandler, setExchangePattern, setPollingConsumerBlockTimeout, setPollingConsumerBlockWhenFull, setPollingConsumerQueueSize, setProperties, setSynchronous, toString
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
public 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, String jobName)
public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor) throws Exception
Exception
public boolean isSingleton()
protected void doStart() throws Exception
doStart
in class org.apache.camel.impl.DefaultEndpoint
Exception
public String getJobName()
public void setJobName(String jobName)
@Deprecated public String getJobLauncherRef()
@Deprecated public void setJobLauncherRef(String jobLauncherRef)
public org.springframework.batch.core.launch.JobLauncher getJobLauncher()
public void setJobLauncher(org.springframework.batch.core.launch.JobLauncher jobLauncher)
Apache Camel