Package | Description |
---|---|
com.pushtechnology.diffusion.client |
Client API.
|
com.pushtechnology.diffusion.client.features |
Client API : Standard Features.
|
com.pushtechnology.diffusion.client.features.control.topics |
Client API : Topic Control Features.
|
com.pushtechnology.diffusion.client.topics.details |
Client API : Topic Specifications.
|
Modifier and Type | Method and Description |
---|---|
static TopicSpecification |
Diffusion.newTopicSpecification(TopicType topicType)
Create a new
TopicSpecification for a given topic type. |
TopicSpecification |
Diffusion.Implementation.newTopicSpecification(TopicType topicType) |
Modifier and Type | Method and Description |
---|---|
TopicSpecification |
Topics.FetchResult.TopicResult.specification()
Returns the topic specification.
|
Modifier and Type | Method and Description |
---|---|
<T> CompletableFuture<TopicCreationResult> |
TopicUpdate.addAndSet(String path,
TopicSpecification specification,
Class<T> valueClass,
T value)
Ensures a topic exists and sets its value.
|
<T> CompletableFuture<TopicCreationResult> |
TopicUpdate.addAndSet(String path,
TopicSpecification specification,
Class<T> valueClass,
T value,
UpdateConstraint constraint)
Ensures a topic exists and sets its value.
|
<T> UpdateStream<T> |
TopicUpdate.createUpdateStream(String path,
TopicSpecification specification,
Class<T> valueClass)
Deprecated.
since 6.9
|
<T> UpdateStream<T> |
TopicUpdate.createUpdateStream(String path,
TopicSpecification specification,
Class<T> valueClass,
UpdateConstraint constraint)
Deprecated.
since 6.9
|
void |
Topics.SubscriberStream.onSubscription(String topicPath,
TopicSpecification specification)
Subscription notification.
|
void |
Topics.SubscriberStream.Default.onSubscription(String topicPath,
TopicSpecification specification) |
void |
Topics.SubscriberStream.onUnsubscription(String topicPath,
TopicSpecification specification,
Topics.UnsubscribeReason reason)
Unsubscription notification.
|
void |
Topics.SubscriberStream.Default.onUnsubscription(String topicPath,
TopicSpecification specification,
Topics.UnsubscribeReason reason) |
void |
Topics.ValueStream.onValue(String topicPath,
TopicSpecification specification,
V oldValue,
V newValue)
Notifies an update to a topic value from the server.
|
void |
Topics.ValueStream.Default.onValue(String topicPath,
TopicSpecification specification,
V oldValue,
V newValue) |
UpdateStream.Builder |
UpdateStream.Builder.specification(TopicSpecification topicSpecification)
Specifies a TopicSpecification for this update stream.
|
Modifier and Type | Method and Description |
---|---|
TopicSpecification |
TopicControl.newSpecification(TopicType topicType)
Deprecated.
since 6.7
Use
|
Modifier and Type | Method and Description |
---|---|
CompletableFuture<TopicControl.AddTopicResult> |
TopicControl.addTopic(String topicPath,
TopicSpecification specification)
Request creation of a topic.
|
<C> void |
TopicControl.addTopic(String topicPath,
TopicSpecification specification,
C context,
TopicControl.AddContextCallback<C> callback)
Deprecated.
since 6.7
Methods that use callbacks are deprecated and will be removed in a future release. Use CompletableFuture variant instead. |
void |
TopicControl.addTopic(String topicPath,
TopicSpecification specification,
TopicControl.AddCallback callback)
Deprecated.
since 6.7
Methods that use callbacks are deprecated and will be removed in a future release. Use CompletableFuture variant instead. |
void |
TopicNotifications.TopicNotificationListener.onTopicNotification(String topicPath,
TopicSpecification specification,
TopicNotifications.TopicNotificationListener.NotificationType type)
A notification for a selected topic.
|
void |
TopicNotifications.TopicNotificationListener.Default.onTopicNotification(String topicPath,
TopicSpecification specification,
TopicNotifications.TopicNotificationListener.NotificationType type) |
Modifier and Type | Method and Description |
---|---|
TopicSpecification |
TopicSpecification.withoutProperties(String... propertyNames)
Returns a new specification that does not have the specified properties.
|
TopicSpecification |
TopicSpecification.withProperties(Map<String,String> properties)
Creates a new specification with the specified properties.
|
TopicSpecification |
TopicSpecification.withProperty(String key,
String value)
Creates a new specification with the specified property value set.
|
Copyright © 2024 DiffusionData Ltd. All Rights Reserved.