org.springframework.cloud.stream.config

Class ChannelBindingServiceConfiguration

java.lang.Object

org.springframework.cloud.stream.config.ChannelBindingServiceConfiguration

@Configuration
 @EnableConfigurationProperties(value=ChannelBindingServiceProperties.class)
public class ChannelBindingServiceConfiguration
extends Object

Configuration class that provides necessary beans for MessageChannel binding.

Author:

Dave Syer, David Turanski, Marius Bogoevici, Ilayaperumal Gopinathan, Gary Russell

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	ChannelBindingServiceConfiguration.PostProcessorConfiguration

Constructor Summary

Constructors

Constructor and Description
ChannelBindingServiceConfiguration()

Method Summary

Modifier and Type	Method and Description
BinderAwareChannelResolver	binderAwareChannelResolver(ChannelBindingService channelBindingService, BindableChannelFactory bindableChannelFactory, DynamicDestinationsBindable dynamicDestinationsBindable)
ChannelBindingService	bindingService(ChannelBindingServiceProperties channelBindingServiceProperties, BinderFactory<org.springframework.messaging.MessageChannel> binderFactory)
static StreamListenerAnnotationBeanPostProcessor	bindToAnnotationBeanPostProcessor(BinderAwareChannelResolver binderAwareChannelResolver, org.springframework.messaging.handler.annotation.support.MessageHandlerMethodFactory messageHandlerMethodFactory)
BindableChannelFactory	channelFactory(CompositeMessageChannelConfigurer compositeMessageChannelConfigurer)
CompositeMessageChannelConfigurer	compositeMessageChannelConfigurer(MessageConverterConfigurer messageConverterConfigurer)
CompositeMessageConverterFactory	compositeMessageConverterFactory()
ContextStartAfterRefreshListener	contextStartAfterRefreshListener()
DynamicDestinationsBindable	dynamicDestinationsBindable()
SingleChannelBindable	errorChannelBindable(org.springframework.integration.channel.PublishSubscribeChannel errorChannel)
InputBindingLifecycle	inputBindingLifecycle()
MessageConverterConfigurer	messageConverterConfigurer(ChannelBindingServiceProperties channelBindingServiceProperties, org.springframework.integration.support.MessageBuilderFactory messageBuilderFactory, CompositeMessageConverterFactory compositeMessageConverterFactory)
static org.springframework.messaging.handler.annotation.support.MessageHandlerMethodFactory	messageHandlerMethodFactory(CompositeMessageConverterFactory compositeMessageConverterFactory)
OutputBindingLifecycle	outputBindingLifecycle()

Methods inherited from class java.lang.Object

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

Constructor Detail

ChannelBindingServiceConfiguration

public ChannelBindingServiceConfiguration()

Method Detail

bindingService

@Bean
 @ConditionalOnMissingBean(value=ChannelBindingService.class)
public ChannelBindingService bindingService(ChannelBindingServiceProperties channelBindingServiceProperties,
                                                                                                                BinderFactory<org.springframework.messaging.MessageChannel> binderFactory)

messageConverterConfigurer

@Bean
public MessageConverterConfigurer messageConverterConfigurer(ChannelBindingServiceProperties channelBindingServiceProperties,
                                                                   org.springframework.integration.support.MessageBuilderFactory messageBuilderFactory,
                                                                   CompositeMessageConverterFactory compositeMessageConverterFactory)

channelFactory

@Bean
public BindableChannelFactory channelFactory(CompositeMessageChannelConfigurer compositeMessageChannelConfigurer)

compositeMessageChannelConfigurer

@Bean
public CompositeMessageChannelConfigurer compositeMessageChannelConfigurer(MessageConverterConfigurer messageConverterConfigurer)

outputBindingLifecycle

@Bean
 @DependsOn(value="bindingService")
public OutputBindingLifecycle outputBindingLifecycle()

inputBindingLifecycle

@Bean
 @DependsOn(value="bindingService")
public InputBindingLifecycle inputBindingLifecycle()

contextStartAfterRefreshListener

@Bean
 @DependsOn(value="bindingService")
public ContextStartAfterRefreshListener contextStartAfterRefreshListener()

binderAwareChannelResolver

@Bean
public BinderAwareChannelResolver binderAwareChannelResolver(ChannelBindingService channelBindingService,
                                                                   BindableChannelFactory bindableChannelFactory,
                                                                   DynamicDestinationsBindable dynamicDestinationsBindable)

errorChannelBindable

@Bean
 @ConditionalOnProperty(value="spring.cloud.stream.bindings.error.destination")
public SingleChannelBindable errorChannelBindable(@Qualifier(value="errorChannel")
                                                                                                                                        org.springframework.integration.channel.PublishSubscribeChannel errorChannel)

dynamicDestinationsBindable

@Bean
public DynamicDestinationsBindable dynamicDestinationsBindable()

compositeMessageConverterFactory

@Bean
public CompositeMessageConverterFactory compositeMessageConverterFactory()

messageHandlerMethodFactory

@Bean
public static org.springframework.messaging.handler.annotation.support.MessageHandlerMethodFactory messageHandlerMethodFactory(CompositeMessageConverterFactory compositeMessageConverterFactory)

bindToAnnotationBeanPostProcessor

@Bean
public static StreamListenerAnnotationBeanPostProcessor bindToAnnotationBeanPostProcessor(@Lazy
                                                                                                BinderAwareChannelResolver binderAwareChannelResolver,
                                                                                                @Lazy
                                                                                                org.springframework.messaging.handler.annotation.support.MessageHandlerMethodFactory messageHandlerMethodFactory)