public class KinesisMessageHandler extends AbstractAwsMessageHandler
AbstractMessageHandler implementation for the Amazon Kinesis putRecord(s).AmazonKinesis.putRecord(PutRecordRequest),
AmazonKinesis.putRecords(PutRecordsRequest),
AsyncHandlerDEFAULT_SEND_TIMEOUTmessagingTemplate| 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 |
setExplicitHashKey(java.lang.String explicitHashKey) |
void |
setExplicitHashKeyExpression(org.springframework.expression.Expression explicitHashKeyExpression) |
void |
setExplicitHashKeyExpressionString(java.lang.String explicitHashKeyExpression) |
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) |
getAsyncHandler, getErrorMessageStrategy, getEvaluationContext, getFailureChannel, 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, shouldSplitOutputconfigureMetrics, getActiveCount, getActiveCountLong, getComponentType, getDuration, getErrorCount, getErrorCountLong, getHandleCount, getHandleCountLong, getManagedName, getManagedType, getMaxDuration, getMeanDuration, getMinDuration, getOrder, getOverrides, getStandardDeviationDuration, handleMessage, isCountsEnabled, isLoggingEnabled, isStatsEnabled, onComplete, onError, onNext, onSubscribe, 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)
protected java.util.concurrent.Future<?> handleMessageToAws(org.springframework.messaging.Message<?> message)
handleMessageToAws in class AbstractAwsMessageHandlerprotected void additionalOnSuccessHeaders(org.springframework.integration.support.AbstractIntegrationMessageBuilder<?> messageBuilder,
com.amazonaws.AmazonWebServiceRequest request,
java.lang.Object result)
additionalOnSuccessHeaders in class AbstractAwsMessageHandler