org.springframework.cloud.stream.binder.kinesis.properties

Class KinesisExtendedBindingProperties

java.lang.Object

org.springframework.cloud.stream.binder.kinesis.properties.KinesisExtendedBindingProperties

All Implemented Interfaces:

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

@ConfigurationProperties(value="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.

Author:

Peter Oates, Artem Bilan

Constructor Summary

Constructors

Constructor and Description
KinesisExtendedBindingProperties()

Method Summary

Modifier and Type	Method and 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 Detail

KinesisExtendedBindingProperties

public KinesisExtendedBindingProperties()

Method Detail

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>