public interface SubscriptionControl extends Feature
Requests to subscribe sessions to topics can be submitted at any time even if
the topics do not exist at the server. Topic selectors
are used on subscription to match against topics at the server. The session
will become subscribed to any topics that exist at the server that match the
selector (unless they are already subscribed, or the session has insufficient
permission). The subscription request is also retained at the server so that
if any newly created topics match the selector, the session will then become
subscribed to it (unless a subsequent unsubscription cancels it).
Specific sessions may be subscribed/unsubscribed if the SessionId
is
known.
Subscriptions may also be requested using 'session filters' (see
Session
for a full description of session filters), where all
sessions that satisfy a particular filter expression will be
subscribed/unsubscribed. The filter is only evaluated once against the
current sessions that exist at the time - it is not retained and applied to
any sessions that are created later. In order to be notified of new sessions
as they are created session event listeners
can be
used and those sessions subscribed as required based upon their session
properties.
MODIFY_SESSION
permission, and
SELECT_TOPIC
permission for the path
prefix of the topic selector used for subscription. The subscribed sessions
will only be subscribed to matching topics for which they have
READ_TOPIC
permission.
To unsubscribe other sessions, a session must have
MODIFY_SESSION
permission.
Operations that identify sessions using a session filter require the
VIEW_SESSION
permission.
session
as follows:
SubscriptionControl subsControl = session.feature(SubscriptionControl.class);
Modifier and Type | Interface and Description |
---|---|
static interface |
SubscriptionControl.SubscriptionByFilterCallback
Deprecated.
since 6.7
Methods that use callbacks are deprecated and will be removed in a future release. Use CompletableFuture variant instead. |
static interface |
SubscriptionControl.SubscriptionByFilterContextCallback<C>
Deprecated.
since 6.7
Methods that use callbacks are deprecated and will be removed in a future release. Use CompletableFuture variant instead. |
static interface |
SubscriptionControl.SubscriptionByFilterResult
Result used by CompletableFuture variants of
subscribeByFilter and
unsubscribeByFilter . |
static interface |
SubscriptionControl.SubscriptionCallback
Deprecated.
since 6.7
Methods that use callbacks are deprecated and will be removed in a future release. Use CompletableFuture variant instead. |
static interface |
SubscriptionControl.SubscriptionContextCallback<C>
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 |
---|---|
CompletableFuture<?> |
subscribe(SessionId sessionId,
String topics)
Subscribe another session to topics.
|
<C> void |
subscribe(SessionId sessionId,
String 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 |
subscribe(SessionId sessionId,
String 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<?> |
subscribe(SessionId sessionId,
TopicSelector topics)
Subscribe another session to topics.
|
<C> void |
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 |
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> |
subscribeByFilter(String filter,
String topics)
Subscribe sessions that satisfy a given session filter to topics.
|
<C> void |
subscribeByFilter(String filter,
String 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 |
subscribeByFilter(String filter,
String 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.SubscriptionByFilterResult> |
subscribeByFilter(String filter,
TopicSelector topics)
Subscribe sessions that satisfy a given session filter to topics.
|
<C> void |
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 |
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<?> |
unsubscribe(SessionId sessionId,
String topics)
Unsubscribe another session from topics.
|
<C> void |
unsubscribe(SessionId sessionId,
String 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 |
unsubscribe(SessionId sessionId,
String 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<?> |
unsubscribe(SessionId sessionId,
TopicSelector topics)
Unsubscribe another session from topics.
|
<C> void |
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 |
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> |
unsubscribeByFilter(String filter,
String topics)
Unsubscribe sessions that satisfy a given session filter from topics.
|
<C> void |
unsubscribeByFilter(String filter,
String 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 |
unsubscribeByFilter(String filter,
String 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.SubscriptionByFilterResult> |
unsubscribeByFilter(String filter,
TopicSelector topics)
Unsubscribe sessions that satisfy a given session filter from topics.
|
<C> void |
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 |
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. |
getSession
CompletableFuture<?> subscribe(SessionId sessionId, String topics) throws IllegalArgumentException
This is equivalent to calling
subscribe(SessionId, TopicSelector)
with a selector parsed using
TopicSelectors.parse(String)
.
sessionId
- identifies the session to subscribetopics
- the topics to subscribe to specified as a
TopicSelector
expressionIf the subscription was accepted, the CompletableFuture will complete successfully. The result type is any rather than Void to provide forward compatibility with future iterations of this API that may provide a non-null result with a more specific result type.
Otherwise, the CompletableFuture will complete exceptionally with
a CompletionException
. Common reasons for failure, listed
by the exception reported as the
cause
, include:
PermissionsException
– if the calling session
does not have MODIFY_SESSION
permission;
PermissionsException
– if the calling session
does not have SELECT_TOPIC
permission for the path prefix
of the selector expression ;
NoSuchSessionException
– if there is no session
with the given sessionId
;
SessionClosedException
– if the session is
closed.
IllegalArgumentException
- if topics
is not a valid
selector expressionCompletableFuture<?> subscribe(SessionId sessionId, TopicSelector topics)
New subscriptions will be established for existing topics that match the
provided topic selector and for which the subscribed session has
READ_TOPIC
permission. The topic selector will be added to the
topic selections of the subscribed session, and re-evaluated when new
topics are added or the session's security roles change.
A session that does not have SELECT_TOPIC
permission for a topic
cannot subscribe directly, but can be subscribed indirectly using this
method.
sessionId
- identifies the session to subscribetopics
- identifies the topics to subscribe toIf the subscription was accepted, the CompletableFuture will complete successfully. The result type is any rather than Void to provide forward compatibility with future iterations of this API that may provide a non-null result with a more specific result type.
Otherwise, the CompletableFuture will complete exceptionally with
a CompletionException
. Common reasons for failure, listed
by the exception reported as the
cause
, include:
PermissionsException
– if the calling session
does not have MODIFY_SESSION
permission;
PermissionsException
– if the calling session
does not have SELECT_TOPIC
permission for the path prefix
of the selector expression ;
NoSuchSessionException
– if there is no session
with the given sessionId
;
SessionClosedException
– if the session is
closed.
@Deprecated void subscribe(SessionId sessionId, String topics, SubscriptionControl.SubscriptionCallback callback) throws IllegalArgumentException
Methods that use callbacks are deprecated and will be removed in a future release. Use CompletableFuture variant instead.
This is equivalent to calling
subscribe(SessionId, TopicSelector, SubscriptionCallback)
with a
selector parsed using TopicSelectors.parse(String)
.
sessionId
- identifies the session to subscribetopics
- the topics to subscribe to specified as a
TopicSelector
expressioncallback
- provides callback methods to indicate success or failureIllegalArgumentException
- if topics
is not a valid
selector expression@Deprecated void subscribe(SessionId sessionId, TopicSelector topics, SubscriptionControl.SubscriptionCallback callback)
Methods that use callbacks are deprecated and will be removed in a future release. Use CompletableFuture variant instead.
New subscriptions will be established for existing topics that match the
provided topic selector and for which the subscribed session has
READ_TOPIC
permission. The topic selector will be added to the
topic selections of the subscribed session, and re-evaluated when new
topics are added or the session's security roles change.
A session that does not have SELECT_TOPIC
permission for a topic
cannot subscribe directly, but can be subscribed indirectly using this
method.
sessionId
- identifies the session to subscribetopics
- identifies the topics to subscribe tocallback
- provides callback methods to indicate success or failure@Deprecated <C> void subscribe(SessionId sessionId, String topics, C context, SubscriptionControl.SubscriptionContextCallback<C> callback) throws IllegalArgumentException
Methods that use callbacks are deprecated and will be removed in a future release. Use CompletableFuture variant instead.
This is equivalent to calling
subscribe(SessionId, TopicSelector, Object, SubscriptionContextCallback)
with a selector parsed using TopicSelectors.parse(String)
.
C
- context object typesessionId
- identifies the session to subscribetopics
- the topics to subscribe to specified as a
TopicSelector
expressioncontext
- passed to the callback with the reply to allow requests
and replies to be correlated. The caller may use any convenient
object reference, including null
callback
- provides callback methods to indicate success or failureIllegalArgumentException
- if topics
is not a valid
selector expression@Deprecated <C> void subscribe(SessionId sessionId, TopicSelector topics, C context, SubscriptionControl.SubscriptionContextCallback<C> callback)
Methods that use callbacks are deprecated and will be removed in a future release. Use CompletableFuture variant instead.
New subscriptions will be established for existing topics that match the
provided topic selector and for which the subscribed session has
READ_TOPIC
permission. The topic selector will be added to the
topic selections of the subscribed session, and re-evaluated when new
topics are added or the session's security roles change.
A session that does not have SELECT_TOPIC
permission for a topic
cannot subscribe directly, but can be subscribed indirectly using this
method.
C
- context object typesessionId
- identifies the session to subscribetopics
- identifies the topics to subscribe tocontext
- passed to the callback with the reply to allow requests
and replies to be correlated. The caller may use any convenient
object reference, including null
callback
- provides callback methods to indicate success or failureCompletableFuture<?> unsubscribe(SessionId sessionId, String topics) throws IllegalArgumentException
This is equivalent to calling
unsubscribe(SessionId, TopicSelector)
with a selector parsed
using TopicSelectors.parse(String)
.
sessionId
- identifies the session to unsubscribetopics
- the topics to unsubscribe specified as a
TopicSelector
expressionIf the unsubscription was accepted, the CompletableFuture will complete successfully. The result type is any rather than Void to provide forward compatibility with future iterations of this API that may provide a non-null result with a more specific result type.
Otherwise, the CompletableFuture will complete exceptionally with
a CompletionException
. Common reasons for failure, listed
by the exception reported as the
cause
, include:
PermissionsException
– if the calling session
does not have MODIFY_SESSION
permission;
NoSuchSessionException
– if there is no session
with the given sessionId
;
SessionClosedException
– if the session is
closed.
IllegalArgumentException
- if topics
is not a valid
selector expressionCompletableFuture<?> unsubscribe(SessionId sessionId, TopicSelector topics)
sessionId
- identifies the session to unsubscribetopics
- the topics to unsubscribe fromIf the unsubscription was accepted, the CompletableFuture will complete successfully. The result type is any rather than Void to provide forward compatibility with future iterations of this API that may provide a non-null result with a more specific result type.
Otherwise, the CompletableFuture will complete exceptionally with
a CompletionException
. Common reasons for failure, listed
by the exception reported as the
cause
, include:
PermissionsException
– if the calling session
does not have MODIFY_SESSION
permission;
NoSuchSessionException
– if there is no session
with the given sessionId
;
SessionClosedException
– if the session is
closed.
@Deprecated void unsubscribe(SessionId sessionId, String topics, SubscriptionControl.SubscriptionCallback callback) throws IllegalArgumentException
Methods that use callbacks are deprecated and will be removed in a future release. Use CompletableFuture variant instead.
This is equivalent to calling
unsubscribe(SessionId, TopicSelector, SubscriptionCallback)
with
a selector parsed using TopicSelectors.parse(String)
.
sessionId
- identifies the session to unsubscribetopics
- the topics to unsubscribe specified as a
TopicSelector
expressioncallback
- provides callback methods indicating the status of this
operationIllegalArgumentException
- if topics
is not a valid
selector expression@Deprecated void unsubscribe(SessionId sessionId, TopicSelector topics, SubscriptionControl.SubscriptionCallback callback)
Methods that use callbacks are deprecated and will be removed in a future release. Use CompletableFuture variant instead.
sessionId
- identifies the session to unsubscribetopics
- the topics to unsubscribe fromcallback
- provides callback methods indicating the status of this
operation@Deprecated <C> void unsubscribe(SessionId sessionId, String topics, C context, SubscriptionControl.SubscriptionContextCallback<C> callback) throws IllegalArgumentException
Methods that use callbacks are deprecated and will be removed in a future release. Use CompletableFuture variant instead.
This is equivalent to calling
unsubscribe(SessionId, TopicSelector, Object, SubscriptionContextCallback)
with a selector parsed using TopicSelectors.parse(String)
.
C
- context object typesessionId
- identifies the session to unsubscribetopics
- the topics to unsubscribe specified as a
TopicSelector
expressioncontext
- passed to the callback with the reply to allow requests
and replies to be correlated. The caller may use any convenient
object reference, including null
callback
- provides callback methods indicating the status of this
operationIllegalArgumentException
- if topics
is not a valid
selector expression@Deprecated <C> void unsubscribe(SessionId sessionId, TopicSelector topics, C context, SubscriptionControl.SubscriptionContextCallback<C> callback)
Methods that use callbacks are deprecated and will be removed in a future release. Use CompletableFuture variant instead.
C
- context object typesessionId
- identifies the session to unsubscribetopics
- the topics to unsubscribe fromcontext
- passed to the callback with the reply to allow requests
and replies to be correlated. The caller may use any convenient
object reference, including null
callback
- provides callback methods indicating the status of this
operationCompletableFuture<SubscriptionControl.SubscriptionByFilterResult> subscribeByFilter(String filter, String topics) throws IllegalArgumentException
This is equivalent to calling
subscribeByFilter(String, TopicSelector)
with a selector parsed
using TopicSelectors.parse(String)
.
filter
- the session filter expressiontopics
- the topics to subscribe to specified as a
TopicSelector
expression
If the subscription was accepted, the CompletableFuture will
complete successfully with a SubscriptionControl.SubscriptionByFilterResult
.
Otherwise, the CompletableFuture will complete exceptionally with
a CompletionException
. Common reasons for failure, listed
by the exception reported as the
cause
, include:
InvalidFilterException
– if the filter is
invalid;
PermissionsException
– if the calling session
does not have MODIFY_SESSION
and VIEW_SESSION
global permissions;
PermissionsException
– if the calling session
does not have SELECT_TOPIC
permission for the path prefix
of the selector expression;
SessionClosedException
– if the session is
closed.
IllegalArgumentException
- if topics
is not a valid
selector expressionCompletableFuture<SubscriptionControl.SubscriptionByFilterResult> subscribeByFilter(String filter, TopicSelector topics)
For each session that matches the filter, new subscriptions will be
established for existing topics that match the provided topic selector
and for which the sessions has READ_TOPIC
permission. The topic
selector will be added to the topic selections of the subscribed session,
and re-evaluated when new topics are added or the session's security
roles change.
A session that does not have SELECT_TOPIC
permission for a topic
cannot subscribe directly, but can be subscribed indirectly using this
method.
filter
- the session filter expressiontopics
- the topics to subscribe to specified as a
TopicSelector
expression
If the subscription was accepted, the CompletableFuture will
complete successfully with a SubscriptionControl.SubscriptionByFilterResult
.
Otherwise, the CompletableFuture will complete exceptionally with
a CompletionException
. Common reasons for failure, listed
by the exception reported as the
cause
, include:
InvalidFilterException
– if the filter is
invalid;
PermissionsException
– if the calling session
does not have MODIFY_SESSION
and VIEW_SESSION
permissions;
PermissionsException
– if the calling session
does not have SELECT_TOPIC
permission for the path prefix
of the selector expression;
SessionClosedException
– if the session is
closed.
@Deprecated void subscribeByFilter(String filter, String topics, SubscriptionControl.SubscriptionByFilterCallback callback) throws IllegalArgumentException
Methods that use callbacks are deprecated and will be removed in a future release. Use CompletableFuture variant instead.
This is equivalent to calling
subscribeByFilter(String, TopicSelector, SubscriptionByFilterCallback)
with a selector parsed using TopicSelectors.parse(String)
.
filter
- the session filter expressiontopics
- the topics to subscribe to specified as a
TopicSelector
expressioncallback
- provides callback methods to indicate success or failureIllegalArgumentException
- if topics
is not a valid
selector expression@Deprecated void subscribeByFilter(String filter, TopicSelector topics, SubscriptionControl.SubscriptionByFilterCallback callback)
Methods that use callbacks are deprecated and will be removed in a future release. Use CompletableFuture variant instead.
For each session that matches the filter, new subscriptions will be
established for existing topics that match the provided topic selector
and for which the sessions has READ_TOPIC
permission. The topic
selector will be added to the topic selections of the subscribed session,
and re-evaluated when new topics are added or the session's security
roles change.
A session that does not have SELECT_TOPIC
permission for a topic
cannot subscribe directly, but can be subscribed indirectly using this
method.
filter
- the session filter expressiontopics
- identifies the topics to subscribe tocallback
- provides callback methods to indicate success or failure@Deprecated <C> void subscribeByFilter(String filter, String topics, C context, SubscriptionControl.SubscriptionByFilterContextCallback<C> callback) throws IllegalArgumentException
Methods that use callbacks are deprecated and will be removed in a future release. Use CompletableFuture variant instead.
This is equivalent to calling
subscribeByFilter(String, TopicSelector, Object, SubscriptionByFilterContextCallback)
with a selector parsed using TopicSelectors.parse(String)
.
C
- context object typefilter
- the session filter expressiontopics
- the topics to subscribe to specified as a
TopicSelector
expressioncontext
- passed to the callback with the reply to allow requests
and replies to be correlated. The caller may use any convenient
object reference, including null
callback
- provides callback methods to indicate success or failureIllegalArgumentException
- if topics
is not a valid
selector expression@Deprecated <C> void subscribeByFilter(String filter, TopicSelector topics, C context, SubscriptionControl.SubscriptionByFilterContextCallback<C> callback)
Methods that use callbacks are deprecated and will be removed in a future release. Use CompletableFuture variant instead.
For each session that matches the filter, new subscriptions will be
established for existing topics that match the provided topic selector
and for which the sessions has READ_TOPIC
permission. The topic
selector will be added to the topic selections of the subscribed session,
and re-evaluated when new topics are added or the session's security
roles change.
A session that does not have SELECT_TOPIC
permission for a topic
cannot subscribe directly, but can be subscribed indirectly using this
method.
C
- context object typefilter
- the session filter expressiontopics
- identifies the topics to subscribe tocontext
- passed to the callback with the reply to allow requests
and replies to be correlated. The caller may use any convenient
object reference, including null
callback
- provides callback methods to indicate success or failureCompletableFuture<SubscriptionControl.SubscriptionByFilterResult> unsubscribeByFilter(String filter, String topics) throws IllegalArgumentException
This is equivalent to calling
unsubscribeByFilter(String, TopicSelector)
with a selector
parsed using TopicSelectors.parse(String)
.
filter
- the session filter expressiontopics
- the topics to unsubscribe from specified as a
TopicSelector
expression
If the unsubscription was accepted, the CompletableFuture will
complete successfully with a SubscriptionControl.SubscriptionByFilterResult
.
Otherwise, the CompletableFuture will complete exceptionally with
a CompletionException
. Common reasons for failure, listed
by the exception reported as the
cause
, include:
InvalidFilterException
– if the filter is
invalid;
PermissionsException
– if the calling session
does not have MODIFY_SESSION
and VIEW_SESSION
permissions;
SessionClosedException
– if the session is
closed.
IllegalArgumentException
- if topics
is not a valid
selector expressionCompletableFuture<SubscriptionControl.SubscriptionByFilterResult> unsubscribeByFilter(String filter, TopicSelector topics)
filter
- the session filter expressiontopics
- the topics to unsubscribe from specified as a
TopicSelector
expression
If the unsubscription was accepted, the CompletableFuture will
complete successfully with a SubscriptionControl.SubscriptionByFilterResult
.
Otherwise, the CompletableFuture will complete exceptionally with
a CompletionException
. Common reasons for failure, listed
by the exception reported as the
cause
, include:
InvalidFilterException
– if the filter is
invalid;
PermissionsException
– if the calling session
does not have MODIFY_SESSION
and VIEW_SESSION
global permissions;
SessionClosedException
– if the session is
closed.
@Deprecated void unsubscribeByFilter(String filter, String topics, SubscriptionControl.SubscriptionByFilterCallback callback) throws IllegalArgumentException
Methods that use callbacks are deprecated and will be removed in a future release. Use CompletableFuture variant instead.
This is equivalent to calling
unsubscribeByFilter(String, TopicSelector, SubscriptionByFilterCallback)
with a selector parsed using TopicSelectors.parse(String)
.
filter
- the session filter expressiontopics
- the topics to unsubscribe specified as a
TopicSelector
expressioncallback
- provides callback methods indicating the status of this
operationIllegalArgumentException
- if topics
is not a valid
selector expression@Deprecated void unsubscribeByFilter(String filter, TopicSelector topics, SubscriptionControl.SubscriptionByFilterCallback callback)
Methods that use callbacks are deprecated and will be removed in a future release. Use CompletableFuture variant instead.
filter
- the session filter expressiontopics
- the topics to unsubscribe fromcallback
- provides callback methods indicating the status of this
operation@Deprecated <C> void unsubscribeByFilter(String filter, String topics, C context, SubscriptionControl.SubscriptionByFilterContextCallback<C> callback) throws IllegalArgumentException
Methods that use callbacks are deprecated and will be removed in a future release. Use CompletableFuture variant instead.
This is equivalent to calling
unsubscribeByFilter(String, TopicSelector, SubscriptionByFilterCallback)
with a selector parsed using TopicSelectors.parse(String)
.
C
- context object typefilter
- the session filter expressiontopics
- the topics to unsubscribe specified as a
TopicSelector
expressioncontext
- passed to the callback with the reply to allow requests
and replies to be correlated. The caller may use any convenient
object reference, including null
callback
- provides callback methods indicating the status of this
operationIllegalArgumentException
- if topics
is not a valid
selector expression@Deprecated <C> void unsubscribeByFilter(String filter, TopicSelector topics, C context, SubscriptionControl.SubscriptionByFilterContextCallback<C> callback)
Methods that use callbacks are deprecated and will be removed in a future release. Use CompletableFuture variant instead.
C
- context object typefilter
- the session filter expressiontopics
- the topics to unsubscribe fromcontext
- passed to the callback with the reply to allow requests
and replies to be correlated. The caller may use any convenient
object reference, including null
callback
- provides callback methods indicating the status of this
operationCopyright © 2024 DiffusionData Ltd. All Rights Reserved.