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) |
String |
getDefaultsPrefix() |
protected org.springframework.integration.support.ErrorMessageStrategy |
getErrorMessageStrategy() |
KinesisConsumerProperties |
getExtendedConsumerProperties(String channelName) |
KinesisProducerProperties |
getExtendedProducerProperties(String channelName) |
Class<? extends org.springframework.cloud.stream.binder.BinderSpecificPropertiesProvider> |
getExtendedPropertiesEntryClass() |
protected void |
onInit() |
protected void |
postProcessOutputChannel(org.springframework.messaging.MessageChannel outputChannel,
org.springframework.cloud.stream.binder.ExtendedProducerProperties<KinesisProducerProperties> producerProperties) |
void |
setCheckpointStore(org.springframework.integration.metadata.ConcurrentMetadataStore checkpointStore) |
void |
setExtendedBindingProperties(KinesisExtendedBindingProperties extendedBindingProperties) |
void |
setLockRegistry(org.springframework.integration.support.locks.LockRegistry lockRegistry) |
afterUnbindConsumer, afterUnbindProducer, bindPollableConsumer, createPolledConsumerResources, createProducerMessageHandler, doBindConsumer, doBindProducer, errorsBaseName, errorsBaseName, getApplicationEventPublisher, getContainerCustomizer, getDefaultErrorMessageHandler, getErrorBridgeName, getErrorBridgeName, getErrorMessageHandler, getErrorMessageHandlerName, getErrorRecovererName, getPolledConsumerErrorMessageHandler, getPolledConsumerRecoveryCallback, postProcessPollableSource, registerErrorInfrastructure, registerErrorInfrastructure, setApplicationEventPublisher, useNativeEncoding
afterPropertiesSet, applyPrefix, bindConsumer, bindProducer, buildPartitionRoutingExpression, buildRetryTemplate, constructDLQName, getApplicationContext, getBeanFactory, getEvaluationContext, groupedName, serializePayloadIfNecessary, setApplicationContext
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public KinesisMessageChannelBinder(com.amazonaws.services.kinesis.AmazonKinesisAsync amazonKinesis, KinesisBinderConfigurationProperties configurationProperties, KinesisStreamProvisioner provisioningProvider)
public void setExtendedBindingProperties(KinesisExtendedBindingProperties extendedBindingProperties)
public void setCheckpointStore(org.springframework.integration.metadata.ConcurrentMetadataStore checkpointStore)
public void setLockRegistry(org.springframework.integration.support.locks.LockRegistry lockRegistry)
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>
public String getDefaultsPrefix()
getDefaultsPrefix
in interface org.springframework.cloud.stream.binder.ExtendedBindingProperties<KinesisConsumerProperties,KinesisProducerProperties>
public Class<? extends org.springframework.cloud.stream.binder.BinderSpecificPropertiesProvider> getExtendedPropertiesEntryClass()
getExtendedPropertiesEntryClass
in interface org.springframework.cloud.stream.binder.ExtendedBindingProperties<KinesisConsumerProperties,KinesisProducerProperties>
protected void onInit() throws Exception
onInit
in class org.springframework.cloud.stream.binder.AbstractBinder<org.springframework.messaging.MessageChannel,org.springframework.cloud.stream.binder.ExtendedConsumerProperties<KinesisConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<KinesisProducerProperties>>
Exception
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)
createProducerMessageHandler
in class org.springframework.cloud.stream.binder.AbstractMessageChannelBinder<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<KinesisConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<KinesisProducerProperties>,KinesisStreamProvisioner>
protected void postProcessOutputChannel(org.springframework.messaging.MessageChannel outputChannel, org.springframework.cloud.stream.binder.ExtendedProducerProperties<KinesisProducerProperties> producerProperties)
postProcessOutputChannel
in class org.springframework.cloud.stream.binder.AbstractMessageChannelBinder<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<KinesisConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<KinesisProducerProperties>,KinesisStreamProvisioner>
protected org.springframework.integration.core.MessageProducer createConsumerEndpoint(org.springframework.cloud.stream.provisioning.ConsumerDestination destination, String group, org.springframework.cloud.stream.binder.ExtendedConsumerProperties<KinesisConsumerProperties> properties)
createConsumerEndpoint
in class org.springframework.cloud.stream.binder.AbstractMessageChannelBinder<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<KinesisConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<KinesisProducerProperties>,KinesisStreamProvisioner>
protected org.springframework.integration.support.ErrorMessageStrategy getErrorMessageStrategy()
getErrorMessageStrategy
in class org.springframework.cloud.stream.binder.AbstractMessageChannelBinder<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<KinesisConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<KinesisProducerProperties>,KinesisStreamProvisioner>
Copyright © 2019 Pivotal Software, Inc.. All rights reserved.