org.springframework.cloud.stream.app.cassandra.sink

Class CassandraSinkProperties

java.lang.Object

org.springframework.cloud.stream.app.cassandra.sink.CassandraSinkProperties

@ConfigurationProperties(value="cassandra")
public class CassandraSinkProperties
extends Object

Author:

Artem Bilan, Thomas Risberg

Constructor Summary

Constructors

Constructor and Description
CassandraSinkProperties()

Method Summary

Modifier and Type	Method and Description
org.springframework.cassandra.core.ConsistencyLevel	getConsistencyLevel()
String	getIngestQuery()
org.springframework.integration.cassandra.outbound.CassandraMessageHandler.Type	getQueryType()
org.springframework.cassandra.core.RetryPolicy	getRetryPolicy()
org.springframework.expression.Expression	getStatementExpression()
int	getTtl()
void	setConsistencyLevel(org.springframework.cassandra.core.ConsistencyLevel consistencyLevel)
void	setIngestQuery(String ingestQuery)
void	setQueryType(org.springframework.integration.cassandra.outbound.CassandraMessageHandler.Type queryType)
void	setRetryPolicy(org.springframework.cassandra.core.RetryPolicy retryPolicy)
void	setStatementExpression(org.springframework.expression.Expression statementExpression)
void	setTtl(int ttl)

Methods inherited from class java.lang.Object

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

Constructor Detail

CassandraSinkProperties

public CassandraSinkProperties()

Method Detail

getConsistencyLevel

public org.springframework.cassandra.core.ConsistencyLevel getConsistencyLevel()

setConsistencyLevel

public void setConsistencyLevel(org.springframework.cassandra.core.ConsistencyLevel consistencyLevel)

getRetryPolicy

public org.springframework.cassandra.core.RetryPolicy getRetryPolicy()

setRetryPolicy

public void setRetryPolicy(org.springframework.cassandra.core.RetryPolicy retryPolicy)

getTtl

public int getTtl()

setTtl

public void setTtl(int ttl)

getQueryType

public org.springframework.integration.cassandra.outbound.CassandraMessageHandler.Type getQueryType()

setQueryType

public void setQueryType(org.springframework.integration.cassandra.outbound.CassandraMessageHandler.Type queryType)

getIngestQuery

public String getIngestQuery()

setIngestQuery

public void setIngestQuery(String ingestQuery)

getStatementExpression

public org.springframework.expression.Expression getStatementExpression()

setStatementExpression

public void setStatementExpression(org.springframework.expression.Expression statementExpression)