public class KinesisMessageHandler
extends org.springframework.integration.handler.AbstractMessageProducingHandler
AbstractMessageHandler implementation for the Amazon Kinesis putRecord(s).AmazonKinesis.putRecord(PutRecordRequest),
AmazonKinesis.putRecords(PutRecordsRequest),
AsyncHandlermessagingTemplate| Constructor and Description |
|---|
KinesisMessageHandler(AmazonKinesisAsync amazonKinesis) |
| Modifier and Type | Method and Description |
|---|---|
protected org.springframework.messaging.MessageChannel |
getFailureChannel() |
protected void |
handleMessageInternal(org.springframework.messaging.Message<?> message) |
protected void |
onInit() |
void |
setAsyncHandler(AsyncHandler<? extends AmazonWebServiceRequest,?> asyncHandler) |
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 |
setFailureChannel(org.springframework.messaging.MessageChannel failureChannel)
Set the failure channel.
|
void |
setFailureChannelName(java.lang.String failureChannelName)
Set the failure channel name.
|
void |
setPartitionKey(java.lang.String partitionKey) |
void |
setPartitionKeyExpression(org.springframework.expression.Expression partitionKeyExpression) |
void |
setPartitionKeyExpressionString(java.lang.String partitionKeyExpression) |
void |
setSendTimeout(long sendTimeout) |
void |
setSendTimeoutExpression(org.springframework.expression.Expression sendTimeoutExpression) |
void |
setSendTimeoutExpressionString(java.lang.String sendTimeoutExpression) |
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) |
void |
setSync(boolean sync) |
addNotPropagatedHeaders, 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, getStandardDeviationDuration, handleMessage, isCountsEnabled, isLoggingEnabled, isStatsEnabled, 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, toStringpublic KinesisMessageHandler(AmazonKinesisAsync amazonKinesis)
public void setAsyncHandler(AsyncHandler<? extends AmazonWebServiceRequest,?> asyncHandler)
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 setSync(boolean sync)
public void setSendTimeout(long sendTimeout)
setSendTimeout in class org.springframework.integration.handler.AbstractMessageProducingHandlerpublic void setSendTimeoutExpressionString(java.lang.String sendTimeoutExpression)
public void setSendTimeoutExpression(org.springframework.expression.Expression sendTimeoutExpression)
public void setFailureChannel(org.springframework.messaging.MessageChannel failureChannel)
ErrorMessage will be sent
to this channel with a payload of a AwsRequestFailureException with the
failed message and cause.failureChannel - the failure channel.protected org.springframework.messaging.MessageChannel getFailureChannel()
public void setFailureChannelName(java.lang.String failureChannelName)
ErrorMessage will be
sent to this channel name with a payload of a AwsRequestFailureException
with the failed message and cause.failureChannelName - the failure channel name.protected void onInit()
throws java.lang.Exception
onInit in class org.springframework.integration.handler.AbstractMessageProducingHandlerjava.lang.Exceptionprotected void handleMessageInternal(org.springframework.messaging.Message<?> message)
throws java.lang.Exception
handleMessageInternal in class org.springframework.integration.handler.AbstractMessageHandlerjava.lang.Exception