public abstract static class Topics.SubscriberStream.Default extends Stream.Default implements Topics.SubscriberStream
Topics.SubscriberStream
implementation.
This logs calls to onSubscription and onUnsubscription at 'debug' level. These implementations can be useful during development but are usually overridden to provide meaningful processing.
Topics.SubscriberStream.Default
Constructor and Description |
---|
Default() |
Modifier and Type | Method and Description |
---|---|
void |
onSubscription(String topicPath,
TopicSpecification specification)
Subscription notification.
|
void |
onUnsubscription(String topicPath,
TopicSpecification specification,
Topics.UnsubscribeReason reason)
Unsubscription notification.
|
onClose
onError
public void onSubscription(String topicPath, TopicSpecification specification)
Topics.SubscriberStream
This method is called when a session is subscribed to a topic that matches the stream registration. This method is also called when a stream is added, for all of the session's subscriptions to topics that match the stream registration.
For a given topic, onSubscription
will be the initial
notification, and the first notification following an
unsubscription
notification if the session
re-subscribes to the topic.
This method is also called for fallback streams that match the topic type when the session removes the last stream that selected a subscribed topic. The fallback stream will now receive updates for the topic, starting with an immediate notification of the currently cached value (if any).
onSubscription
in interface Topics.SubscriberStream
topicPath
- the topic pathspecification
- the topic specificationpublic void onUnsubscription(String topicPath, TopicSpecification specification, Topics.UnsubscribeReason reason)
Topics.SubscriberStream
This method is called if the session is unsubscribed from a topic that matches the stream registration. The stream will receive no more updates for the topic unless the session re-subscribes to the topic.
This method is also called for fallback streams that match the topic
type if the session
adds
the first
stream that selects a subscribed topic. For these notifications,
reason
will be Topics.UnsubscribeReason.STREAM_CHANGE
. The
fallback stream will no longer receive updates for the topic.
onUnsubscription
in interface Topics.SubscriberStream
topicPath
- the topic pathspecification
- the topic specificationreason
- the reason for unsubscriptionCopyright © 2024 DiffusionData Ltd. All Rights Reserved.