Class CassandraMessageHandler

java.lang.Object

org.springframework.integration.context.IntegrationObjectSupport

org.springframework.integration.handler.MessageHandlerSupport

org.springframework.integration.handler.AbstractMessageHandler

org.springframework.integration.handler.AbstractMessageProducingHandler

org.springframework.integration.handler.AbstractReplyProducingMessageHandler

org.springframework.integration.cassandra.outbound.CassandraMessageHandler

All Implemented Interfaces:

org.reactivestreams.Subscriber<Message<?>>, Aware, BeanClassLoaderAware, BeanFactoryAware, BeanNameAware, DisposableBean, InitializingBean, ApplicationContextAware, Ordered, ExpressionCapable, Orderable, MessageProducer, HeaderPropagationAware, IntegrationPattern, NamedComponent, IntegrationManagement, TrackableComponent, MessageHandler, reactor.core.CoreSubscriber<Message<?>>

public class CassandraMessageHandler
extends AbstractReplyProducingMessageHandler

An AbstractReplyProducingMessageHandler implementation for Cassandra outbound operations.

Since:

6.0

Author:

Soby Chacko, Artem Bilan, Filippo Balicchia

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	CassandraMessageHandler.Type	The mode for the CassandraMessageHandler.

Nested classes/interfaces inherited from class org.springframework.integration.handler.AbstractReplyProducingMessageHandler

AbstractReplyProducingMessageHandler.RequestHandler

Nested classes/interfaces inherited from interface org.springframework.integration.support.management.IntegrationManagement

IntegrationManagement.ManagementOverrides

Field Summary

Fields inherited from class org.springframework.integration.handler.AbstractMessageProducingHandler

messagingTemplate

Fields inherited from class org.springframework.integration.context.IntegrationObjectSupport

EXPRESSION_PARSER, logger

Fields inherited from interface org.springframework.integration.support.management.IntegrationManagement

METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME

Fields inherited from interface org.springframework.core.Ordered

HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE

Constructor Summary

Constructors

Constructor	Description
CassandraMessageHandler(org.springframework.data.cassandra.core.ReactiveCassandraOperations cassandraOperations)
CassandraMessageHandler(org.springframework.data.cassandra.core.ReactiveCassandraOperations cassandraOperations, CassandraMessageHandler.Type queryType)

Method Summary

Modifier and Type	Method	Description
protected void	doInit()
String	getComponentType()	Subclasses may implement this method to provide component type information.
protected Object	handleRequestMessage(Message<?> requestMessage)	Subclasses must implement this method to handle the request Message.
void	setIngestQuery(String ingestQuery)
void	setParameterExpressions(Map<String,Expression> parameterExpressions)
void	setProducesReply(boolean producesReply)
void	setQuery(String query)
void	setStatementExpression(Expression statementExpression)
void	setStatementExpressionString(String statementExpression)
void	setStatementProcessor(MessageProcessor<com.datastax.oss.driver.api.core.cql.Statement<?>> statementProcessor)
void	setWriteOptions(org.springframework.data.cassandra.core.cql.WriteOptions writeOptions)

Methods inherited from class org.springframework.integration.handler.AbstractReplyProducingMessageHandler

doInvokeAdvisedRequestHandler, getBeanClassLoader, getIntegrationPatternType, getRequiresReply, handleMessageInternal, hasAdviceChain, onInit, setAdviceChain, setBeanClassLoader, setRequiresReply

Methods inherited from class org.springframework.integration.handler.AbstractMessageProducingHandler

addNotPropagatedHeaders, createOutputMessage, getNotPropagatedHeaders, getOutputChannel, isAsync, messageBuilderForReply, produceOutput, resolveErrorChannel, sendErrorMessage, sendOutput, sendOutputs, setAsync, setNotPropagatedHeaders, setOutputChannel, setOutputChannelName, setSendTimeout, setupMessageProcessor, shouldCopyRequestHeaders, shouldSplitOutput, updateNotPropagatedHeaders

Methods inherited from class org.springframework.integration.handler.AbstractMessageHandler

handleMessage, onComplete, onError, onNext, onSubscribe, setObservationConvention

Methods inherited from class org.springframework.integration.handler.MessageHandlerSupport

buildSendTimer, destroy, getManagedName, getManagedType, getMetricsCaptor, getObservationRegistry, getOrder, getOverrides, isLoggingEnabled, isObserved, registerMetricsCaptor, registerObservationRegistry, sendTimer, setLoggingEnabled, setManagedName, setManagedType, setOrder, setShouldTrack, shouldTrack

Methods inherited from class org.springframework.integration.context.IntegrationObjectSupport

afterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanDescription, getBeanFactory, getBeanName, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface reactor.core.CoreSubscriber

currentContext

Methods inherited from interface org.springframework.integration.support.management.IntegrationManagement

getThisAs

Methods inherited from interface org.springframework.integration.support.context.NamedComponent

getBeanName, getComponentName

Constructor Details

CassandraMessageHandler

public CassandraMessageHandler(org.springframework.data.cassandra.core.ReactiveCassandraOperations cassandraOperations)

CassandraMessageHandler

public CassandraMessageHandler(org.springframework.data.cassandra.core.ReactiveCassandraOperations cassandraOperations,
 CassandraMessageHandler.Type queryType)

Method Details

setIngestQuery

public void setIngestQuery(String ingestQuery)

setWriteOptions

public void setWriteOptions(org.springframework.data.cassandra.core.cql.WriteOptions writeOptions)

setProducesReply

public void setProducesReply(boolean producesReply)

setStatementExpressionString

public void setStatementExpressionString(String statementExpression)

setStatementExpression

public void setStatementExpression(Expression statementExpression)

setQuery

public void setQuery(String query)

setParameterExpressions

public void setParameterExpressions(Map<String,Expression> parameterExpressions)

setStatementProcessor

public void setStatementProcessor(MessageProcessor<com.datastax.oss.driver.api.core.cql.Statement<?>> statementProcessor)

getComponentType

public String getComponentType()

Description copied from class: IntegrationObjectSupport

Subclasses may implement this method to provide component type information.

Specified by:

getComponentType in interface NamedComponent

Overrides:

getComponentType in class MessageHandlerSupport

doInit

protected void doInit()

Overrides:

doInit in class AbstractReplyProducingMessageHandler

handleRequestMessage

protected Object handleRequestMessage(Message<?> requestMessage)

Description copied from class: AbstractReplyProducingMessageHandler

Subclasses must implement this method to handle the request Message. The return value may be a Message, a MessageBuilder, or any plain Object. The base class will handle the final creation of a reply Message from any of those starting points. If the return value is null, the Message flow will end here.

Specified by:

handleRequestMessage in class AbstractReplyProducingMessageHandler

Parameters:

requestMessage - The request message.

Returns:

The result of handling the message, or null.