Class KinesisMessageHandler
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<Void>
org.springframework.integration.aws.outbound.KinesisMessageHandler
- 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 Kinesis
putRecord(s).- Since:
- 1.1
- Author:
- Artem Bilan, Jacob Severson
- 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
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected voidadditionalOnSuccessHeaders(org.springframework.integration.support.AbstractIntegrationMessageBuilder<?> messageBuilder, AmazonWebServiceRequest request, Object result) protected Future<?>handleMessageToAws(org.springframework.messaging.Message<?> message) voidsetConverter(org.springframework.core.convert.converter.Converter<Object, byte[]> converter) Deprecated.voidsetEmbeddedHeadersMapper(org.springframework.integration.mapping.OutboundMessageMapper<byte[]> embeddedHeadersMapper) Specify aOutboundMessageMapperfor embedding message headers into the record data together with payload.voidsetExplicitHashKey(String explicitHashKey) voidsetExplicitHashKeyExpression(org.springframework.expression.Expression explicitHashKeyExpression) voidsetExplicitHashKeyExpressionString(String explicitHashKeyExpression) voidsetHeaderMapper(org.springframework.integration.mapping.HeaderMapper<Void> headerMapper) Unsupported operation.voidsetMessageConverter(org.springframework.messaging.converter.MessageConverter messageConverter) Configure aMessageConverterfor converting payload tobyte[]for Kinesis record.voidsetPartitionKey(String partitionKey) voidsetPartitionKeyExpression(org.springframework.expression.Expression partitionKeyExpression) voidsetPartitionKeyExpressionString(String partitionKeyExpression) voidsetSequenceNumberExpression(org.springframework.expression.Expression sequenceNumberExpression) voidsetSequenceNumberExpressionString(String sequenceNumberExpression) voidvoidsetStreamExpression(org.springframework.expression.Expression streamExpression) voidsetStreamExpressionString(String streamExpression) Methods inherited from class org.springframework.integration.aws.outbound.AbstractAwsMessageHandler
doSetHeaderMapper, getAsyncHandler, getErrorMessageStrategy, getEvaluationContext, getFailureChannel, getHeaderMapper, getSendTimeoutExpression, handleMessageInternal, isSync, obtainAsyncHandler, onInit, setAsyncHandler, setErrorMessageStrategy, setFailureChannel, setFailureChannelName, 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
-
KinesisMessageHandler
-
-
Method Details
-
setConverter
@Deprecated public void setConverter(org.springframework.core.convert.converter.Converter<Object, byte[]> converter) Deprecated.since 2.3 in favor ofsetMessageConverter(org.springframework.messaging.converter.MessageConverter)Specify aConverterto serializepayloadto thebyte[]if that isn'tbyte[]already.- Parameters:
converter- theConverterto use; cannot be null.
-
setMessageConverter
public void setMessageConverter(org.springframework.messaging.converter.MessageConverter messageConverter) Configure aMessageConverterfor converting payload tobyte[]for Kinesis record.- Parameters:
messageConverter- theMessageConverterto use.- Since:
- 2.3
-
setStream
-
setStreamExpressionString
-
setStreamExpression
public void setStreamExpression(org.springframework.expression.Expression streamExpression) -
setPartitionKey
-
setPartitionKeyExpressionString
-
setPartitionKeyExpression
public void setPartitionKeyExpression(org.springframework.expression.Expression partitionKeyExpression) -
setExplicitHashKey
-
setExplicitHashKeyExpressionString
-
setExplicitHashKeyExpression
public void setExplicitHashKeyExpression(org.springframework.expression.Expression explicitHashKeyExpression) -
setSequenceNumberExpressionString
-
setSequenceNumberExpression
public void setSequenceNumberExpression(org.springframework.expression.Expression sequenceNumberExpression) -
setEmbeddedHeadersMapper
public void setEmbeddedHeadersMapper(org.springframework.integration.mapping.OutboundMessageMapper<byte[]> embeddedHeadersMapper) Specify aOutboundMessageMapperfor embedding message headers into the record data together with payload.- Parameters:
embeddedHeadersMapper- theOutboundMessageMapperto embed headers into the record data.- Since:
- 2.0
- See Also:
-
EmbeddedJsonHeadersMessageMapper
-
setHeaderMapper
public void setHeaderMapper(org.springframework.integration.mapping.HeaderMapper<Void> headerMapper) Unsupported operation. UsesetEmbeddedHeadersMapper(org.springframework.integration.mapping.OutboundMessageMapper<byte[]>)instead.- Overrides:
setHeaderMapperin classAbstractAwsMessageHandler<Void>- Parameters:
headerMapper- is not used.- See Also:
-
handleMessageToAws
- Specified by:
handleMessageToAwsin classAbstractAwsMessageHandler<Void>
-
additionalOnSuccessHeaders
protected void additionalOnSuccessHeaders(org.springframework.integration.support.AbstractIntegrationMessageBuilder<?> messageBuilder, AmazonWebServiceRequest request, Object result) - Specified by:
additionalOnSuccessHeadersin classAbstractAwsMessageHandler<Void>
-
setMessageConverter(org.springframework.messaging.converter.MessageConverter)