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 final 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 Details

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 Details

BindingServiceConfiguration

public BindingServiceConfiguration()

Method Details

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)