Class CassandraMessageHandlerSpec
java.lang.Object
org.springframework.beans.factory.config.AbstractFactoryBean<T>
org.springframework.integration.dsl.IntegrationComponentSpec<S,H>
org.springframework.integration.dsl.MessageHandlerSpec<CassandraMessageHandlerSpec,CassandraMessageHandler>
org.springframework.integration.cassandra.dsl.CassandraMessageHandlerSpec
- All Implemented Interfaces:
Aware
,BeanClassLoaderAware
,BeanFactoryAware
,DisposableBean
,FactoryBean<CassandraMessageHandler>
,InitializingBean
,Lifecycle
,Phased
,SmartLifecycle
public class CassandraMessageHandlerSpec
extends MessageHandlerSpec<CassandraMessageHandlerSpec,CassandraMessageHandler>
- Since:
- 6.0
- Author:
- Artem Bilan
-
Field Summary
Fields inherited from class org.springframework.integration.dsl.IntegrationComponentSpec
PARSER, target
Fields inherited from class org.springframework.beans.factory.config.AbstractFactoryBean
logger
Fields inherited from interface org.springframework.beans.factory.FactoryBean
OBJECT_TYPE_ATTRIBUTE
Fields inherited from interface org.springframework.context.SmartLifecycle
DEFAULT_PHASE
-
Constructor Summary
ModifierConstructorDescriptionprotected
CassandraMessageHandlerSpec
(org.springframework.data.cassandra.core.ReactiveCassandraOperations cassandraOperations) protected
CassandraMessageHandlerSpec
(org.springframework.data.cassandra.core.ReactiveCassandraOperations cassandraOperations, CassandraMessageHandler.Type queryType) -
Method Summary
Modifier and TypeMethodDescriptioningestQuery
(String ingestQuery) Set an ingest query.Add a named bindable parameter with a SpEL expression to evaluate its value against a request message.Add a named bindable parameter with a function to evaluate its value against a request message.parameter
(String name, Expression expression) Add a named bindable parameter with a SpEL expression to evaluate its value against a request message.parameterExpressions
(Map<String, Expression> parameterExpressions) Set a map for named parameters and expressions for their values against a request message.protected CassandraMessageHandlerSpec
producesReply
(boolean producesReply) Set aSELECT
query.statementExpression
(String statementExpression) Set a SpEL expression to evaluate aStatement
against request message.statementExpression
(Expression statementExpression) Set a SpEL expression to evaluate aStatement
against request message.statementFunction
(Function<Message<?>, com.datastax.oss.driver.api.core.cql.Statement<?>> statementFunction) Set aFunction
to evaluate aStatement
against request message.writeOptions
(org.springframework.data.cassandra.core.cql.WriteOptions writeOptions) Set aWriteOptions
forINSERT
,UPDATE
orDELETE
operations.Methods inherited from class org.springframework.integration.dsl.IntegrationComponentSpec
_this, createInstance, destroyInstance, doGet, get, getId, getObjectType, getPhase, id, isAutoStartup, isRunning, start, stop, stop
Methods inherited from class org.springframework.beans.factory.config.AbstractFactoryBean
afterPropertiesSet, destroy, getBeanFactory, getBeanTypeConverter, getEarlySingletonInterfaces, getObject, isSingleton, setBeanClassLoader, setBeanFactory, setSingleton
-
Constructor Details
-
CassandraMessageHandlerSpec
protected CassandraMessageHandlerSpec(org.springframework.data.cassandra.core.ReactiveCassandraOperations cassandraOperations) -
CassandraMessageHandlerSpec
protected CassandraMessageHandlerSpec(org.springframework.data.cassandra.core.ReactiveCassandraOperations cassandraOperations, CassandraMessageHandler.Type queryType)
-
-
Method Details
-
producesReply
-
ingestQuery
Set an ingest query.- Parameters:
ingestQuery
- ingest query to use.- Returns:
- this spec
-
writeOptions
public CassandraMessageHandlerSpec writeOptions(org.springframework.data.cassandra.core.cql.WriteOptions writeOptions) Set aWriteOptions
forINSERT
,UPDATE
orDELETE
operations.- Parameters:
writeOptions
- theWriteOptions
to use.- Returns:
- this spec
-
statementExpression
Set a SpEL expression to evaluate aStatement
against request message.- Parameters:
statementExpression
- the SpEL expression to use.- Returns:
- this spec
-
statementExpression
Set a SpEL expression to evaluate aStatement
against request message.- Parameters:
statementExpression
- the SpEL expression to use.- Returns:
- this spec
-
statementFunction
public CassandraMessageHandlerSpec statementFunction(Function<Message<?>, com.datastax.oss.driver.api.core.cql.Statement<?>> statementFunction) Set aFunction
to evaluate aStatement
against request message.- Parameters:
statementFunction
- the function to use.- Returns:
- this spec
-
query
Set aSELECT
query.- Parameters:
query
- the CQL query to execute- Returns:
- this spec
-
parameterExpressions
public CassandraMessageHandlerSpec parameterExpressions(Map<String, Expression> parameterExpressions) Set a map for named parameters and expressions for their values against a request message.- Parameters:
parameterExpressions
- the map to use.- Returns:
- this spec
-
parameter
Add a named bindable parameter with a SpEL expression to evaluate its value against a request message.- Parameters:
name
- the name of parameter.expression
- the SpEL expression for parameter value.- Returns:
- this spec
-
parameter
Add a named bindable parameter with a function to evaluate its value against a request message.- Parameters:
name
- the name of parameter.function
- the function for parameter value.- Returns:
- this spec
-
parameter
Add a named bindable parameter with a SpEL expression to evaluate its value against a request message.- Parameters:
name
- the name of parameter.expression
- the SpEL expression for parameter value.- Returns:
- this spec
-