Package | Description |
---|---|
com.pushtechnology.diffusion.client.features |
Unified API - Standard Client Features.
|
com.pushtechnology.diffusion.client.features.control.topics |
Unified API - Topic Control Features.
|
com.pushtechnology.diffusion.client.topics |
Unified API - Topics.
|
Modifier and Type | Method and Description |
---|---|
void |
Messaging.addMessageStream(TopicSelector topics,
Messaging.MessageStream stream)
Adds a message stream for messages received from the server on topics
that match a given
TopicSelector . |
<V> void |
Topics.addStream(TopicSelector topics,
Class<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 type that matches a specified
type. |
void |
Topics.addTopicStream(TopicSelector topics,
Topics.TopicStream stream)
Add a topic stream to receive topic events for all topics that match a
given
TopicSelector . |
<C> void |
Topics.fetch(TopicSelector topics,
C context,
Topics.FetchContextStream<C> callback)
Fetch the current state of topics.
|
void |
Topics.fetch(TopicSelector topics,
Topics.FetchStream callback)
Fetch the current state of topics.
|
<C> void |
Topics.subscribe(TopicSelector topics,
C context,
Topics.CompletionContextCallback<C> callback)
Request subscription to topics.
|
void |
Topics.subscribe(TopicSelector topics,
Topics.CompletionCallback callback)
Request subscription to topics.
|
<C> void |
Topics.unsubscribe(TopicSelector topics,
C context,
Topics.CompletionContextCallback<C> callback)
Unsubscribe from topics.
|
void |
Topics.unsubscribe(TopicSelector topics,
Topics.CompletionCallback callback)
Unsubscribe from topics.
|
Modifier and Type | Method and Description |
---|---|
TopicSelector |
TopicControl.MissingTopicNotification.getTopicSelector()
Returns the
TopicSelector that triggered this notification. |
Modifier and Type | Method and Description |
---|---|
void |
TopicUpdateControl.removeCachedValues(TopicSelector topics)
Removes values from the cache.
|
void |
TopicUpdateControl.ValueUpdater.removeCachedValues(TopicSelector topics)
Removes values from the value cache.
|
<C> void |
SubscriptionControl.subscribe(SessionId sessionId,
TopicSelector topics,
C context,
SubscriptionControl.SubscriptionContextCallback<C> callback)
Subscribe a client session to topics.
|
void |
SubscriptionControl.subscribe(SessionId sessionId,
TopicSelector topics,
SubscriptionControl.SubscriptionCallback callback)
Subscribe a client session to topics.
|
<C> void |
SubscriptionControl.subscribeByFilter(String filter,
TopicSelector topics,
C context,
SubscriptionControl.SubscriptionByFilterContextCallback<C> callback)
Subscribe to all sessions that satisfy a given session filter to topics.
|
void |
SubscriptionControl.subscribeByFilter(String filter,
TopicSelector topics,
SubscriptionControl.SubscriptionByFilterCallback callback)
Subscribe to all sessions that satisfy a given session filter to topics.
|
<C> void |
SubscriptionControl.unsubscribe(SessionId sessionId,
TopicSelector topics,
C context,
SubscriptionControl.SubscriptionContextCallback<C> callback)
Unsubscribe a client session from topics.
|
void |
SubscriptionControl.unsubscribe(SessionId sessionId,
TopicSelector topics,
SubscriptionControl.SubscriptionCallback callback)
Unsubscribe a client session from topics.
|
<C> void |
SubscriptionControl.unsubscribeByFilter(String filter,
TopicSelector topics,
C context,
SubscriptionControl.SubscriptionByFilterContextCallback<C> callback)
Unsubscribe all sessions that satisfy a given session filter from topics.
|
void |
SubscriptionControl.unsubscribeByFilter(String filter,
TopicSelector topics,
SubscriptionControl.SubscriptionByFilterCallback callback)
Unsubscribe all sessions that satisfy a given session filter from topics.
|
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 © 2016 Push Technology Ltd. All Rights Reserved.