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.