org.springframework.cloud.stream.config

Class BindingServiceConfiguration

java.lang.Object

org.springframework.cloud.stream.config.BindingServiceConfiguration

@Configuration
 @EnableConfigurationProperties(value={BindingServiceProperties.class,SpringIntegrationProperties.class})
 @Import(value={ContentTypeConfiguration.class,DestinationPublishingMetricsAutoConfiguration.class,SpelExpressionConverterConfiguration.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
org.springframework.context.ApplicationListener<org.springframework.context.event.ContextRefreshedEvent>	appListener(SpringIntegrationProperties springIntegrationProperties)
BinderAwareChannelResolver	binderAwareChannelResolver(BindingService bindingService, AbstractBindingTargetFactory<? extends org.springframework.messaging.MessageChannel> bindingTargetFactory, DynamicDestinationsBindable dynamicDestinationsBindable, BinderAwareChannelResolver.NewDestinationBindingCallback callback, org.springframework.integration.config.GlobalChannelInterceptorProcessor globalChannelInterceptorProcessor)
BinderAwareRouterBeanPostProcessor	binderAwareRouterBeanPostProcessor(org.springframework.integration.router.AbstractMappingMessageRouter[] routers, org.springframework.messaging.core.DestinationResolver<org.springframework.messaging.MessageChannel> channelResolver)
BindingService	bindingService(BindingServiceProperties bindingServiceProperties, BinderFactory binderFactory, org.springframework.scheduling.TaskScheduler taskScheduler)
SubscribableChannelBindingTargetFactory	channelFactory(CompositeMessageChannelConfigurer compositeMessageChannelConfigurer)
CompositeMessageChannelConfigurer	compositeMessageChannelConfigurer(MessageConverterConfigurer messageConverterConfigurer)
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(BindingService bindingService, Map<String,Bindable> bindables)
MessageChannelStreamListenerResultAdapter	messageChannelStreamListenerResultAdapter()
MessageConverterConfigurer	messageConverterConfigurer(BindingServiceProperties bindingServiceProperties, CompositeMessageConverterFactory compositeMessageConverterFactory)
static org.springframework.messaging.handler.annotation.support.MessageHandlerMethodFactory	messageHandlerMethodFactory(CompositeMessageConverterFactory compositeMessageConverterFactory, org.springframework.integration.config.HandlerMethodArgumentResolversHolder ahmar)
MessageSourceBindingTargetFactory	messageSourceFactory(CompositeMessageConverterFactory compositeMessageConverterFactory, CompositeMessageChannelConfigurer compositeMessageChannelConfigurer)
OutputBindingLifecycle	outputBindingLifecycle(BindingService bindingService, Map<String,Bindable> bindables)
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,
                                                                                                                                     @Qualifier(value="integrationArgumentResolvers")
                                                                                                                                     org.springframework.integration.config.HandlerMethodArgumentResolversHolder ahmar)

streamListenerAnnotationBeanPostProcessor

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

bindingService

@Bean
 @ConditionalOnMissingBean
public BindingService bindingService(BindingServiceProperties bindingServiceProperties,
                                                                      BinderFactory binderFactory,
                                                                      org.springframework.scheduling.TaskScheduler taskScheduler)

messageConverterConfigurer

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

channelFactory

@Bean
public SubscribableChannelBindingTargetFactory channelFactory(CompositeMessageChannelConfigurer compositeMessageChannelConfigurer)

messageSourceFactory

@Bean
public MessageSourceBindingTargetFactory messageSourceFactory(CompositeMessageConverterFactory compositeMessageConverterFactory,
                                                                    CompositeMessageChannelConfigurer compositeMessageChannelConfigurer)

compositeMessageChannelConfigurer

@Bean
 @ConditionalOnMissingBean
public CompositeMessageChannelConfigurer compositeMessageChannelConfigurer(MessageConverterConfigurer messageConverterConfigurer)

outputBindingLifecycle

@Bean
 @DependsOn(value="bindingService")
public OutputBindingLifecycle outputBindingLifecycle(BindingService bindingService,
                                                                                               Map<String,Bindable> bindables)

inputBindingLifecycle

@Bean
 @DependsOn(value="bindingService")
public InputBindingLifecycle inputBindingLifecycle(BindingService bindingService,
                                                                                             Map<String,Bindable> bindables)

contextStartAfterRefreshListener

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

binderAwareChannelResolver

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

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()

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)

appListener

@Bean
public org.springframework.context.ApplicationListener<org.springframework.context.event.ContextRefreshedEvent> appListener(SpringIntegrationProperties springIntegrationProperties)