Class Cassandra

java.lang.Object

org.springframework.integration.cassandra.dsl.Cassandra

public final class Cassandra
extends Object

Factory class for Apache Cassandra components DSL.

Since:

6.0

Author:

Artem Bilan

Method Summary

Modifier and Type	Method	Description
static CassandraMessageHandlerSpec	outboundChannelAdapter(org.springframework.data.cassandra.core.ReactiveCassandraOperations cassandraOperations)	Create an instance of CassandraMessageHandlerSpec for the provided ReactiveCassandraOperations.
static CassandraMessageHandlerSpec	outboundChannelAdapter(org.springframework.data.cassandra.core.ReactiveCassandraOperations cassandraOperations, CassandraMessageHandler.Type queryType)	Create an instance of CassandraMessageHandlerSpec for the provided ReactiveCassandraOperations.
static CassandraMessageHandlerSpec	outboundGateway(org.springframework.data.cassandra.core.ReactiveCassandraOperations cassandraOperations)	Create an instance of CassandraMessageHandlerSpec for the provided ReactiveCassandraOperations in an outbound gateway mode.
static CassandraMessageHandlerSpec	outboundGateway(org.springframework.data.cassandra.core.ReactiveCassandraOperations cassandraOperations, CassandraMessageHandler.Type queryType)	Create an instance of CassandraMessageHandlerSpec for the provided ReactiveCassandraOperations in an outbound gateway mode.

Methods inherited from class java.lang.Object

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

Method Details

outboundChannelAdapter

public static CassandraMessageHandlerSpec outboundChannelAdapter(org.springframework.data.cassandra.core.ReactiveCassandraOperations cassandraOperations)

Create an instance of CassandraMessageHandlerSpec for the provided ReactiveCassandraOperations.

Parameters:

cassandraOperations - the ReactiveCassandraOperations to use.

Returns:

the spec.

outboundChannelAdapter

public static CassandraMessageHandlerSpec outboundChannelAdapter(org.springframework.data.cassandra.core.ReactiveCassandraOperations cassandraOperations,
 CassandraMessageHandler.Type queryType)

Create an instance of CassandraMessageHandlerSpec for the provided ReactiveCassandraOperations.

Parameters:

cassandraOperations - the ReactiveCassandraOperations to use.

queryType - the CassandraMessageHandler.Type to use.

Returns:

the spec.

outboundGateway

public static CassandraMessageHandlerSpec outboundGateway(org.springframework.data.cassandra.core.ReactiveCassandraOperations cassandraOperations)

Create an instance of CassandraMessageHandlerSpec for the provided ReactiveCassandraOperations in an outbound gateway mode.

Parameters:

cassandraOperations - the ReactiveCassandraOperations to use.

Returns:

the spec.

outboundGateway

public static CassandraMessageHandlerSpec outboundGateway(org.springframework.data.cassandra.core.ReactiveCassandraOperations cassandraOperations,
 CassandraMessageHandler.Type queryType)

Create an instance of CassandraMessageHandlerSpec for the provided ReactiveCassandraOperations in an outbound gateway mode.

Parameters:

cassandraOperations - the ReactiveCassandraOperations to use.

queryType - the CassandraMessageHandler.Type to use.

Returns:

the spec.