public class KinesisMessageHandler extends AbstractAwsMessageHandler<java.lang.Void>
AbstractMessageHandler implementation for the Amazon Kinesis putRecord(s).AmazonKinesis.putRecord(PutRecordRequest),
AmazonKinesis.putRecords(PutRecordsRequest),
AsyncHandlerDEFAULT_SEND_TIMEOUTmessagingTemplateEXPRESSION_PARSER, logger| Constructor and Description |
|---|
KinesisMessageHandler(com.amazonaws.services.kinesis.AmazonKinesisAsync amazonKinesis) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
additionalOnSuccessHeaders(org.springframework.integration.support.AbstractIntegrationMessageBuilder<?> messageBuilder,
com.amazonaws.AmazonWebServiceRequest request,
java.lang.Object result) |
protected java.util.concurrent.Future<?> |
handleMessageToAws(org.springframework.messaging.Message<?> message) |
void |
setConverter(org.springframework.core.convert.converter.Converter<java.lang.Object,byte[]> converter)
Specify a
Converter to serialize payload to the byte[]
if that isn't byte[] already. |
void |
setEmbeddedHeadersMapper(org.springframework.integration.mapping.OutboundMessageMapper<byte[]> embeddedHeadersMapper)
Specify a
OutboundMessageMapper for embedding message headers into the record data
together with payload. |
void |
setExplicitHashKey(java.lang.String explicitHashKey) |
void |
setExplicitHashKeyExpression(org.springframework.expression.Expression explicitHashKeyExpression) |
void |
setExplicitHashKeyExpressionString(java.lang.String explicitHashKeyExpression) |
void |
setHeaderMapper(org.springframework.integration.mapping.HeaderMapper<java.lang.Void> headerMapper)
Unsupported operation.
|
void |
setPartitionKey(java.lang.String partitionKey) |
void |
setPartitionKeyExpression(org.springframework.expression.Expression partitionKeyExpression) |
void |
setPartitionKeyExpressionString(java.lang.String partitionKeyExpression) |
void |
setSequenceNumberExpression(org.springframework.expression.Expression sequenceNumberExpression) |
void |
setSequenceNumberExpressionString(java.lang.String sequenceNumberExpression) |
void |
setStream(java.lang.String stream) |
void |
setStreamExpression(org.springframework.expression.Expression streamExpression) |
void |
setStreamExpressionString(java.lang.String streamExpression) |
doSetHeaderMapper, getAsyncHandler, getErrorMessageStrategy, getEvaluationContext, getFailureChannel, getHeaderMapper, getSendTimeoutExpression, handleMessageInternal, isSync, obtainAsyncHandler, onInit, setAsyncHandler, setErrorMessageStrategy, setFailureChannel, setFailureChannelName, setSendTimeout, setSendTimeoutExpression, setSendTimeoutExpressionString, setSyncaddNotPropagatedHeaders, createOutputMessage, getNotPropagatedHeaders, getOutputChannel, isAsync, produceOutput, resolveErrorChannel, sendErrorMessage, sendOutput, sendOutputs, setAsync, setNotPropagatedHeaders, setOutputChannel, setOutputChannelName, shouldCopyRequestHeaders, shouldSplitOutput, updateNotPropagatedHeadersconfigureMetrics, getActiveCount, getActiveCountLong, getComponentType, getDuration, getErrorCount, getErrorCountLong, getHandleCount, getHandleCountLong, getManagedName, getManagedType, getMaxDuration, getMeanDuration, getMinDuration, getOrder, getOverrides, getStandardDeviationDuration, handleMessage, isCountsEnabled, isLoggingEnabled, isStatsEnabled, onComplete, onError, onNext, onSubscribe, registerMetricsCaptor, reset, setCountsEnabled, setLoggingEnabled, setManagedName, setManagedType, setOrder, setShouldTrack, setStatsEnabledafterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toStringclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitpublic KinesisMessageHandler(com.amazonaws.services.kinesis.AmazonKinesisAsync amazonKinesis)
public void setConverter(org.springframework.core.convert.converter.Converter<java.lang.Object,byte[]> converter)
Converter to serialize payload to the byte[]
if that isn't byte[] already.converter - the Converter to use; cannot be null.public void setStream(java.lang.String stream)
public void setStreamExpressionString(java.lang.String streamExpression)
public void setStreamExpression(org.springframework.expression.Expression streamExpression)
public void setPartitionKey(java.lang.String partitionKey)
public void setPartitionKeyExpressionString(java.lang.String partitionKeyExpression)
public void setPartitionKeyExpression(org.springframework.expression.Expression partitionKeyExpression)
public void setExplicitHashKey(java.lang.String explicitHashKey)
public void setExplicitHashKeyExpressionString(java.lang.String explicitHashKeyExpression)
public void setExplicitHashKeyExpression(org.springframework.expression.Expression explicitHashKeyExpression)
public void setSequenceNumberExpressionString(java.lang.String sequenceNumberExpression)
public void setSequenceNumberExpression(org.springframework.expression.Expression sequenceNumberExpression)
public void setEmbeddedHeadersMapper(org.springframework.integration.mapping.OutboundMessageMapper<byte[]> embeddedHeadersMapper)
OutboundMessageMapper for embedding message headers into the record data
together with payload.embeddedHeadersMapper - the OutboundMessageMapper to embed headers into the record data.EmbeddedJsonHeadersMessageMapperpublic void setHeaderMapper(org.springframework.integration.mapping.HeaderMapper<java.lang.Void> headerMapper)
setEmbeddedHeadersMapper(org.springframework.integration.mapping.OutboundMessageMapper<byte[]>) instead.setHeaderMapper in class AbstractAwsMessageHandler<java.lang.Void>headerMapper - is not used.setEmbeddedHeadersMapper(org.springframework.integration.mapping.OutboundMessageMapper<byte[]>)protected java.util.concurrent.Future<?> handleMessageToAws(org.springframework.messaging.Message<?> message)
throws java.lang.Exception
handleMessageToAws in class AbstractAwsMessageHandler<java.lang.Void>java.lang.Exceptionprotected void additionalOnSuccessHeaders(org.springframework.integration.support.AbstractIntegrationMessageBuilder<?> messageBuilder,
com.amazonaws.AmazonWebServiceRequest request,
java.lang.Object result)
additionalOnSuccessHeaders in class AbstractAwsMessageHandler<java.lang.Void>