public class CassandraMessageHandler
extends org.springframework.integration.handler.AbstractReplyProducingMessageHandler
AbstractReplyProducingMessageHandler implementation for Cassandra outbound operations.| Modifier and Type | Class and Description |
|---|---|
static class |
CassandraMessageHandler.Type
The mode for the
CassandraMessageHandler. |
messagingTemplateEXPRESSION_PARSER, logger| Constructor and Description |
|---|
CassandraMessageHandler(org.springframework.data.cassandra.core.ReactiveCassandraOperations cassandraOperations) |
CassandraMessageHandler(org.springframework.data.cassandra.core.ReactiveCassandraOperations cassandraOperations,
CassandraMessageHandler.Type queryType) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
doInit() |
java.lang.String |
getComponentType() |
protected java.lang.Object |
handleRequestMessage(org.springframework.messaging.Message<?> requestMessage) |
void |
setIngestQuery(java.lang.String ingestQuery) |
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 |
setStatementExpressionString(java.lang.String statementExpression) |
void |
setStatementProcessor(org.springframework.integration.handler.MessageProcessor<com.datastax.oss.driver.api.core.cql.Statement<?>> statementProcessor) |
void |
setWriteOptions(org.springframework.data.cassandra.core.cql.WriteOptions writeOptions) |
doInvokeAdvisedRequestHandler, getBeanClassLoader, getIntegrationPatternType, getRequiresReply, handleMessageInternal, hasAdviceChain, onInit, setAdviceChain, setBeanClassLoader, setRequiresReplyaddNotPropagatedHeaders, createOutputMessage, getNotPropagatedHeaders, getOutputChannel, isAsync, messageBuilderForReply, produceOutput, resolveErrorChannel, sendErrorMessage, sendOutput, sendOutputs, setAsync, setNotPropagatedHeaders, setOutputChannel, setOutputChannelName, setSendTimeout, shouldCopyRequestHeaders, shouldSplitOutput, updateNotPropagatedHeadershandleMessage, onComplete, onError, onNext, onSubscribebuildSendTimer, configureMetrics, destroy, getActiveCount, getActiveCountLong, getDuration, getErrorCount, getErrorCountLong, getHandleCount, getHandleCountLong, getHandlerMetrics, getManagedName, getManagedType, getMaxDuration, getMeanDuration, getMetricsCaptor, getMinDuration, getOrder, getOverrides, getStandardDeviationDuration, isCountsEnabled, isLoggingEnabled, isStatsEnabled, registerMetricsCaptor, reset, sendTimer, setCountsEnabled, setLoggingEnabled, setManagedName, setManagedType, setOrder, setShouldTrack, setStatsEnabled, shouldTrackafterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanDescription, getBeanFactory, getBeanName, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toStringclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitpublic CassandraMessageHandler(org.springframework.data.cassandra.core.ReactiveCassandraOperations cassandraOperations)
public CassandraMessageHandler(org.springframework.data.cassandra.core.ReactiveCassandraOperations cassandraOperations,
CassandraMessageHandler.Type queryType)
public void setIngestQuery(java.lang.String ingestQuery)
public void setWriteOptions(org.springframework.data.cassandra.core.cql.WriteOptions writeOptions)
public void setProducesReply(boolean producesReply)
public void setStatementExpressionString(java.lang.String statementExpression)
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.oss.driver.api.core.cql.Statement<?>> statementProcessor)
public java.lang.String getComponentType()
getComponentType in interface org.springframework.integration.support.context.NamedComponentgetComponentType in class org.springframework.integration.handler.MessageHandlerSupportprotected void doInit()
doInit in class org.springframework.integration.handler.AbstractReplyProducingMessageHandlerprotected java.lang.Object handleRequestMessage(org.springframework.messaging.Message<?> requestMessage)
handleRequestMessage in class org.springframework.integration.handler.AbstractReplyProducingMessageHandler