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, Oleg Zhurakousky

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	BinderAwareChannelResolver.NewDestinationBindingCallback<T> Configure a new destination before it is bound.

Constructor Summary

Constructors

Constructor and Description
BinderAwareChannelResolver(BindingService bindingService, AbstractBindingTargetFactory<? extends org.springframework.messaging.MessageChannel> bindingTargetFactory, DynamicDestinationsBindable dynamicDestinationsBindable)
BinderAwareChannelResolver(BindingService bindingService, AbstractBindingTargetFactory<? extends org.springframework.messaging.MessageChannel> bindingTargetFactory, DynamicDestinationsBindable dynamicDestinationsBindable, BinderAwareChannelResolver.NewDestinationBindingCallback callback)
BinderAwareChannelResolver(BindingService bindingService, AbstractBindingTargetFactory<? extends org.springframework.messaging.MessageChannel> bindingTargetFactory, DynamicDestinationsBindable dynamicDestinationsBindable, BinderAwareChannelResolver.NewDestinationBindingCallback callback, org.springframework.integration.config.GlobalChannelInterceptorProcessor globalChannelInterceptorProcessor)

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(BindingService bindingService,
                                  AbstractBindingTargetFactory<? extends org.springframework.messaging.MessageChannel> bindingTargetFactory,
                                  DynamicDestinationsBindable dynamicDestinationsBindable)

BinderAwareChannelResolver

public BinderAwareChannelResolver(BindingService bindingService,
                                  AbstractBindingTargetFactory<? extends org.springframework.messaging.MessageChannel> bindingTargetFactory,
                                  DynamicDestinationsBindable dynamicDestinationsBindable,
                                  BinderAwareChannelResolver.NewDestinationBindingCallback callback)

BinderAwareChannelResolver

public BinderAwareChannelResolver(BindingService bindingService,
                                  AbstractBindingTargetFactory<? extends org.springframework.messaging.MessageChannel> bindingTargetFactory,
                                  DynamicDestinationsBindable dynamicDestinationsBindable,
                                  BinderAwareChannelResolver.NewDestinationBindingCallback callback,
                                  org.springframework.integration.config.GlobalChannelInterceptorProcessor globalChannelInterceptorProcessor)

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