Class SqsMessageHandler
java.lang.Object
org.springframework.integration.context.IntegrationObjectSupport
org.springframework.integration.handler.MessageHandlerSupport
org.springframework.integration.handler.AbstractMessageHandler
org.springframework.integration.handler.AbstractMessageProducingHandler
org.springframework.integration.aws.outbound.AbstractAwsMessageHandler<Map<String,MessageAttributeValue>>
org.springframework.integration.aws.outbound.SqsMessageHandler
- 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,reactor.core.CoreSubscriber<org.springframework.messaging.Message<?>>
The
AbstractMessageHandler implementation for the Amazon SQS
sendMessage.- Author:
- Artem Bilan, Rahul Pilani, Taylor Wicksell, Seth Kelly
- See Also:
-
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.aws.outbound.AbstractAwsMessageHandler
DEFAULT_SEND_TIMEOUTFields inherited from class org.springframework.integration.handler.AbstractMessageProducingHandler
messagingTemplateFields inherited from class org.springframework.integration.context.IntegrationObjectSupport
EXPRESSION_PARSER, loggerFields inherited from interface org.springframework.integration.support.management.IntegrationManagement
METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAMEFields inherited from interface org.springframework.core.Ordered
HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE -
Constructor Summary
ConstructorsConstructorDescriptionSqsMessageHandler(AmazonSQSAsync amazonSqs) SqsMessageHandler(AmazonSQSAsync amazonSqs, io.awspring.cloud.core.env.ResourceIdResolver resourceIdResolver) SqsMessageHandler(AmazonSQSAsync amazonSqs, org.springframework.messaging.core.DestinationResolver<?> destinationResolver) -
Method Summary
Modifier and TypeMethodDescriptionprotected voidadditionalOnSuccessHeaders(org.springframework.integration.support.AbstractIntegrationMessageBuilder<?> messageBuilder, AmazonWebServiceRequest request, Object result) protected Future<?>handleMessageToAws(org.springframework.messaging.Message<?> message) protected voidonInit()voidsetDelay(int delaySeconds) voidsetDelayExpression(org.springframework.expression.Expression delayExpression) voidsetDelayExpressionString(String delayExpression) voidsetMessageConverter(org.springframework.messaging.converter.MessageConverter messageConverter) voidsetMessageDeduplicationId(String messageDeduplicationId) voidsetMessageDeduplicationIdExpression(org.springframework.expression.Expression messageDeduplicationIdExpression) voidsetMessageDeduplicationIdExpressionString(String messageDeduplicationIdExpression) voidsetMessageGroupId(String messageGroupId) voidsetMessageGroupIdExpression(org.springframework.expression.Expression messageGroupIdExpression) voidsetMessageGroupIdExpressionString(String groupIdExpression) voidvoidsetQueueExpression(org.springframework.expression.Expression queueExpression) voidsetQueueExpressionString(String queueExpression) Methods inherited from class org.springframework.integration.aws.outbound.AbstractAwsMessageHandler
doSetHeaderMapper, getAsyncHandler, getErrorMessageStrategy, getEvaluationContext, getFailureChannel, getHeaderMapper, getSendTimeoutExpression, handleMessageInternal, isSync, obtainAsyncHandler, setAsyncHandler, setErrorMessageStrategy, setFailureChannel, setFailureChannelName, setHeaderMapper, setSendTimeout, setSendTimeoutExpression, setSendTimeoutExpressionString, setSyncMethods 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, updateNotPropagatedHeadersMethods inherited from class org.springframework.integration.handler.AbstractMessageHandler
handleMessage, onComplete, onError, onNext, onSubscribeMethods 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, shouldTrackMethods 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, toStringMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitMethods inherited from interface reactor.core.CoreSubscriber
currentContextMethods inherited from interface org.springframework.integration.support.management.IntegrationManagement
getThisAsMethods inherited from interface org.springframework.integration.support.context.NamedComponent
getBeanName, getComponentName
-
Constructor Details
-
SqsMessageHandler
-
SqsMessageHandler
public SqsMessageHandler(AmazonSQSAsync amazonSqs, io.awspring.cloud.core.env.ResourceIdResolver resourceIdResolver) -
SqsMessageHandler
public SqsMessageHandler(AmazonSQSAsync amazonSqs, org.springframework.messaging.core.DestinationResolver<?> destinationResolver)
-
-
Method Details
-
setQueue
-
setQueueExpressionString
-
setQueueExpression
public void setQueueExpression(org.springframework.expression.Expression queueExpression) -
setDelay
public void setDelay(int delaySeconds) -
setDelayExpressionString
-
setDelayExpression
public void setDelayExpression(org.springframework.expression.Expression delayExpression) -
setMessageGroupId
-
setMessageGroupIdExpressionString
-
setMessageGroupIdExpression
public void setMessageGroupIdExpression(org.springframework.expression.Expression messageGroupIdExpression) -
setMessageDeduplicationId
-
setMessageDeduplicationIdExpressionString
-
setMessageDeduplicationIdExpression
public void setMessageDeduplicationIdExpression(org.springframework.expression.Expression messageDeduplicationIdExpression) -
setMessageConverter
public void setMessageConverter(org.springframework.messaging.converter.MessageConverter messageConverter) -
onInit
protected void onInit()- Overrides:
onInitin classAbstractAwsMessageHandler<Map<String,MessageAttributeValue>>
-
handleMessageToAws
- Specified by:
handleMessageToAwsin classAbstractAwsMessageHandler<Map<String,MessageAttributeValue>>
-
additionalOnSuccessHeaders
protected void additionalOnSuccessHeaders(org.springframework.integration.support.AbstractIntegrationMessageBuilder<?> messageBuilder, AmazonWebServiceRequest request, Object result) - Specified by:
additionalOnSuccessHeadersin classAbstractAwsMessageHandler<Map<String,MessageAttributeValue>>
-