public class KinesisMessageHandler extends AbstractAwsMessageHandler<java.lang.Void>
AbstractMessageHandler
implementation for the Amazon Kinesis putRecord(s)
.AmazonKinesis.putRecord(PutRecordRequest)
,
AmazonKinesis.putRecords(PutRecordsRequest)
,
AsyncHandler
DEFAULT_SEND_TIMEOUT
messagingTemplate
EXPRESSION_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, setSync
addNotPropagatedHeaders, createOutputMessage, getNotPropagatedHeaders, getOutputChannel, isAsync, produceOutput, resolveErrorChannel, sendErrorMessage, sendOutput, sendOutputs, setAsync, setNotPropagatedHeaders, setOutputChannel, setOutputChannelName, shouldCopyRequestHeaders, shouldSplitOutput, updateNotPropagatedHeaders
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, registerMetricsCaptor, 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)
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.EmbeddedJsonHeadersMessageMapper
public 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.Exception
protected void additionalOnSuccessHeaders(org.springframework.integration.support.AbstractIntegrationMessageBuilder<?> messageBuilder, com.amazonaws.AmazonWebServiceRequest request, java.lang.Object result)
additionalOnSuccessHeaders
in class AbstractAwsMessageHandler<java.lang.Void>