Modifier and Type | Method and Description |
---|---|
KinesisProducerProperties |
KinesisMessageChannelBinder.getExtendedProducerProperties(String channelName) |
Modifier and Type | Method and Description |
---|---|
protected org.springframework.messaging.MessageHandler |
KinesisMessageChannelBinder.createProducerMessageHandler(org.springframework.cloud.stream.provisioning.ProducerDestination destination,
org.springframework.cloud.stream.binder.ExtendedProducerProperties<KinesisProducerProperties> producerProperties,
org.springframework.messaging.MessageChannel errorChannel) |
protected void |
KinesisMessageChannelBinder.postProcessOutputChannel(org.springframework.messaging.MessageChannel outputChannel,
org.springframework.cloud.stream.binder.ExtendedProducerProperties<KinesisProducerProperties> producerProperties) |
Modifier and Type | Method and Description |
---|---|
KinesisProducerProperties |
KinesisExtendedBindingProperties.getExtendedProducerProperties(String channelName) |
KinesisProducerProperties |
KinesisBindingProperties.getProducer() |
Modifier and Type | Method and Description |
---|---|
void |
KinesisBindingProperties.setProducer(KinesisProducerProperties producer) |
Modifier and Type | Method and Description |
---|---|
org.springframework.cloud.stream.provisioning.ProducerDestination |
KinesisStreamProvisioner.provisionProducerDestination(String name,
org.springframework.cloud.stream.binder.ExtendedProducerProperties<KinesisProducerProperties> properties) |
Copyright © 2019 Pivotal Software, Inc.. All rights reserved.