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

Class RouterSinkConfiguration

java.lang.Object

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

@EnableBinding(value=org.springframework.cloud.stream.messaging.Sink.class)
 @EnableConfigurationProperties(value=RouterSinkProperties.class)
 @Import(value=ScriptVariableGeneratorConfiguration.class)
public class RouterSinkConfiguration
extends Object

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

Author:

Gary Russell, Artem Bilan, Christian Tzolov

Constructor Summary

Constructors

Constructor and Description
RouterSinkConfiguration()

Method Summary

Modifier and Type	Method and Description
org.springframework.integration.router.MessageRouter	router(org.springframework.cloud.stream.binding.BinderAwareChannelResolver channelResolver, org.springframework.integration.scripting.ScriptVariableGenerator scriptVariableGenerator, RouterSinkProperties properties)
org.springframework.integration.groovy.GroovyScriptExecutingMessageProcessor	scriptProcessor(org.springframework.integration.scripting.ScriptVariableGenerator scriptVariableGenerator, RouterSinkProperties properties)

Methods inherited from class java.lang.Object

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

Constructor Detail

RouterSinkConfiguration

public RouterSinkConfiguration()

Method Detail

router

@Bean
 @ServiceActivator(inputChannel="input")
public org.springframework.integration.router.MessageRouter router(org.springframework.cloud.stream.binding.BinderAwareChannelResolver channelResolver,
                                                                                                                  org.springframework.integration.scripting.ScriptVariableGenerator scriptVariableGenerator,
                                                                                                                  RouterSinkProperties properties)

scriptProcessor

@Bean
 @ConditionalOnProperty(value="router.script")
public org.springframework.integration.groovy.GroovyScriptExecutingMessageProcessor scriptProcessor(org.springframework.integration.scripting.ScriptVariableGenerator scriptVariableGenerator,
                                                                                                                                                         RouterSinkProperties properties)