Package | Description |
---|---|
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 |
Client API : Topics.
|
Modifier and Type | Method and Description |
---|---|
<V> void |
Topics.addStream(TopicSelector topics,
Class<? extends V> valueClass,
Topics.ValueStream<V> stream)
Add a value stream to receive topic events for topics that match a given
TopicSelector and have a value class that matches a specified
type. |
<V> void |
Topics.addTimeSeriesStream(TopicSelector topics,
Class<? extends V> eventValueClass,
Topics.ValueStream<TimeSeries.Event<V>> stream)
Add a value stream to receive topic events for time series topics that
match a given
TopicSelector and have a compatible time series
event value class. |
CompletableFuture<Topics.FetchResult<V>> |
Topics.FetchRequest.fetch(TopicSelector topics)
Sends a fetch request to the server.
|
CompletableFuture<?> |
Topics.subscribe(TopicSelector topics)
Request subscription to topics.
|
<C> void |
Topics.subscribe(TopicSelector topics,
C context,
Topics.CompletionContextCallback<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 |
Topics.subscribe(TopicSelector topics,
Topics.CompletionCallback callback)
Deprecated.
since 6.7
Methods that use callbacks are deprecated and will be removed in a future release. Use CompletableFuture variant instead. |
CompletableFuture<?> |
Topics.unsubscribe(TopicSelector topics)
Unsubscribe from topics.
|
<C> void |
Topics.unsubscribe(TopicSelector topics,
C context,
Topics.CompletionContextCallback<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 |
Topics.unsubscribe(TopicSelector topics,
Topics.CompletionCallback callback)
Deprecated.
since 6.7
Methods that use callbacks are deprecated and will be removed in a future release. Use CompletableFuture variant instead. |
Modifier and Type | Method and Description |
---|---|
TopicSelector |
TopicControl.MissingTopicNotification.getTopicSelector()
Returns the
TopicSelector that triggered this notification. |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<?> |
TopicNotifications.NotificationRegistration.deselect(TopicSelector selector)
Request to stop receiving notifications for all topics matched by the
given selector.
|
CompletableFuture<TopicControl.TopicRemovalResult> |
TopicControl.removeTopics(TopicSelector topicSelector)
Send a request to remove one or more topics.
|
CompletableFuture<?> |
TopicNotifications.NotificationRegistration.select(TopicSelector selector)
Request to receive notifications for all topics matched by the
provided topic selector.
|
CompletableFuture<?> |
SubscriptionControl.subscribe(SessionId sessionId,
TopicSelector topics)
Subscribe another session to topics.
|
<C> void |
SubscriptionControl.subscribe(SessionId sessionId,
TopicSelector topics,
C context,
SubscriptionControl.SubscriptionContextCallback<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 |
SubscriptionControl.subscribe(SessionId sessionId,
TopicSelector topics,
SubscriptionControl.SubscriptionCallback callback)
Deprecated.
since 6.7
Methods that use callbacks are deprecated and will be removed in a future release. Use CompletableFuture variant instead. |
CompletableFuture<SubscriptionControl.SubscriptionByFilterResult> |
SubscriptionControl.subscribeByFilter(String filter,
TopicSelector topics)
Subscribe sessions that satisfy a given session filter to topics.
|
<C> void |
SubscriptionControl.subscribeByFilter(String filter,
TopicSelector topics,
C context,
SubscriptionControl.SubscriptionByFilterContextCallback<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 |
SubscriptionControl.subscribeByFilter(String filter,
TopicSelector topics,
SubscriptionControl.SubscriptionByFilterCallback callback)
Deprecated.
since 6.7
Methods that use callbacks are deprecated and will be removed in a future release. Use CompletableFuture variant instead. |
CompletableFuture<?> |
SubscriptionControl.unsubscribe(SessionId sessionId,
TopicSelector topics)
Unsubscribe another session from topics.
|
<C> void |
SubscriptionControl.unsubscribe(SessionId sessionId,
TopicSelector topics,
C context,
SubscriptionControl.SubscriptionContextCallback<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 |
SubscriptionControl.unsubscribe(SessionId sessionId,
TopicSelector topics,
SubscriptionControl.SubscriptionCallback callback)
Deprecated.
since 6.7
Methods that use callbacks are deprecated and will be removed in a future release. Use CompletableFuture variant instead. |
CompletableFuture<SubscriptionControl.SubscriptionByFilterResult> |
SubscriptionControl.unsubscribeByFilter(String filter,
TopicSelector topics)
Unsubscribe sessions that satisfy a given session filter from topics.
|
<C> void |
SubscriptionControl.unsubscribeByFilter(String filter,
TopicSelector topics,
C context,
SubscriptionControl.SubscriptionByFilterContextCallback<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 |
SubscriptionControl.unsubscribeByFilter(String filter,
TopicSelector topics,
SubscriptionControl.SubscriptionByFilterCallback callback)
Deprecated.
since 6.7
Methods that use callbacks are deprecated and will be removed in a future release. Use CompletableFuture variant instead. |
Modifier and Type | Interface and Description |
---|---|
interface |
TopicPathSelector
A selector that selects a single topic path.
|
Modifier and Type | Method and Description |
---|---|
TopicSelector |
TopicSelectors.anyOf(String... expressions)
Convenient wrapper of
TopicSelectors.anyOf(TopicSelector...) that first parses
the supplied expressions to create selectors. |
TopicSelector |
TopicSelectors.anyOf(TopicSelector... selectors)
Create a
SELECTOR_SET selector that matches if any of the
provided selectors match. |
TopicSelector |
TopicSelectors.parse(String expression)
Parse an expression to create a selector.
|
Modifier and Type | Method and Description |
---|---|
TopicSelector |
TopicSelectors.anyOf(TopicSelector... selectors)
Create a
SELECTOR_SET selector that matches if any of the
provided selectors match. |
Copyright © 2024 DiffusionData Ltd. All Rights Reserved.