public class KinesisMessageHandler extends AbstractAwsMessageHandler
AbstractMessageHandler
implementation for the Amazon Kinesis putRecord(s)
.AmazonKinesis.putRecord(PutRecordRequest)
,
AmazonKinesis.putRecords(PutRecordsRequest)
,
AsyncHandler
DEFAULT_SEND_TIMEOUT
messagingTemplate
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, setSync
addNotPropagatedHeaders, createOutputMessage, getNotPropagatedHeaders, getOutputChannel, isAsync, produceOutput, resolveErrorChannel, sendErrorMessage, sendOutput, sendOutputs, setAsync, setNotPropagatedHeaders, setOutputChannel, setOutputChannelName, shouldCopyRequestHeaders, shouldSplitOutput
configureMetrics, 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, setStatsEnabled
afterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
public 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 AbstractAwsMessageHandler
protected void additionalOnSuccessHeaders(org.springframework.integration.support.AbstractIntegrationMessageBuilder<?> messageBuilder, com.amazonaws.AmazonWebServiceRequest request, java.lang.Object result)
additionalOnSuccessHeaders
in class AbstractAwsMessageHandler