Class KinesisExtendedBindingProperties

java.lang.Object

io.awspring.cloud.kinesis.stream.binder.properties.KinesisExtendedBindingProperties

All Implemented Interfaces:

org.springframework.cloud.stream.binder.ExtendedBindingProperties<KinesisConsumerProperties,KinesisProducerProperties>

@ConfigurationProperties("spring.cloud.stream.kinesis")
public class KinesisExtendedBindingProperties
extends Object
implements org.springframework.cloud.stream.binder.ExtendedBindingProperties<KinesisConsumerProperties,KinesisProducerProperties>

The extended Kinesis-specific binding configuration properties.

Since:

4.0

Author:

Peter Oates, Artem Bilan

Constructor Summary

Constructors

Constructor	Description
KinesisExtendedBindingProperties()

Method Summary

Modifier and Type	Method	Description
Map<String,KinesisBindingProperties>	getBindings()
String	getDefaultsPrefix()
KinesisConsumerProperties	getExtendedConsumerProperties(String channelName)
KinesisProducerProperties	getExtendedProducerProperties(String channelName)
Class<? extends org.springframework.cloud.stream.binder.BinderSpecificPropertiesProvider>	getExtendedPropertiesEntryClass()
void	setBindings(Map<String,KinesisBindingProperties> bindings)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

KinesisExtendedBindingProperties

public KinesisExtendedBindingProperties()

Method Details

getBindings

public Map<String,KinesisBindingProperties> getBindings()

Specified by:

getBindings in interface org.springframework.cloud.stream.binder.ExtendedBindingProperties<KinesisConsumerProperties,KinesisProducerProperties>

setBindings

public void setBindings(Map<String,KinesisBindingProperties> bindings)

getExtendedConsumerProperties

public KinesisConsumerProperties getExtendedConsumerProperties(String channelName)

Specified by:

getExtendedConsumerProperties in interface org.springframework.cloud.stream.binder.ExtendedBindingProperties<KinesisConsumerProperties,KinesisProducerProperties>

getExtendedProducerProperties

public KinesisProducerProperties getExtendedProducerProperties(String channelName)

Specified by:

getExtendedProducerProperties in interface org.springframework.cloud.stream.binder.ExtendedBindingProperties<KinesisConsumerProperties,KinesisProducerProperties>

getDefaultsPrefix

public String getDefaultsPrefix()

Specified by:

getDefaultsPrefix in interface org.springframework.cloud.stream.binder.ExtendedBindingProperties<KinesisConsumerProperties,KinesisProducerProperties>

getExtendedPropertiesEntryClass

public Class<? extends org.springframework.cloud.stream.binder.BinderSpecificPropertiesProvider> getExtendedPropertiesEntryClass()

Specified by:

getExtendedPropertiesEntryClass in interface org.springframework.cloud.stream.binder.ExtendedBindingProperties<KinesisConsumerProperties,KinesisProducerProperties>