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 ObjectConfiguration class that provides necessary beans forMessageChannelbinding.- 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 StringSTREAM_LISTENER_ANNOTATION_BEAN_POST_PROCESSOR_NAMEName of the Spring Cloud Stream stream listener annotation bean post processor.
-
Constructor Summary
Constructors Constructor Description BindingServiceConfiguration()
-
Method Summary
-
-
-
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
-
-
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)
-
-