| Package | Description | 
|---|---|
| com.diffusiondata.gateway.framework | 
 Diffusion Gateway Framework API. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
TopicProperties | 
CustomPublisher.getConfiguredTopicProperties()  | 
TopicProperties | 
Publisher.getConfiguredTopicProperties()
Returns a  
TopicProperties with user-configured or default
 topic properties for the service. | 
TopicProperties | 
UpdateContext.getTopicProperties()
Returns the topic properties that would have been used for the Diffusion
 topic. 
 | 
TopicProperties | 
TopicProperties.withDontRetainValue(boolean dontRetainValue)
Returns a new instance of TopicProperties with the supplied boolean value to
 specify whether a topic should not retain its last value. 
 | 
TopicProperties | 
TopicProperties.withPersistencePolicy(TopicProperties.PersistencePolicy persistencePolicy)
Returns a new instance of TopicProperties with the supplied PersistencePolicy
 and other existing properties. 
 | 
TopicProperties | 
TopicProperties.withPublishValuesOnly(boolean publishValuesOnly)
Returns a new instance of TopicProperties with the supplied boolean value to
 specify whether a topic should publish only values. 
 | 
TopicProperties | 
TopicProperties.withTimeSeries(boolean isTimeSeries)
Returns a new instance of TopicProperties with the supplied boolean value to
 specify if the topic is time series and other existing properties. 
 | 
TopicProperties | 
TopicProperties.withTimeSeriesRetainedRange(String timeSeriesRetainedRange)
Returns a new instance of TopicProperties with the supplied
 timeSeriesRetainedRange and other existing properties. 
 | 
TopicProperties | 
TopicProperties.withTimeSeriesSubscriptionRange(String timeSeriesSubscriptionRange)
Returns a new instance of TopicProperties with the supplied
 timeSeriesSubscriptionRange and other existing properties. 
 | 
TopicProperties | 
TopicProperties.withTopicType(TopicType topicType)
Returns a new instance of TopicProperties with the supplied topic type and
 other existing properties. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
default CompletableFuture<?> | 
SinkHandler.onSubscription(String topicPath,
              TopicProperties topicProperties)
Called when the sink service is subscribed to a Diffusion topic. 
 | 
default CompletableFuture<?> | 
SinkHandler.onUnsubscription(String topicPath,
                TopicProperties topicProperties,
                SinkHandler.UnsubscriptionReason reason)
Called when the sink service is unsubscribed from a Diffusion topic. 
 | 
CompletableFuture<?> | 
CustomPublisher.publish(String path,
       Object value,
       TopicProperties topicProperties)  | 
CompletableFuture<?> | 
Publisher.publish(String path,
       Object value,
       TopicProperties topicProperties)
Publishes a new value to Diffusion. 
 | 
CompletableFuture<?> | 
SinkHandler.update(String path,
      T value,
      TopicProperties topicProperties)
Called by the framework to publish a new value received from Diffusion to
 the sink. 
 | 
Copyright © 2024 DiffusionData Limited. All rights reserved.