Package | Description |
---|---|
com.pushtechnology.diffusion.api.data |
Diffusion Topic Data API.
|
com.pushtechnology.diffusion.api.data.routing |
Diffusion Routing Topic Data API.
|
com.pushtechnology.diffusion.api.data.service |
Diffusion Service Topic Data API.
|
com.pushtechnology.diffusion.api.publisher |
Diffusion Internal Publisher API.
|
com.pushtechnology.diffusion.api.topic |
Diffusion Topics API.
|
Modifier and Type | Method and Description |
---|---|
TopicMessage |
TopicData.getLoadMessage(TopicClient client)
This returns the current data state as a Topic Load message.
|
void |
PublishingTopicData.publishExclusiveMessage(TopicMessage message,
TopicClient client)
As
PublishingTopicData.publishMessage(TopicMessage) but excluding a specified
client. |
void |
PublishingTopicData.publishExclusiveMessage(TopicMessage message,
TopicClient client,
MessagePriority priority)
As
PublishingTopicData.publishExclusiveMessage(TopicMessage, TopicClient) but
allowing a message priority to be specified. |
Modifier and Type | Method and Description |
---|---|
List<TopicClient> |
RoutingTopicData.getClientsForTopic(Topic topic)
Get the list of Clients that are mapped to a particular Topic.
|
Modifier and Type | Method and Description |
---|---|
Topic |
RoutingTopicDataSubscriptionHandler.clientSubscriptionRequest(TopicClient client,
RoutingTopicData topicData)
This is called when a Client attempts to subscribe to the Routing Topic.
|
void |
RoutingTopicData.subscribe(TopicClient client,
Topic topic)
This may be used to subscribe a client to a Topic other than the parent
Topic, bypassing any authorisation checks.
|
Modifier and Type | Method and Description |
---|---|
TopicClient |
ServiceRequest.getClient()
Deprecated.
Returns the client that initiated the request.
|
Modifier and Type | Interface and Description |
---|---|
interface |
Client
A Client represents a client connection to the Diffusion Server.
|
Modifier and Type | Method and Description |
---|---|
List<TopicClient> |
Publisher.getClients(Topic topic)
Returns the list of clients currently subscribed to a given topic.
|
Modifier and Type | Method and Description |
---|---|
List<String> |
Publisher.getClientGroupMembership(TopicClient client) |
void |
Publisher.publishExclusiveMessage(TopicMessage message,
TopicClient client) |
void |
Publisher.publishExclusiveMessage(TopicMessage message,
TopicClient client,
MessagePriority priority) |
Modifier and Type | Method and Description |
---|---|
void |
Publisher.messageNotAcknowledged(TopicMessage message,
List<TopicClient> clients) |
Modifier and Type | Method and Description |
---|---|
TopicClient |
Subscription.getClient()
Returns the Client.
|
Modifier and Type | Method and Description |
---|---|
List<TopicClient> |
Topic.getClients()
Returns a list of all of the client sessions that are directly subscribed
to the topic.
|
List<TopicClient> |
ClientGroup.getClients()
Returns a snapshot of all of the clients currently in the group.
|
Modifier and Type | Method and Description |
---|---|
boolean |
ClientGroup.addClient(TopicClient client)
Adds a client to the group.
|
boolean |
TopicSubscriptionHandler.clientSubscriptionRequest(TopicClient client,
Topic topic)
Deprecated.
This is called before a client is actually subscribed to the Topic and it
allows for additional validation or delegation of the authorisation to
some asynchronous process.
|
boolean |
ClientGroup.containsClient(TopicClient client)
Returns true if the client is contained within the group.
|
List<String> |
TopicProvider.getClientGroupMembership(TopicClient client)
Gets a list of group names that a specified client currently belongs to.
|
boolean |
TopicLoader.load(TopicClient client,
Topic topic)
This is used to perform the Topic Load processing for a Client when
requested.
|
boolean |
SimpleTopicLoader.load(TopicClient client,
Topic topic)
Simple Implementation of
TopicLoader.load(TopicClient, Topic) |
boolean |
CachedTopicLoader.load(TopicClient client,
Topic topic)
Cached Topic load implementation.
|
void |
TopicProvider.publishExclusiveMessage(TopicMessage message,
TopicClient client)
Deprecated.
since 5.6. See
TopicProvider.publishMessage(TopicMessage) for
details. |
void |
Topic.publishExclusiveMessage(TopicMessage message,
TopicClient client)
A variant of
Topic.publishMessage(TopicMessage) that publishes a
message to all but one client. |
void |
TopicProvider.publishExclusiveMessage(TopicMessage message,
TopicClient client,
MessagePriority priority)
Deprecated.
since 5.6. See
TopicProvider.publishMessage(TopicMessage) for
details. |
void |
Topic.publishExclusiveMessage(TopicMessage message,
TopicClient client,
MessagePriority priority)
A variant of
Topic.publishMessage(TopicMessage) that publishes a
message to all but one client and allows the message priority to be
specified. |
boolean |
ClientGroup.removeClient(TopicClient client)
Removes a client from the group.
|
void |
ClientGroup.sendExclusive(TopicMessage message,
TopicClient excludeClient)
Send an exclusive message, i.e.
|
void |
ClientGroup.sendExclusive(TopicMessage message,
TopicClient excludeClient,
MessagePriority priority)
Send an exclusive message, i.e.
|
void |
Topic.subscribe(TopicClient client)
Subscribe a client to this topic.
|
Modifier and Type | Method and Description |
---|---|
void |
ClientAckListener.messageNotAcknowledged(TopicMessage message,
List<TopicClient> clients)
This is a notification of non acknowledgement of a message that required
acknowledgement by one or more Clients.
|
Copyright © 2016 Push Technology Ltd. All Rights Reserved.