Package org.springframework.cloud.fn.consumer.cassandra

Class CassandraConsumerConfiguration

java.lang.Object
org.springframework.cloud.fn.consumer.cassandra.CassandraConsumerConfiguration
@AutoConfiguration @EnableConfigurationProperties(CassandraConsumerProperties.class) @Import(CassandraAppClusterConfiguration.class) public class CassandraConsumerConfiguration extends Object
Author:
Artem Bilan, Thomas Risberg, Ashu Gairola, Akos Ratku

  • Constructor Details

    • CassandraConsumerConfiguration

      public CassandraConsumerConfiguration()

  • Method Details

    • cassandraConsumerFlow

      @Bean public org.springframework.integration.dsl.IntegrationFlow cassandraConsumerFlow(MessageHandler cassandraSinkMessageHandler, com.fasterxml.jackson.databind.ObjectMapper objectMapper)

    • cassandraSinkMessageHandler

      @Bean public MessageHandler cassandraSinkMessageHandler(org.springframework.data.cassandra.core.ReactiveCassandraOperations cassandraOperations)