Package org.springframework.cloud.stream.config

Class BindingServiceConfiguration

java.lang.Object

org.springframework.cloud.stream.config.BindingServiceConfiguration

@Configuration(proxyBeanMethods=false)
@EnableConfigurationProperties({BindingServiceProperties.class,SpringIntegrationProperties.class,StreamFunctionProperties.class})
@Import({DestinationPublishingMetricsAutoConfiguration.class,SpelExpressionConverterConfiguration.class})
@Role(2)
@ConditionalOnBean(value=BinderTypeRegistry.class,
                   search=CURRENT)
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, Soby Chacko

Field Summary

Fields

Modifier and Type	Field	Description
static String	STREAM_LISTENER_ANNOTATION_BEAN_POST_PROCESSOR_NAME	Name of the Spring Cloud Stream stream listener annotation bean post processor.

Constructor Summary

Constructors

Constructor	Description
BindingServiceConfiguration()

Method Summary

Modifier and Type	Method	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)
BinderAwareRouter	binderAwareRouterBeanPostProcessor(List<org.springframework.integration.router.AbstractMappingMessageRouter> routers, org.springframework.messaging.core.DestinationResolver<org.springframework.messaging.MessageChannel> channelResolver)
BinderFactory	binderFactory(BinderTypeRegistry binderTypeRegistry, BindingServiceProperties bindingServiceProperties, org.springframework.beans.factory.ObjectProvider<BinderCustomizer> binderCustomizerProvider)
BindingHandlerAdvise	BindingHandlerAdvise(BindingHandlerAdvise.MappingsProvider[] providers)
BindingService	bindingService(BindingServiceProperties bindingServiceProperties, BinderFactory binderFactory, org.springframework.scheduling.TaskScheduler taskScheduler, com.fasterxml.jackson.databind.ObjectMapper objectMapper)
BindingsLifecycleController	bindingsLifecycleController(List<InputBindingLifecycle> inputBindingLifecycles, List<OutputBindingLifecycle> outputBindingsLifecycles)
ContextStartAfterRefreshListener	contextStartAfterRefreshListener()
DynamicDestinationsBindable	dynamicDestinationsBindable()
static org.springframework.beans.factory.config.BeanPostProcessor	globalErrorChannelCustomizer()
InputBindingLifecycle	inputBindingLifecycle(BindingService bindingService, Map<String,Bindable> bindables)
MessageChannelStreamListenerResultAdapter	messageChannelStreamListenerResultAdapter()
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

Name of the Spring Cloud Stream stream listener annotation bean post processor.

See Also:

Constant Field Values

Constructor Detail

BindingServiceConfiguration

public BindingServiceConfiguration()

Method Detail

globalErrorChannelCustomizer

@Bean
public static org.springframework.beans.factory.config.BeanPostProcessor globalErrorChannelCustomizer()

streamListenerAnnotationBeanPostProcessor

@Bean(name="streamListenerAnnotationBeanPostProcessor")
@ConditionalOnMissingBean(search=CURRENT)
public static StreamListenerAnnotationBeanPostProcessor streamListenerAnnotationBeanPostProcessor()

BindingHandlerAdvise

@Bean
public BindingHandlerAdvise BindingHandlerAdvise(@Nullable
                                                 BindingHandlerAdvise.MappingsProvider[] providers)

binderFactory

@Bean
@ConditionalOnMissingBean(BinderFactory.class)
public BinderFactory binderFactory(BinderTypeRegistry binderTypeRegistry,
                                   BindingServiceProperties bindingServiceProperties,
                                   org.springframework.beans.factory.ObjectProvider<BinderCustomizer> binderCustomizerProvider)

messageChannelStreamListenerResultAdapter

@Bean
public MessageChannelStreamListenerResultAdapter messageChannelStreamListenerResultAdapter()

bindingService

@Bean
@ConditionalOnMissingBean(search=CURRENT)
public BindingService bindingService(BindingServiceProperties bindingServiceProperties,
                                     BinderFactory binderFactory,
                                     org.springframework.scheduling.TaskScheduler taskScheduler,
                                     @Nullable
                                     com.fasterxml.jackson.databind.ObjectMapper objectMapper)

outputBindingLifecycle

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

inputBindingLifecycle

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

bindingsLifecycleController

@Bean
public BindingsLifecycleController bindingsLifecycleController(List<InputBindingLifecycle> inputBindingLifecycles,
                                                               List<OutputBindingLifecycle> outputBindingsLifecycles)

contextStartAfterRefreshListener

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

binderAwareChannelResolver

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

dynamicDestinationsBindable

@Bean
public DynamicDestinationsBindable dynamicDestinationsBindable()

binderAwareRouterBeanPostProcessor

@Bean
@ConditionalOnMissingBean
public BinderAwareRouter binderAwareRouterBeanPostProcessor(@Autowired(required=false)
                                                            List<org.springframework.integration.router.AbstractMappingMessageRouter> routers,
                                                            @Autowired(required=false) @Qualifier("binderAwareChannelResolver")
                                                            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)