public class JobLaunchingGateway
extends org.springframework.integration.handler.AbstractReplyProducingMessageHandler
JobLaunchingGateway is used to launch Batch Jobs. Internally it
delegates to a JobLaunchingMessageHandler.messagingTemplateEXPRESSION_PARSER, logger| Constructor and Description |
|---|
JobLaunchingGateway(org.springframework.batch.core.launch.JobLauncher jobLauncher)
Constructor taking a
JobLauncher as parameter. |
| Modifier and Type | Method and Description |
|---|---|
protected java.lang.Object |
handleRequestMessage(org.springframework.messaging.Message<?> requestMessage)
Launches a Batch Job using the provided request
Message. |
doInit, doInvokeAdvisedRequestHandler, getBeanClassLoader, getRequiresReply, handleMessageInternal, hasAdviceChain, onInit, setAdviceChain, setBeanClassLoader, setRequiresReplyaddNotPropagatedHeaders, createOutputMessage, getNotPropagatedHeaders, getOutputChannel, isAsync, produceOutput, resolveErrorChannel, sendErrorMessage, sendOutput, sendOutputs, setAsync, setNotPropagatedHeaders, setOutputChannel, setOutputChannelName, setSendTimeout, shouldCopyRequestHeaders, shouldSplitOutput, updateNotPropagatedHeadersconfigureMetrics, destroy, getActiveCount, getActiveCountLong, getComponentType, getDuration, getErrorCount, getErrorCountLong, getHandleCount, getHandleCountLong, getManagedName, getManagedType, getMaxDuration, getMeanDuration, getMinDuration, getOrder, getOverrides, getStandardDeviationDuration, handleMessage, isCountsEnabled, isLoggingEnabled, isStatsEnabled, onComplete, onError, onNext, onSubscribe, registerMetricsCaptor, reset, setCountsEnabled, setLoggingEnabled, setManagedName, setManagedType, setOrder, setShouldTrack, setStatsEnabledafterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanFactory, getBeanName, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toStringclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waiterrorCount, handleCountpublic JobLaunchingGateway(org.springframework.batch.core.launch.JobLauncher jobLauncher)
JobLauncher as parameter.jobLauncher - Must not be null.protected java.lang.Object handleRequestMessage(org.springframework.messaging.Message<?> requestMessage)
Message. The payload
of the Message must be an instance of JobLaunchRequest.handleRequestMessage in class org.springframework.integration.handler.AbstractReplyProducingMessageHandlerrequestMessage - must not be null.JobExecution will always be returned. An
exception (MessageHandlingException) will only be thrown if there
is a failure to start the job. The cause of the exception will be a
JobExecutionException.org.springframework.messaging.MessageHandlingException - when a job cannot be launched