Package com.azure.spring.integration.core.handler

Class DefaultMessageHandler

java.lang.Object
org.springframework.integration.context.IntegrationObjectSupport
org.springframework.integration.handler.MessageHandlerSupport
org.springframework.integration.handler.AbstractMessageHandler
org.springframework.integration.handler.AbstractMessageProducingHandler
com.azure.spring.integration.core.handler.DefaultMessageHandler
All Implemented Interfaces:
org.reactivestreams.Subscriber<org.springframework.messaging.Message<?>>, org.springframework.beans.factory.Aware, 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.IntegrationPattern, org.springframework.integration.support.context.NamedComponent, org.springframework.integration.support.management.IntegrationManagement, org.springframework.integration.support.management.TrackableComponent, org.springframework.messaging.MessageHandler, CoreSubscriber<org.springframework.messaging.Message<?>>
public class DefaultMessageHandler extends org.springframework.integration.handler.AbstractMessageProducingHandler
Base class of outbound adapter to publish to azure backed messaging service

It delegates real operation to SendOperation which supports synchronous and asynchronous sending.

  • Nested Class Summary

    Nested classes/interfaces inherited from interface org.springframework.integration.support.management.IntegrationManagement

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

  • Field Summary

    Fields inherited from class org.springframework.integration.handler.AbstractMessageProducingHandler

    messagingTemplate

    Fields inherited from class org.springframework.integration.context.IntegrationObjectSupport

    EXPRESSION_PARSER, logger

    Fields inherited from interface org.springframework.integration.support.management.IntegrationManagement

    METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME

    Fields inherited from interface org.springframework.core.Ordered

    HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE

  • Constructor Summary

    Constructors
    Constructor
    Description
    DefaultMessageHandler(String destination, SendOperation sendOperation)
    Construct a DefaultMessageHandler with the specified destination and sendOperation.

  • Method Summary

    Modifier and Type
    Method
    Description
    protected org.springframework.integration.support.ErrorMessageStrategy
    getErrorMessageStrategy()
    Get error message strategy.
    protected org.springframework.messaging.MessageChannel
    getSendFailureChannel()
    Get send failure channel.
    org.springframework.expression.Expression
    getSendTimeoutExpression()
    Get send time out expression.
    protected void
    handleMessageInternal(org.springframework.messaging.Message<?> message)
     
    protected void
    onInit()
     
    void
    setErrorMessageStrategy(org.springframework.integration.support.ErrorMessageStrategy errorMessageStrategy)
    Set error message strategy.
    void
    setPartitionIdExpression(org.springframework.expression.Expression partitionIdExpression)
    Set partition id expression.
    void
    setPartitionKey(String partitionKey)
    Set partition Key.
    void
    setPartitionKeyExpression(org.springframework.expression.Expression partitionKeyExpression)
    Set partition key expression.
    void
    setPartitionKeyExpressionString(String partitionKeyExpression)
    Set partition key expression string.
    void
    setSendCallback(org.springframework.util.concurrent.ListenableFutureCallback<Void> callback)
    Set send call back.
    void
    setSendFailureChannel(org.springframework.messaging.MessageChannel sendFailureChannel)
    Set send failure channel.
    void
    setSendFailureChannelName(String sendFailureChannelName)
    Set send failure channel name.
    void
    setSendTimeout(long sendTimeout)
     
    void
    setSendTimeoutExpression(org.springframework.expression.Expression sendTimeoutExpression)
    Set send time out expression.
    void
    setSync(boolean sync)
    Set sync.

    Methods inherited from class org.springframework.integration.handler.AbstractMessageProducingHandler

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

    Methods inherited from class org.springframework.integration.handler.AbstractMessageHandler

    handleMessage, onComplete, onError, onNext, onSubscribe

    Methods inherited from class org.springframework.integration.handler.MessageHandlerSupport

    buildSendTimer, destroy, getComponentType, getIntegrationPatternType, getManagedName, getManagedType, getMetricsCaptor, getOrder, getOverrides, isLoggingEnabled, registerMetricsCaptor, sendTimer, setLoggingEnabled, setManagedName, setManagedType, setOrder, setShouldTrack, shouldTrack

    Methods inherited from class org.springframework.integration.context.IntegrationObjectSupport

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

    Methods inherited from class java.lang.Object

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

    Methods inherited from interface reactor.core.CoreSubscriber

    currentContext

    Methods inherited from interface org.springframework.integration.support.management.IntegrationManagement

    getThisAs

    Methods inherited from interface org.springframework.integration.support.context.NamedComponent

    getBeanName, getComponentName

  • Constructor Details

    • DefaultMessageHandler

      public DefaultMessageHandler(String destination, @NonNull SendOperation sendOperation)
      Construct a DefaultMessageHandler with the specified destination and sendOperation.
      Parameters:
      destination - the destination
      sendOperation - operation for sending Messages to a destination

  • Method Details

    • onInit

      protected void onInit()
      Overrides:
      onInit in class org.springframework.integration.handler.AbstractMessageProducingHandler

    • handleMessageInternal

      protected void handleMessageInternal(org.springframework.messaging.Message<?> message)
      Specified by:
      handleMessageInternal in class org.springframework.integration.handler.AbstractMessageHandler

    • setSync

      public void setSync(boolean sync)
      Set sync.
      Parameters:
      sync - the sync

    • setSendTimeout

      public void setSendTimeout(long sendTimeout)
      Overrides:
      setSendTimeout in class org.springframework.integration.handler.AbstractMessageProducingHandler

    • setPartitionKey

      public void setPartitionKey(String partitionKey)
      Set partition Key.
      Parameters:
      partitionKey - the partition Key

    • setPartitionKeyExpression

      public void setPartitionKeyExpression(org.springframework.expression.Expression partitionKeyExpression)
      Set partition key expression.
      Parameters:
      partitionKeyExpression - the partition key expression

    • setPartitionIdExpression

      public void setPartitionIdExpression(org.springframework.expression.Expression partitionIdExpression)
      Set partition id expression.
      Parameters:
      partitionIdExpression - the partition id expression

    • setPartitionKeyExpressionString

      public void setPartitionKeyExpressionString(String partitionKeyExpression)
      Set partition key expression string.
      Parameters:
      partitionKeyExpression - the partition key expression

    • setSendCallback

      public void setSendCallback(org.springframework.util.concurrent.ListenableFutureCallback<Void> callback)
      Set send call back.
      Parameters:
      callback - the call back

    • getSendTimeoutExpression

      public org.springframework.expression.Expression getSendTimeoutExpression()
      Get send time out expression.
      Returns:
      sendTimeoutExpression the send time out expression

    • setSendTimeoutExpression

      public void setSendTimeoutExpression(org.springframework.expression.Expression sendTimeoutExpression)
      Set send time out expression.
      Parameters:
      sendTimeoutExpression - the send time out expression

    • getSendFailureChannel

      protected org.springframework.messaging.MessageChannel getSendFailureChannel()
      Get send failure channel.
      Returns:
      sendFailureChannel If sendFailureChannel or sendFailureChannelName is not null, null otherwise

    • setSendFailureChannel

      public void setSendFailureChannel(org.springframework.messaging.MessageChannel sendFailureChannel)
      Set send failure channel.
      Parameters:
      sendFailureChannel - the send failure channel

    • setSendFailureChannelName

      public void setSendFailureChannelName(String sendFailureChannelName)
      Set send failure channel name.
      Parameters:
      sendFailureChannelName - the send failure channel name

    • getErrorMessageStrategy

      protected org.springframework.integration.support.ErrorMessageStrategy getErrorMessageStrategy()
      Get error message strategy.
      Returns:
      the error message strategy

    • setErrorMessageStrategy

      public void setErrorMessageStrategy(org.springframework.integration.support.ErrorMessageStrategy errorMessageStrategy)
      Set error message strategy.
      Parameters:
      errorMessageStrategy - the error message strategy