public class CassandraMessageHandler<T>
extends org.springframework.integration.handler.AbstractReplyProducingMessageHandler
implements org.springframework.integration.expression.IntegrationEvaluationContextAware
| Modifier and Type | Class and Description |
|---|---|
static class |
CassandraMessageHandler.Type |
| Constructor and Description |
|---|
CassandraMessageHandler(org.springframework.data.cassandra.core.CassandraOperations cassandraTemplate) |
CassandraMessageHandler(org.springframework.data.cassandra.core.CassandraOperations cassandraTemplate,
CassandraMessageHandler.Type queryType) |
| Modifier and Type | Method and Description |
|---|---|
java.lang.String |
getComponentType() |
protected java.lang.Object |
handleRequestMessage(org.springframework.messaging.Message<?> requestMessage) |
void |
setIngestQuery(java.lang.String ingestQuery) |
void |
setIntegrationEvaluationContext(org.springframework.expression.EvaluationContext evaluationContext) |
void |
setParameterExpressions(java.util.Map<java.lang.String,org.springframework.expression.Expression> parameterExpressions) |
void |
setProducesReply(boolean producesReply) |
void |
setQuery(java.lang.String query) |
void |
setStatementExpression(org.springframework.expression.Expression statementExpression) |
void |
setStatementProcessor(org.springframework.integration.handler.MessageProcessor<com.datastax.driver.core.Statement> statementProcessor) |
void |
setWriteOptions(org.springframework.cassandra.core.WriteOptions writeOptions) |
protected boolean |
shouldSplitOutput(java.lang.Iterable<?> reply)
Always return
false to prevent a ResultSet
draining on iteration. |
doInit, doInvokeAdvisedRequestHandler, handleMessageInternal, hasAdviceChain, onInit, setAdviceChain, setBeanClassLoader, setRequiresReplygetOutputChannel, produceOutput, sendOutputs, setOutputChannel, setOutputChannelName, setSendTimeout, shouldCopyRequestHeadersgetOrder, handleMessage, setOrder, setShouldTrackafterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getConversionService, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setTaskScheduler, toStringpublic CassandraMessageHandler(org.springframework.data.cassandra.core.CassandraOperations cassandraTemplate)
public CassandraMessageHandler(org.springframework.data.cassandra.core.CassandraOperations cassandraTemplate,
CassandraMessageHandler.Type queryType)
public void setIngestQuery(java.lang.String ingestQuery)
public void setWriteOptions(org.springframework.cassandra.core.WriteOptions writeOptions)
public void setProducesReply(boolean producesReply)
public void setStatementExpression(org.springframework.expression.Expression statementExpression)
public void setQuery(java.lang.String query)
public void setParameterExpressions(java.util.Map<java.lang.String,org.springframework.expression.Expression> parameterExpressions)
public void setStatementProcessor(org.springframework.integration.handler.MessageProcessor<com.datastax.driver.core.Statement> statementProcessor)
public void setIntegrationEvaluationContext(org.springframework.expression.EvaluationContext evaluationContext)
setIntegrationEvaluationContext in interface org.springframework.integration.expression.IntegrationEvaluationContextAwarepublic java.lang.String getComponentType()
getComponentType in interface org.springframework.integration.support.context.NamedComponentgetComponentType in class org.springframework.integration.handler.AbstractMessageHandlerprotected java.lang.Object handleRequestMessage(org.springframework.messaging.Message<?> requestMessage)
handleRequestMessage in class org.springframework.integration.handler.AbstractReplyProducingMessageHandlerprotected boolean shouldSplitOutput(java.lang.Iterable<?> reply)
false to prevent a ResultSet
draining on iteration.shouldSplitOutput in class org.springframework.integration.handler.AbstractMessageProducingHandlerreply - ignored.false.