public class KinesisMessageChannelBinder extends org.springframework.cloud.stream.binder.AbstractMessageChannelBinder<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<KinesisConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<KinesisProducerProperties>,KinesisStreamProvisioner> implements org.springframework.cloud.stream.binder.ExtendedPropertiesBinder<org.springframework.messaging.MessageChannel,KinesisConsumerProperties,KinesisProducerProperties>
Constructor and Description |
---|
KinesisMessageChannelBinder(com.amazonaws.services.kinesis.AmazonKinesisAsync amazonKinesis,
KinesisBinderConfigurationProperties configurationProperties,
KinesisStreamProvisioner provisioningProvider) |
Modifier and Type | Method and Description |
---|---|
protected org.springframework.integration.core.MessageProducer |
createConsumerEndpoint(org.springframework.cloud.stream.provisioning.ConsumerDestination destination,
String group,
org.springframework.cloud.stream.binder.ExtendedConsumerProperties<KinesisConsumerProperties> properties) |
protected org.springframework.messaging.MessageHandler |
createProducerMessageHandler(org.springframework.cloud.stream.provisioning.ProducerDestination destination,
org.springframework.cloud.stream.binder.ExtendedProducerProperties<KinesisProducerProperties> producerProperties,
org.springframework.messaging.MessageChannel errorChannel) |
KinesisConsumerProperties |
getExtendedConsumerProperties(String channelName) |
KinesisProducerProperties |
getExtendedProducerProperties(String channelName) |
void |
setCheckpointStore(org.springframework.integration.metadata.MetadataStore checkpointStore) |
afterUnbindConsumer, afterUnbindProducer, doBindConsumer, doBindProducer, errorsBaseName, errorsBaseName, getDefaultErrorMessageHandler, getErrorBridgeName, getErrorBridgeName, getErrorMessageHandler, getErrorMessageHandlerName, getErrorMessageStrategy, getErrorRecovererName, registerErrorInfrastructure
afterPropertiesSet, applyPrefix, bindConsumer, bindProducer, buildPartitionRoutingExpression, buildRetryTemplate, constructDLQName, deserializePayloadIfNecessary, deserializePayloadIfNecessary, getApplicationContext, getBeanFactory, groupedName, onInit, serializePayloadIfNecessary, serializePayloadIfNecessary, setApplicationContext, setCodec, setIntegrationEvaluationContext
public KinesisMessageChannelBinder(com.amazonaws.services.kinesis.AmazonKinesisAsync amazonKinesis, KinesisBinderConfigurationProperties configurationProperties, KinesisStreamProvisioner provisioningProvider)
public KinesisConsumerProperties getExtendedConsumerProperties(String channelName)
getExtendedConsumerProperties
in interface org.springframework.cloud.stream.binder.ExtendedBindingProperties<KinesisConsumerProperties,KinesisProducerProperties>
public KinesisProducerProperties getExtendedProducerProperties(String channelName)
getExtendedProducerProperties
in interface org.springframework.cloud.stream.binder.ExtendedBindingProperties<KinesisConsumerProperties,KinesisProducerProperties>
protected org.springframework.messaging.MessageHandler createProducerMessageHandler(org.springframework.cloud.stream.provisioning.ProducerDestination destination, org.springframework.cloud.stream.binder.ExtendedProducerProperties<KinesisProducerProperties> producerProperties, org.springframework.messaging.MessageChannel errorChannel) throws Exception
createProducerMessageHandler
in class org.springframework.cloud.stream.binder.AbstractMessageChannelBinder<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<KinesisConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<KinesisProducerProperties>,KinesisStreamProvisioner>
Exception
protected org.springframework.integration.core.MessageProducer createConsumerEndpoint(org.springframework.cloud.stream.provisioning.ConsumerDestination destination, String group, org.springframework.cloud.stream.binder.ExtendedConsumerProperties<KinesisConsumerProperties> properties) throws Exception
createConsumerEndpoint
in class org.springframework.cloud.stream.binder.AbstractMessageChannelBinder<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<KinesisConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<KinesisProducerProperties>,KinesisStreamProvisioner>
Exception
public void setCheckpointStore(org.springframework.integration.metadata.MetadataStore checkpointStore)
Copyright © 2017 Pivotal Software, Inc.. All rights reserved.