@ManagedResource
@IntegrationManagedResource
public class KclMessageDrivenChannelAdapter
extends org.springframework.integration.endpoint.MessageProducerSupport
MessageProducerSupport implementation for receiving data from Amazon
Kinesis stream(s) using AWS KCL.lifecycleCondition, lifecycleLock| Constructor and Description |
|---|
KclMessageDrivenChannelAdapter(com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration kinesisClientLibConfiguration) |
KclMessageDrivenChannelAdapter(com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration kinesisClientLibConfiguration,
AmazonKinesis kinesisClient,
AmazonCloudWatch cloudWatchClient,
AmazonDynamoDB dynamoDBClient) |
KclMessageDrivenChannelAdapter(java.lang.String streams) |
KclMessageDrivenChannelAdapter(java.lang.String stream,
AmazonKinesis kinesisClient,
AmazonCloudWatch cloudWatchClient,
AmazonDynamoDB dynamoDBClient,
AWSCredentialsProvider kinesisProxyCredentialsProvider) |
KclMessageDrivenChannelAdapter(java.lang.String streams,
Regions region) |
| Modifier and Type | Method and Description |
|---|---|
void |
destroy() |
protected void |
doStart() |
protected void |
doStop()
Takes no action by default.
|
java.lang.String |
getConsumerGroup() |
protected org.springframework.core.AttributeAccessor |
getErrorMessageAttributes(org.springframework.messaging.Message<?> message) |
protected void |
onInit() |
void |
setBindSourceRecord(boolean bindSourceRecord)
Set to true to bind the source consumer record in the header named
IntegrationMessageHeaderAccessor.SOURCE_DATA. |
void |
setCheckpointMode(CheckpointMode checkpointMode) |
void |
setCheckpointsInterval(long checkpointsInterval)
Sets the interval between 2 checkpoints.
|
void |
setConsumerBackoff(int consumerBackoff) |
void |
setConsumerGroup(java.lang.String consumerGroup) |
void |
setConverter(org.springframework.core.convert.converter.Converter<byte[],java.lang.Object> converter)
Specify a
Converter to deserialize the byte[] from record's body. |
void |
setEmbeddedHeadersMapper(org.springframework.integration.mapping.InboundMessageMapper<byte[]> embeddedHeadersMapper)
Specify an
InboundMessageMapper to extract message headers embedded into
the record data. |
void |
setExecutor(org.springframework.core.task.TaskExecutor executor) |
void |
setIdleBetweenPolls(int idleBetweenPolls) |
void |
setListenerMode(ListenerMode listenerMode) |
void |
setStreamInitialSequence(com.amazonaws.services.kinesis.clientlibrary.lib.worker.InitialPositionInStream streamInitialSequence) |
void |
setWorkerId(java.lang.String workerId)
Sets the worker identifier used to distinguish different workers/processes of a
Kinesis application.
|
java.lang.String |
toString() |
afterSingletonsInstantiated, buildErrorMessage, getErrorChannel, getIntegrationPatternType, getMessagingTemplate, getOutputChannel, sendErrorMessageIfNecessary, sendMessage, setErrorChannel, setErrorChannelName, setErrorMessageStrategy, setOutputChannel, setOutputChannelName, setSendTimeout, setShouldTrack, subscribeToPublisherdoStop, getPhase, getRole, isActive, isAutoStartup, isRunning, setAutoStartup, setPhase, setRole, start, stop, stopafterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanDescription, getBeanFactory, getBeanName, getChannelResolver, getComponentName, getComponentType, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskSchedulerpublic KclMessageDrivenChannelAdapter(java.lang.String streams)
public KclMessageDrivenChannelAdapter(java.lang.String streams,
Regions region)
public KclMessageDrivenChannelAdapter(java.lang.String stream,
AmazonKinesis kinesisClient,
AmazonCloudWatch cloudWatchClient,
AmazonDynamoDB dynamoDBClient,
AWSCredentialsProvider kinesisProxyCredentialsProvider)
public KclMessageDrivenChannelAdapter(com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration kinesisClientLibConfiguration)
public KclMessageDrivenChannelAdapter(com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration kinesisClientLibConfiguration, AmazonKinesis kinesisClient, AmazonCloudWatch cloudWatchClient, AmazonDynamoDB dynamoDBClient)
public void setExecutor(org.springframework.core.task.TaskExecutor executor)
public void setConsumerGroup(java.lang.String consumerGroup)
public java.lang.String getConsumerGroup()
public void setEmbeddedHeadersMapper(org.springframework.integration.mapping.InboundMessageMapper<byte[]> embeddedHeadersMapper)
InboundMessageMapper to extract message headers embedded into
the record data.embeddedHeadersMapper - the InboundMessageMapper to use.public void setStreamInitialSequence(com.amazonaws.services.kinesis.clientlibrary.lib.worker.InitialPositionInStream streamInitialSequence)
public void setIdleBetweenPolls(int idleBetweenPolls)
public void setConsumerBackoff(int consumerBackoff)
public void setConverter(org.springframework.core.convert.converter.Converter<byte[],java.lang.Object> converter)
Converter to deserialize the byte[] from record's body.
Can be null meaning no deserialization.converter - the Converter to use or nullpublic void setListenerMode(ListenerMode listenerMode)
public void setCheckpointsInterval(long checkpointsInterval)
checkpointsInterval - interval between 2 checkpoints (in milliseconds)public void setCheckpointMode(CheckpointMode checkpointMode)
public void setWorkerId(java.lang.String workerId)
workerId - the worker identifier to usepublic void setBindSourceRecord(boolean bindSourceRecord)
IntegrationMessageHeaderAccessor.SOURCE_DATA. Does not apply to batch
listeners.bindSourceRecord - true to bind.protected void onInit()
onInit in class org.springframework.integration.endpoint.MessageProducerSupportprotected void doStart()
doStart in class org.springframework.integration.endpoint.MessageProducerSupportprotected void doStop()
doStop in class org.springframework.integration.endpoint.MessageProducerSupportpublic void destroy()
destroy in interface org.springframework.beans.factory.DisposableBeandestroy in class org.springframework.integration.endpoint.AbstractEndpointprotected org.springframework.core.AttributeAccessor getErrorMessageAttributes(org.springframework.messaging.Message<?> message)
getErrorMessageAttributes in class org.springframework.integration.endpoint.MessageProducerSupportpublic java.lang.String toString()
toString in class org.springframework.integration.context.IntegrationObjectSupport