public class KinesisStreamProvisioner extends Object implements org.springframework.cloud.stream.provisioning.ProvisioningProvider<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<KinesisConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<KinesisProducerProperties>>
ProvisioningProvider
implementation for Amazon Kinesis.Constructor and Description |
---|
KinesisStreamProvisioner(com.amazonaws.services.kinesis.AmazonKinesis amazonKinesis,
KinesisBinderConfigurationProperties kinesisBinderConfigurationProperties) |
Modifier and Type | Method and Description |
---|---|
org.springframework.cloud.stream.provisioning.ConsumerDestination |
provisionConsumerDestination(String name,
String group,
org.springframework.cloud.stream.binder.ExtendedConsumerProperties<KinesisConsumerProperties> properties) |
org.springframework.cloud.stream.provisioning.ProducerDestination |
provisionProducerDestination(String name,
org.springframework.cloud.stream.binder.ExtendedProducerProperties<KinesisProducerProperties> properties) |
public KinesisStreamProvisioner(com.amazonaws.services.kinesis.AmazonKinesis amazonKinesis, KinesisBinderConfigurationProperties kinesisBinderConfigurationProperties)
public org.springframework.cloud.stream.provisioning.ProducerDestination provisionProducerDestination(String name, org.springframework.cloud.stream.binder.ExtendedProducerProperties<KinesisProducerProperties> properties) throws org.springframework.cloud.stream.provisioning.ProvisioningException
provisionProducerDestination
in interface org.springframework.cloud.stream.provisioning.ProvisioningProvider<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<KinesisConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<KinesisProducerProperties>>
org.springframework.cloud.stream.provisioning.ProvisioningException
public org.springframework.cloud.stream.provisioning.ConsumerDestination provisionConsumerDestination(String name, String group, org.springframework.cloud.stream.binder.ExtendedConsumerProperties<KinesisConsumerProperties> properties) throws org.springframework.cloud.stream.provisioning.ProvisioningException
provisionConsumerDestination
in interface org.springframework.cloud.stream.provisioning.ProvisioningProvider<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<KinesisConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<KinesisProducerProperties>>
org.springframework.cloud.stream.provisioning.ProvisioningException
Copyright © 2018 Pivotal Software, Inc.. All rights reserved.