org.springframework.cloud.stream.config

Class BindingServiceConfiguration

java.lang.Object

org.springframework.cloud.stream.config.BindingServiceConfiguration

@Configuration
 @EnableConfigurationProperties(value={BindingServiceProperties.class,SpringIntegrationProperties.class})
 @Role(value=2)
public class BindingServiceConfiguration
extends Object

Configuration class that provides necessary beans for MessageChannel binding.

Author:

Dave Syer, David Turanski, Marius Bogoevici, Ilayaperumal Gopinathan, Gary Russell, Vinicius Carvalho, Artem Bilan, Oleg Zhurakousky

Field Summary

Fields

Modifier and Type	Field and Description
static String	ERROR_BRIDGE_CHANNEL
static String	STREAM_LISTENER_ANNOTATION_BEAN_POST_PROCESSOR_NAME

Constructor Summary

Constructors

Constructor and Description
BindingServiceConfiguration()

Method Summary

Modifier and Type	Method and Description
BinderAwareChannelResolver	binderAwareChannelResolver(BindingService bindingService, AbstractBindingTargetFactory<? extends org.springframework.messaging.MessageChannel> bindingTargetFactory, DynamicDestinationsBindable dynamicDestinationsBindable)
BinderAwareRouterBeanPostProcessor	binderAwareRouterBeanPostProcessor(org.springframework.integration.router.AbstractMappingMessageRouter[] routers, org.springframework.messaging.core.DestinationResolver<org.springframework.messaging.MessageChannel> channelResolver)
BindingService	bindingService(BindingServiceProperties bindingServiceProperties, BinderFactory binderFactory)
ChannelBindingServiceProperties	channelBindingServiceProperties(BindingServiceProperties bindingServiceProperties)
SubscribableChannelBindingTargetFactory	channelFactory(CompositeMessageChannelConfigurer compositeMessageChannelConfigurer)
CompositeMessageChannelConfigurer	compositeMessageChannelConfigurer(MessageConverterConfigurer messageConverterConfigurer)
CompositeMessageConverterFactory	compositeMessageConverterFactory()
ContextStartAfterRefreshListener	contextStartAfterRefreshListener()
DynamicDestinationsBindable	dynamicDestinationsBindable()
org.springframework.messaging.MessageChannel	errorBridgeChannel(org.springframework.integration.channel.PublishSubscribeChannel errorChannel)
SingleBindingTargetBindable<org.springframework.messaging.MessageChannel>	errorBridgeChannelBindable(org.springframework.messaging.MessageChannel errorBridgeChannel, CompositeMessageChannelConfigurer compositeMessageChannelConfigurer)
InputBindingLifecycle	inputBindingLifecycle()
MessageChannelStreamListenerResultAdapter	messageChannelStreamListenerResultAdapter()
MessageConverterConfigurer	messageConverterConfigurer(BindingServiceProperties bindingServiceProperties, CompositeMessageConverterFactory compositeMessageConverterFactory)
static org.springframework.beans.factory.InitializingBean	messageHandlerHeaderPropagationBeanPostProcessor(List<org.springframework.integration.handler.AbstractReplyProducingMessageHandler> producingMessageHandlers, SpringIntegrationProperties springIntegrationProperties)
static org.springframework.messaging.handler.annotation.support.MessageHandlerMethodFactory	messageHandlerMethodFactory(CompositeMessageConverterFactory compositeMessageConverterFactory)
OutputBindingLifecycle	outputBindingLifecycle()
org.springframework.beans.factory.InitializingBean	propertyAccessorInjector(org.springframework.integration.config.IntegrationEvaluationContextFactoryBean[] iecfbs)
static StreamListenerAnnotationBeanPostProcessor	streamListenerAnnotationBeanPostProcessor()

Methods inherited from class java.lang.Object

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

Field Detail

STREAM_LISTENER_ANNOTATION_BEAN_POST_PROCESSOR_NAME

public static final String STREAM_LISTENER_ANNOTATION_BEAN_POST_PROCESSOR_NAME

See Also:

Constant Field Values

ERROR_BRIDGE_CHANNEL

public static final String ERROR_BRIDGE_CHANNEL

See Also:

Constant Field Values

Constructor Detail

BindingServiceConfiguration

public BindingServiceConfiguration()

Method Detail

messageChannelStreamListenerResultAdapter

@Bean
public MessageChannelStreamListenerResultAdapter messageChannelStreamListenerResultAdapter()

messageHandlerMethodFactory

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

streamListenerAnnotationBeanPostProcessor

@Bean(name="streamListenerAnnotationBeanPostProcessor")
public static StreamListenerAnnotationBeanPostProcessor streamListenerAnnotationBeanPostProcessor()

bindingService

@Bean
 @ConditionalOnMissingBean(value=BindingService.class)
public BindingService bindingService(BindingServiceProperties bindingServiceProperties,
                                                                                                  BinderFactory binderFactory)

messageConverterConfigurer

@Bean
public MessageConverterConfigurer messageConverterConfigurer(BindingServiceProperties bindingServiceProperties,
                                                                   CompositeMessageConverterFactory compositeMessageConverterFactory)

channelFactory

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

errorBridgeChannel

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

errorBridgeChannelBindable

@Bean
 @ConditionalOnProperty(value="spring.cloud.stream.bindings.error.destination")
public SingleBindingTargetBindable<org.springframework.messaging.MessageChannel> errorBridgeChannelBindable(@Qualifier(value="errorBridgeChannel")
                                                                                                                                                                                                  org.springframework.messaging.MessageChannel errorBridgeChannel,
                                                                                                                                                                                                  CompositeMessageChannelConfigurer compositeMessageChannelConfigurer)

dynamicDestinationsBindable

@Bean
public DynamicDestinationsBindable dynamicDestinationsBindable()

compositeMessageConverterFactory

@Bean
public CompositeMessageConverterFactory compositeMessageConverterFactory()

channelBindingServiceProperties

@Bean
public ChannelBindingServiceProperties channelBindingServiceProperties(BindingServiceProperties bindingServiceProperties)

binderAwareRouterBeanPostProcessor

@Bean
 @ConditionalOnMissingBean
public BinderAwareRouterBeanPostProcessor binderAwareRouterBeanPostProcessor(@Autowired(required=false)
                                                                                                              org.springframework.integration.router.AbstractMappingMessageRouter[] routers,
                                                                                                              @Autowired(required=false)
                                                                                                              org.springframework.messaging.core.DestinationResolver<org.springframework.messaging.MessageChannel> channelResolver)

propertyAccessorInjector

@Bean
public org.springframework.beans.factory.InitializingBean propertyAccessorInjector(org.springframework.integration.config.IntegrationEvaluationContextFactoryBean[] iecfbs)

messageHandlerHeaderPropagationBeanPostProcessor

@Bean
public static org.springframework.beans.factory.InitializingBean messageHandlerHeaderPropagationBeanPostProcessor(@Autowired(required=false)
                                                                                                                        List<org.springframework.integration.handler.AbstractReplyProducingMessageHandler> producingMessageHandlers,
                                                                                                                        @Autowired
                                                                                                                        SpringIntegrationProperties springIntegrationProperties)