Skip to content

Latest commit

 

History

History
33 lines (19 loc) · 1.56 KB

README.adoc

File metadata and controls

33 lines (19 loc) · 1.56 KB
Raw

Cassandra Consumer

This module provides a Cassandra Consumer that can be reused and composed in other applications. Internally it uses the CassandraMessageHandler from Spring Integration. CassandraConsumerFunction is implemented as a java.util.function.Function.

Beans for injection

The CassnadraConsumerConfiguration auto-configuration provides the following beans:

cassandraConsumerFunction

You can use cassandraConsumerFunction as a qualifier when injecting.

Type for injection: Function<Object, Mono<? extends WriteResult>>

You have to subscribe to the returned Mono to trigger a communication with Cassandra. Or use Consumer<Object> cassandraConsumer instead which ignores the result and performs just Mono.block() before returning.

Configuration Options

All configuration properties are prefixed with cassandra.consumer and cassandra.cluster.

For more information on the various options available, please see CassandraConsumerProperties. See this also.

Tests

See this test suite for the various ways, this consumer is used.

Other usage

See this README where this consumer is used to create a Spring Cloud Stream application where it makes a Cassandra sink.