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
ConstructorDescriptionDefaultMessageHandler
(String destination, SendOperation sendOperation) Construct aDefaultMessageHandler
with the specified destination and sendOperation. -
Method Summary
Modifier and TypeMethodDescriptionprotected org.springframework.integration.support.ErrorMessageStrategy
Get error message strategy.protected org.springframework.messaging.MessageChannel
Get send failure channel.org.springframework.expression.Expression
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, setupMessageProcessor, shouldCopyRequestHeaders, shouldSplitOutput, updateNotPropagatedHeaders
Methods inherited from class org.springframework.integration.handler.AbstractMessageHandler
handleMessage, onComplete, onError, onNext, onSubscribe, setObservationConvention
Methods inherited from class org.springframework.integration.handler.MessageHandlerSupport
buildSendTimer, destroy, getComponentType, getIntegrationPatternType, getManagedName, getManagedType, getMetricsCaptor, getObservationRegistry, getOrder, getOverrides, isLoggingEnabled, isObserved, registerMetricsCaptor, registerObservationRegistry, 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, 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
Construct aDefaultMessageHandler
with the specified destination and sendOperation.- Parameters:
destination
- the destinationsendOperation
- operation for sending Messages to a destination
-
-
Method Details
-
onInit
protected void onInit()- Overrides:
onInit
in classorg.springframework.integration.handler.AbstractMessageProducingHandler
-
handleMessageInternal
protected void handleMessageInternal(org.springframework.messaging.Message<?> message) - Specified by:
handleMessageInternal
in classorg.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 classorg.springframework.integration.handler.AbstractMessageProducingHandler
-
setPartitionKey
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
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
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
-