| 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 © 2021 Pivotal Software, Inc.. All rights reserved.