Class Cassandra
java.lang.Object
org.springframework.integration.cassandra.dsl.Cassandra
Factory class for Apache Cassandra components DSL.
- Since:
- 6.0
- Author:
- Artem Bilan
-
Method Summary
Modifier and TypeMethodDescriptionstatic CassandraMessageHandlerSpec
outboundChannelAdapter
(org.springframework.data.cassandra.core.ReactiveCassandraOperations cassandraOperations) Create an instance ofCassandraMessageHandlerSpec
for the providedReactiveCassandraOperations
.static CassandraMessageHandlerSpec
outboundChannelAdapter
(org.springframework.data.cassandra.core.ReactiveCassandraOperations cassandraOperations, CassandraMessageHandler.Type queryType) Create an instance ofCassandraMessageHandlerSpec
for the providedReactiveCassandraOperations
.static CassandraMessageHandlerSpec
outboundGateway
(org.springframework.data.cassandra.core.ReactiveCassandraOperations cassandraOperations) Create an instance ofCassandraMessageHandlerSpec
for the providedReactiveCassandraOperations
in an outbound gateway mode.static CassandraMessageHandlerSpec
outboundGateway
(org.springframework.data.cassandra.core.ReactiveCassandraOperations cassandraOperations, CassandraMessageHandler.Type queryType) Create an instance ofCassandraMessageHandlerSpec
for the providedReactiveCassandraOperations
in an outbound gateway mode.
-
Method Details
-
outboundChannelAdapter
public static CassandraMessageHandlerSpec outboundChannelAdapter(org.springframework.data.cassandra.core.ReactiveCassandraOperations cassandraOperations) Create an instance ofCassandraMessageHandlerSpec
for the providedReactiveCassandraOperations
.- Parameters:
cassandraOperations
- theReactiveCassandraOperations
to use.- Returns:
- the spec.
-
outboundChannelAdapter
public static CassandraMessageHandlerSpec outboundChannelAdapter(org.springframework.data.cassandra.core.ReactiveCassandraOperations cassandraOperations, CassandraMessageHandler.Type queryType) Create an instance ofCassandraMessageHandlerSpec
for the providedReactiveCassandraOperations
.- Parameters:
cassandraOperations
- theReactiveCassandraOperations
to use.queryType
- theCassandraMessageHandler.Type
to use.- Returns:
- the spec.
-
outboundGateway
public static CassandraMessageHandlerSpec outboundGateway(org.springframework.data.cassandra.core.ReactiveCassandraOperations cassandraOperations) Create an instance ofCassandraMessageHandlerSpec
for the providedReactiveCassandraOperations
in an outbound gateway mode.- Parameters:
cassandraOperations
- theReactiveCassandraOperations
to use.- Returns:
- the spec.
-
outboundGateway
public static CassandraMessageHandlerSpec outboundGateway(org.springframework.data.cassandra.core.ReactiveCassandraOperations cassandraOperations, CassandraMessageHandler.Type queryType) Create an instance ofCassandraMessageHandlerSpec
for the providedReactiveCassandraOperations
in an outbound gateway mode.- Parameters:
cassandraOperations
- theReactiveCassandraOperations
to use.queryType
- theCassandraMessageHandler.Type
to use.- Returns:
- the spec.
-