Modifier and Type | Method and Description |
---|---|
KinesisConsumerProperties |
KinesisMessageChannelBinder.getExtendedConsumerProperties(String channelName) |
Modifier and Type | Method and Description |
---|---|
protected org.springframework.integration.core.MessageProducer |
KinesisMessageChannelBinder.createConsumerEndpoint(org.springframework.cloud.stream.provisioning.ConsumerDestination destination,
String group,
org.springframework.cloud.stream.binder.ExtendedConsumerProperties<KinesisConsumerProperties> properties) |
Modifier and Type | Method and Description |
---|---|
KinesisConsumerProperties |
KinesisBindingProperties.getConsumer() |
KinesisConsumerProperties |
KinesisExtendedBindingProperties.getExtendedConsumerProperties(String channelName) |
Modifier and Type | Method and Description |
---|---|
void |
KinesisBindingProperties.setConsumer(KinesisConsumerProperties consumer) |
Modifier and Type | Method and Description |
---|---|
org.springframework.cloud.stream.provisioning.ConsumerDestination |
KinesisStreamProvisioner.provisionConsumerDestination(String name,
String group,
org.springframework.cloud.stream.binder.ExtendedConsumerProperties<KinesisConsumerProperties> properties) |
Copyright © 2017 Pivotal Software, Inc.. All rights reserved.