@Configuration @EnableIntegration @Import(value=CassandraConfiguration.class) public class CassandraSinkConfiguration extends java.lang.Object
修飾子と型 | フィールドと説明 |
---|---|
org.springframework.data.cassandra.core.CassandraOperations | template |
コンストラクターと説明 |
---|
CassandraSinkConfiguration() |
修飾子と型 | メソッドと説明 |
---|---|
org.springframework.messaging.MessageHandler | cassandraSinkMessageHandler() |
org.springframework.messaging.MessageChannel | input() |
org.springframework.messaging.MessageChannel | toSink() |
org.springframework.messaging.MessageHandler | toSinkBridgeMessageHandler() |
@Autowired public org.springframework.data.cassandra.core.CassandraOperations template
@Bean public org.springframework.messaging.MessageChannel input()
@Bean public org.springframework.messaging.MessageChannel toSink()
@Bean @ServiceActivator(inputChannel="input") public org.springframework.messaging.MessageHandler toSinkBridgeMessageHandler()
@Bean @ServiceActivator(inputChannel="toSink") public org.springframework.messaging.MessageHandler cassandraSinkMessageHandler()