org.springframework.cloud.stream.binder

Class DefaultBinderFactory<T>

java.lang.Object

org.springframework.cloud.stream.binder.DefaultBinderFactory<T>

All Implemented Interfaces:

org.springframework.beans.factory.Aware, org.springframework.beans.factory.DisposableBean, BinderFactory<T>, org.springframework.context.ApplicationContextAware

public class DefaultBinderFactory<T>
extends Object
implements BinderFactory<T>, org.springframework.beans.factory.DisposableBean, org.springframework.context.ApplicationContextAware

Default BinderFactory implementation.

Author:

Marius Bogoevici

Constructor Summary

Constructors

Constructor and Description
DefaultBinderFactory(Map<String,BinderConfiguration> binderConfigurations)

Method Summary

Modifier and Type	Method and Description
void	destroy()
Binder<T,?,?>	getBinder(String name) Returns the binder instance associated with the given configuration name.
void	setApplicationContext(org.springframework.context.ApplicationContext applicationContext)
void	setBindersHealthIndicator(org.springframework.boot.actuate.health.CompositeHealthIndicator bindersHealthIndicator)
void	setDefaultBinder(String defaultBinder)

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultBinderFactory

public DefaultBinderFactory(Map<String,BinderConfiguration> binderConfigurations)

Method Detail

setApplicationContext

public void setApplicationContext(org.springframework.context.ApplicationContext applicationContext)

Specified by:

setApplicationContext in interface org.springframework.context.ApplicationContextAware

setBindersHealthIndicator

@Autowired(required=false)
 @Qualifier(value="bindersHealthIndicator")
public void setBindersHealthIndicator(org.springframework.boot.actuate.health.CompositeHealthIndicator bindersHealthIndicator)

setDefaultBinder

public void setDefaultBinder(String defaultBinder)

destroy

public void destroy()
             throws Exception

Specified by:

destroy in interface org.springframework.beans.factory.DisposableBean

Throws:

Exception

getBinder

public Binder<T,?,?> getBinder(String name)

Description copied from interface: BinderFactory

Returns the binder instance associated with the given configuration name. Instance caching is a requirement, and implementations must return the same instance on subsequent invocations with the same argument.

Specified by:

getBinder in interface BinderFactory<T>

Parameters:

name - the name of a binder configuration

Returns:

the binder instance