org.springframework.cloud.stream.binding

Class BinderAwareChannelResolver

java.lang.Object

org.springframework.messaging.core.BeanFactoryMessageChannelDestinationResolver

org.springframework.cloud.stream.binding.BinderAwareChannelResolver

All Implemented Interfaces:

org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanFactoryAware, org.springframework.messaging.core.DestinationResolver<org.springframework.messaging.MessageChannel>

public class BinderAwareChannelResolver
extends org.springframework.messaging.core.BeanFactoryMessageChannelDestinationResolver

A DestinationResolver implementation that resolves the channel from the bean factory and, if not present, creates a new channel and adds it to the factory after binding it to the binder.

Author:

Mark Fisher, Gary Russell, Ilayaperumal Gopinathan

Constructor Summary

Constructors

Constructor and Description
BinderAwareChannelResolver(ChannelBindingService channelBindingService, BindableChannelFactory bindableChannelFactory, DynamicDestinationsBindable dynamicDestinationsBindable)

Method Summary

Modifier and Type	Method and Description
org.springframework.messaging.MessageChannel	resolveDestination(String channelName)
void	setBeanFactory(org.springframework.beans.factory.BeanFactory beanFactory)

Methods inherited from class java.lang.Object

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

Constructor Detail

BinderAwareChannelResolver

public BinderAwareChannelResolver(ChannelBindingService channelBindingService,
                                  BindableChannelFactory bindableChannelFactory,
                                  DynamicDestinationsBindable dynamicDestinationsBindable)

Method Detail

setBeanFactory

public void setBeanFactory(org.springframework.beans.factory.BeanFactory beanFactory)

Specified by:

setBeanFactory in interface org.springframework.beans.factory.BeanFactoryAware

Overrides:

setBeanFactory in class org.springframework.messaging.core.BeanFactoryMessageChannelDestinationResolver

resolveDestination

public org.springframework.messaging.MessageChannel resolveDestination(String channelName)

Specified by:

resolveDestination in interface org.springframework.messaging.core.DestinationResolver<org.springframework.messaging.MessageChannel>

Overrides:

resolveDestination in class org.springframework.messaging.core.BeanFactoryMessageChannelDestinationResolver