org.springframework.cloud.stream.binder

Class DefaultBinderFactory

java.lang.Object

org.springframework.cloud.stream.binder.DefaultBinderFactory

All Implemented Interfaces:

org.springframework.beans.factory.Aware, org.springframework.beans.factory.DisposableBean, BinderFactory, org.springframework.context.ApplicationContextAware

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

Default BinderFactory implementation.

Author:

Marius Bogoevici, Ilayaperumal Gopinathan

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	DefaultBinderFactory.Listener A listener that can be registered with the DefaultBinderFactory that allows the registration of additional configuration.

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	destroy()
<T> Binder<T,?,?>	getBinder(String name, Class<? extends T> bindingTargetType) Returns the binder instance associated with the given configuration name.
void	setApplicationContext(org.springframework.context.ApplicationContext applicationContext)
void	setDefaultBinder(String defaultBinder)
void	setListeners(Collection<DefaultBinderFactory.Listener> listeners)

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

setDefaultBinder

public void setDefaultBinder(String defaultBinder)

setListeners

public void setListeners(Collection<DefaultBinderFactory.Listener> listeners)

destroy

public void destroy()
             throws Exception

Specified by:

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

Throws:

Exception

getBinder

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

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 arguments.

Specified by:

getBinder in interface BinderFactory

Parameters:

name - the name of a binder configuration

Returns:

the binder instance