Uses of Class
org.springframework.integration.cassandra.dsl.CassandraMessageHandlerSpec

Packages that use CassandraMessageHandlerSpec

Package	Description
org.springframework.integration.cassandra.dsl	Provides Apache Cassandra Components support for the Java DSL.

Uses of CassandraMessageHandlerSpec in org.springframework.integration.cassandra.dsl

Methods in org.springframework.integration.cassandra.dsl that return CassandraMessageHandlerSpec

Modifier and Type	Method	Description
CassandraMessageHandlerSpec	CassandraMessageHandlerSpec.ingestQuery(String ingestQuery)	Set an ingest query.
static CassandraMessageHandlerSpec	Cassandra.outboundChannelAdapter(org.springframework.data.cassandra.core.ReactiveCassandraOperations cassandraOperations)	Create an instance of CassandraMessageHandlerSpec for the provided ReactiveCassandraOperations.
static CassandraMessageHandlerSpec	Cassandra.outboundChannelAdapter(org.springframework.data.cassandra.core.ReactiveCassandraOperations cassandraOperations, CassandraMessageHandler.Type queryType)	Create an instance of CassandraMessageHandlerSpec for the provided ReactiveCassandraOperations.
static CassandraMessageHandlerSpec	Cassandra.outboundGateway(org.springframework.data.cassandra.core.ReactiveCassandraOperations cassandraOperations)	Create an instance of CassandraMessageHandlerSpec for the provided ReactiveCassandraOperations in an outbound gateway mode.
static CassandraMessageHandlerSpec	Cassandra.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.
CassandraMessageHandlerSpec	CassandraMessageHandlerSpec.parameter(String name, String expression)	Add a named bindable parameter with a SpEL expression to evaluate its value against a request message.
CassandraMessageHandlerSpec	CassandraMessageHandlerSpec.parameter(String name, Function<Message<?>,?> function)	Add a named bindable parameter with a function to evaluate its value against a request message.
CassandraMessageHandlerSpec	CassandraMessageHandlerSpec.parameter(String name, Expression expression)	Add a named bindable parameter with a SpEL expression to evaluate its value against a request message.
CassandraMessageHandlerSpec	CassandraMessageHandlerSpec.parameterExpressions(Map<String,Expression> parameterExpressions)	Set a map for named parameters and expressions for their values against a request message.
protected CassandraMessageHandlerSpec	CassandraMessageHandlerSpec.producesReply(boolean producesReply)
CassandraMessageHandlerSpec	CassandraMessageHandlerSpec.query(String query)	Set a SELECT query.
CassandraMessageHandlerSpec	CassandraMessageHandlerSpec.statementExpression(String statementExpression)	Set a SpEL expression to evaluate a Statement against request message.
CassandraMessageHandlerSpec	CassandraMessageHandlerSpec.statementExpression(Expression statementExpression)	Set a SpEL expression to evaluate a Statement against request message.
CassandraMessageHandlerSpec	CassandraMessageHandlerSpec.statementFunction(Function<Message<?>,com.datastax.oss.driver.api.core.cql.Statement<?>> statementFunction)	Set a Function to evaluate a Statement against request message.
CassandraMessageHandlerSpec	CassandraMessageHandlerSpec.writeOptions(org.springframework.data.cassandra.core.cql.WriteOptions writeOptions)	Set a WriteOptions for INSERT, UPDATE or DELETE operations.