org.springframework.cloud.fn.supplier.geode

Class GeodeSupplierConfiguration

java.lang.Object

org.springframework.cloud.fn.supplier.geode.GeodeSupplierConfiguration

@Import(value=GeodeClientRegionConfiguration.class)
 @Configuration
 @PropertySource(value="classpath:geode-client.properties")
 @EnableConfigurationProperties(value=GeodeSupplierProperties.class)
public class GeodeSupplierConfiguration
extends Object

The Geode Supplier which publishes a message for each event matching the criteria for a configured Region. If a query is provided, this will use a ContinuousQueryMessageProducer to publish CqEvents that match the query selection criteria. If no query is provided, this will use a CacheListeningMessageProducer to publsh EntryEvents. A SpEl Expression, given by the property 'eventExpression' is evaluated to extract desired information from the payload. The default expression is 'newValue' which returns the current object value. This may not be ideal for every use case especially if it does not provide the key value. The key is referenced by the field 'key'. If the cached key and value types are primitives, an simple expression like "key + ':' + newValue" will work. Additional available depend on the specific event type. More complex transformations, such as Json, will require customization. To access the original object, set 'entryExpression' to '#root' or "#this'. This converts payloads of type PdxInstance, which Geode uses to store JSON content (the type of 'newValue' for instance), to a JSON String.

Author:

David Turanski

Constructor Summary

Constructors

Constructor and Description
GeodeSupplierConfiguration()

Method Summary

Modifier and Type	Method and Description
org.springframework.data.gemfire.client.Interest<?>	allKeysInterest()
org.springframework.integration.core.MessageProducer	cacheListeningMessageProducer(org.springframework.messaging.MessageChannel routerChannel, GeodeSupplierProperties properties, org.apache.geode.cache.Region<?,?> region)
Supplier<reactor.core.publisher.Flux<?>>	geodeSupplier()

Methods inherited from class java.lang.Object

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

Constructor Detail

GeodeSupplierConfiguration

public GeodeSupplierConfiguration()

Method Detail

geodeSupplier

@Bean
public Supplier<reactor.core.publisher.Flux<?>> geodeSupplier()

allKeysInterest

@ConditionalOnMissingBean(value=org.springframework.data.gemfire.client.Interest.class)
 @Bean
public org.springframework.data.gemfire.client.Interest<?> allKeysInterest()

cacheListeningMessageProducer

@Bean
 @Conditional(value=org.springframework.cloud.fn.supplier.geode.GeodeSupplierConfiguration.CQNotEnabled.class)
public org.springframework.integration.core.MessageProducer cacheListeningMessageProducer(org.springframework.messaging.MessageChannel routerChannel,
                                                                                                                                                                                                               GeodeSupplierProperties properties,
                                                                                                                                                                                                               org.apache.geode.cache.Region<?,?> region)