org.springframework.xd.cassandra

Class CassandraSinkConfiguration

java.lang.Object

org.springframework.xd.cassandra.CassandraSinkConfiguration

@Configuration
@EnableIntegration
@Import(value=CassandraConfiguration.class)
public class CassandraSinkConfiguration
extends java.lang.Object

Author:

Artem Bilan

Field Summary

Fields

Modifier and Type	Field and Description
org.springframework.data.cassandra.core.CassandraOperations	template

Constructor Summary

Constructors

Constructor and Description
CassandraSinkConfiguration()

Method Summary

Methods

Modifier and Type	Method and Description
org.springframework.messaging.MessageHandler	cassandraSinkMessageHandler()
org.springframework.messaging.MessageChannel	input()
org.springframework.messaging.MessageChannel	toSink()
org.springframework.messaging.MessageHandler	toSinkBridgeMessageHandler()

Methods inherited from class java.lang.Object

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

Field Detail

template

@Autowired
public org.springframework.data.cassandra.core.CassandraOperations template

Constructor Detail

CassandraSinkConfiguration

public CassandraSinkConfiguration()

Method Detail

input

@Bean
public org.springframework.messaging.MessageChannel input()

toSink

@Bean
public org.springframework.messaging.MessageChannel toSink()

toSinkBridgeMessageHandler

@Bean
@ServiceActivator(inputChannel="input")
public org.springframework.messaging.MessageHandler toSinkBridgeMessageHandler()

cassandraSinkMessageHandler

@Bean
@ServiceActivator(inputChannel="toSink")
public org.springframework.messaging.MessageHandler cassandraSinkMessageHandler()