程序包 org.springframework.batch.integration.launch

类 JobLaunchingGateway

  • 所有已实现的接口:
    org.reactivestreams.Subscriber<org.springframework.messaging.Message<?>>, org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanClassLoaderAware, org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.BeanNameAware, org.springframework.beans.factory.DisposableBean, org.springframework.beans.factory.InitializingBean, org.springframework.context.ApplicationContextAware, org.springframework.core.Ordered, org.springframework.integration.context.ExpressionCapable, org.springframework.integration.context.Orderable, org.springframework.integration.core.MessageProducer, org.springframework.integration.handler.HeaderPropagationAware, org.springframework.integration.support.context.NamedComponent, org.springframework.integration.support.management.ConfigurableMetricsAware<org.springframework.integration.support.management.AbstractMessageHandlerMetrics>, org.springframework.integration.support.management.IntegrationManagement, org.springframework.integration.support.management.IntegrationStatsManagement, org.springframework.integration.support.management.MessageHandlerMetrics, org.springframework.integration.support.management.TrackableComponent, org.springframework.messaging.MessageHandler, reactor.core.CoreSubscriber<org.springframework.messaging.Message<?>>
    public class JobLaunchingGateway
extends org.springframework.integration.handler.AbstractReplyProducingMessageHandler
    The JobLaunchingGateway is used to launch Batch Jobs. Internally it delegates to a JobLaunchingMessageHandler.
    从以下版本开始:
    1.3
    作者:
    Gunnar Hillert

    • 嵌套类概要

      • 从类继承的嵌套类/接口 org.springframework.integration.handler.AbstractReplyProducingMessageHandler

        org.springframework.integration.handler.AbstractReplyProducingMessageHandler.RequestHandler

      • 从接口继承的嵌套类/接口 org.springframework.integration.support.management.IntegrationManagement

        org.springframework.integration.support.management.IntegrationManagement.ManagementOverrides

    • 字段概要

      • 从类继承的字段 org.springframework.integration.handler.AbstractMessageProducingHandler

        messagingTemplate

      • 从类继承的字段 org.springframework.integration.context.IntegrationObjectSupport

        EXPRESSION_PARSER, logger

      • 从接口继承的字段 org.springframework.integration.support.management.IntegrationManagement

        METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME

      • 从接口继承的字段 org.springframework.core.Ordered

        HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE

    • 方法概要

      所有方法 实例方法 具体方法 
      修饰符和类型方法说明
      protected java.lang.ObjecthandleRequestMessage​(org.springframework.messaging.Message<?> requestMessage)
      Launches a Batch Job using the provided request Message.

      • 从类继承的方法 org.springframework.integration.handler.AbstractReplyProducingMessageHandler

        doInit, doInvokeAdvisedRequestHandler, getRequiresReply, handleMessageInternal, hasAdviceChain, onInit, setAdviceChain, setBeanClassLoader, setRequiresReply

      • 从类继承的方法 org.springframework.integration.handler.AbstractMessageProducingHandler

        addNotPropagatedHeaders, createOutputMessage, getNotPropagatedHeaders, getOutputChannel, isAsync, produceOutput, resolveErrorChannel, sendErrorMessage, sendOutput, sendOutputs, setAsync, setNotPropagatedHeaders, setOutputChannel, setOutputChannelName, setSendTimeout, shouldCopyRequestHeaders, shouldSplitOutput, updateNotPropagatedHeaders

      • 从类继承的方法 org.springframework.integration.handler.AbstractMessageHandler

        configureMetrics, destroy, getActiveCount, getActiveCountLong, getComponentType, getDuration, getErrorCount, getErrorCountLong, getHandleCount, getHandleCountLong, getManagedName, getManagedType, getMaxDuration, getMeanDuration, getMetricsCaptor, getMinDuration, getOrder, getOverrides, getStandardDeviationDuration, handleMessage, isCountsEnabled, isLoggingEnabled, isStatsEnabled, onComplete, onError, onNext, onSubscribe, registerMetricsCaptor, reset, setCountsEnabled, setLoggingEnabled, setManagedName, setManagedType, setOrder, setShouldTrack, setStatsEnabled

      • 从类继承的方法 org.springframework.integration.context.IntegrationObjectSupport

        afterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanFactory, getBeanName, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toString

      • 从类继承的方法 java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

      • 从接口继承的方法 reactor.core.CoreSubscriber

        currentContext

      • 从接口继承的方法 org.springframework.integration.support.context.NamedComponent

        getBeanName, getComponentName

    • 方法详细资料

      • handleRequestMessage

        protected java.lang.Object handleRequestMessage​(org.springframework.messaging.Message<?> requestMessage)
        Launches a Batch Job using the provided request Message. The payload of the Messagemust be an instance of JobLaunchRequest.
        指定者:
        handleRequestMessage 在类中 org.springframework.integration.handler.AbstractReplyProducingMessageHandler
        参数:
        requestMessage - must not be null.
        返回:
        Generally a 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