Package org.springframework.cloud.stream.app.sink.router

Class RouterSinkConfiguration

java.lang.Object

org.springframework.cloud.stream.app.sink.router.RouterSinkConfiguration

@Configuration(proxyBeanMethods=false)
@EnableConfigurationProperties(RouterSinkProperties.class)
public class RouterSinkConfiguration
extends Object

A sink app that routes to one or more named channels.

Author:

Gary Russell, Artem Bilan, Christian Tzolov, Soby Chacko

Constructor Summary

Constructors

Constructor	Description
RouterSinkConfiguration(RouterSinkProperties properties)

Method Summary

Modifier and Type	Method	Description
org.springframework.integration.router.AbstractMessageRouter	router(org.springframework.cloud.stream.binding.BindingService bindingService, org.springframework.cloud.stream.function.StreamBridge streamBridge, org.springframework.integration.handler.MessageProcessor<?> scriptProcessor)
Consumer<Message<?>>	routerSinkConsumer(org.springframework.integration.router.AbstractMessageRouter router)
org.springframework.integration.handler.MessageProcessor<?>	scriptProcessor()

Methods inherited from class java.lang.Object

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

Constructor Details

RouterSinkConfiguration

public RouterSinkConfiguration(RouterSinkProperties properties)

Method Details

routerSinkConsumer

@Bean
public Consumer<Message<?>> routerSinkConsumer(org.springframework.integration.router.AbstractMessageRouter router)

router

@Bean
public org.springframework.integration.router.AbstractMessageRouter router(org.springframework.cloud.stream.binding.BindingService bindingService,
 org.springframework.cloud.stream.function.StreamBridge streamBridge,
 @Nullable
 org.springframework.integration.handler.MessageProcessor<?> scriptProcessor)

scriptProcessor

@Bean
@ConditionalOnProperty("router.script")
public org.springframework.integration.handler.MessageProcessor<?> scriptProcessor()