All Classes and Interfaces
Class
Description
This feature allows a client session to authenticate the credentials of other
sessions, and optionally revoke such authentications.
A control authenticator.
The session operation failed due to an authentication failure.
An authentication handler that processes authentication requests from the
server.
Single-use callback provided to the
authenticate call.A read-only binary value with support for binary deltas.
Binary data type.
Binary delta type.
Read-only interface for values that are internally represented as binary
data.
Callback interface that provides responses from the server.
Abstract default callback.
This feature provides the ability for a client session to control other
client sessions.
The server's view of why a client session was closed.
Handler for client queue events.
This provides a default implementation of
ClientControl.QueueEventStream.Provides parameters which specify the level of detail required by a
ClientControl.SessionEventStream registered using
setSessionEventListener.A builder for
SessionEventParameters.The stream to receive for session event listener notifications.
This provides a default implementation of
ClientControl.SessionEventStream
which will simply log session event callbacks at debug level.The interface for an event delivered by the stream.
The session state.
The event type.
Result of ClientControl operations that identify sessions using a client
filter and provide a result through a
CompletableFuture.Provides details of a session lock.
Deprecated.
since 6.11
This provides a default implementation of
ClientControl.SessionPropertiesStream which will simply log session
properties callbacks at debug level.Event type.
Indicates a cluster operation failed because partition ownership changed
during processing.
Indicates a cluster operation failed to be routed to a server within the
cluster due to a communication failure.
Immutable value containing the proof material to support an authentication
request.
Factory for the standard credential types.
Type code indicated the type of the credentials.
A data type is specified for a particular class (its value class).
Diffusion data type implementations.
Optional extension provided by
DataType implementations that support
incremental changes to values.Provides facilities that are shared between sessions.
The contract with the implementation.
Reason codes used to report error conditions.
An error report.
Thrown to report one or more
ErrorReports}.This is the base interface for features that may be added directly to a
client
session.Permissions that protect globally scoped, access-controlled operations.
Thrown to indicate a handler could not be registered because it conflicts
with an existing handler.
Interface that defines a proxy authentication scheme.
Allows for an authentication implementation to be provided for
connections routed via HTTP proxies.
Exception used to report that an operation has failed
because the receiver could not process the supplied data.
Exception used to report a topic is incompatible with an operation.
An operation could not be performed because the topic is managed by a
component (such as fan-out) that prohibits updates from the caller.
Unchecked exception indicating that binary data could not be parsed as a
value.
Exception used to report a filter expression is invalid.
Exception used to report an operation was performed with an invalid
update stream.Immutable JSON data value.
JSON data type.
Structural delta type for
JSON.An unmodifiable map describing the changes to a JSON value.
Policy for managing a client message queue.
This feature provides a client session with request-response messaging
capabilities that can be used to implement application services.
Callback interface for requests dispatched through a filter.
Default implementation of
Messaging.FilteredRequestCallback.Interface which specifies a request handler to receive request
notifications.
Context of the request received.
Responder interface to dispatch responses to requests.
Interface which specifies a request stream to receive request
notifications.
Responder interface to dispatch responses to requests.
This feature allows a client to configure metric collectors.
Common interface for metric collector builders.
Description of a metric alert.
The common base interface for metric collectors.
Represents a single metric sample.
Represents a collection of metric samples.
A parameterized query that can be used to fetch metrics from the server.
The result of a fetch metrics operation, initiated by a
Metrics.MetricsRequest.Enumeration defining the metric types available.
The definition of a session metric collector.
A session metric collector builder.
The definition of a topic metric collector.
A topic metric collector builder.
Exception used to report there is no session for a given session ID.
Exception used to report there is no topic bound to a topic path.
Permissions protecting access-controlled operations that are evaluated for a
specific path.
A permission protects an access-controlled operation.
The session operation failed due to a permissions failure.
This feature provides a client session with the ability to test its
connection to the server.
Server response to a ping.
Factory for
proxy authentication instances.Interface that defines a reconnection strategy.
A single reconnection attempt that can either be started or aborted.
RecordV2 data model.An immutable value representing a list of records.
Builds free format
RecordV2 value.Record-based data type.
RecordV2 structural delta.Represents a single change between one record value and another.
Indicates the type of change.
An extension to
UpdateStream that includes recovery functionality.A reference to a registered handler.
Exception used to report that a recipient session
has rejected a request.
This feature allows a client session to manage remote servers.
Result returned from a
RemoteServers.checkRemoteServer(java.lang.String) invocation.Represents the current connection state of the remote server.
A primary initiator.
Builder for a
RemoteServers.PrimaryInitiator.Base interface for a remote server definition.
Deprecated.
since 6.9
Connection options for use with
RemoteServers.SecondaryServers.The base interface for all remote server builders.
The remote server type.
Exception thrown when an attempt has been made to create a remote server
when one with the same name is already defined.
Exception thrown when one or more of the options specified when creating
a remote server have been found to be invalid.
Secondary remote server that accepts a connection from a primary server.
Builder for a
RemoteServers.SecondaryAcceptor.Secondary remote server that initiates a connection to a primary server.
Builder for an
SecondaryInitiator.Base interface for a secondary remote server.
Base builder interface for
RemoteServers.SecondaryServer.Defines a retry strategy.
RecordV2 schema.Field Definition.
Field Type.
Schema Node - A
Schema.Record or a Schema.Field.Record Definition.
Used to build an immutable
Schema.Indicates a problem that has occurred when parsing a
Schema.Indicates a problem that has occurred when building a
Schema.Exception used to report problems evaluating a script.
This feature provides a client session with the ability to re-authenticate
the session, as well as to query permissions assigned to it.
This feature allows a client session to query and update the security store.
Encapsulates the defined details for an individual role.
A script builder may be used to create a script of commands to apply to
the security store at the server.
Snapshot of information from the security store.
The super interface for features that update security stores.
A session could not be established because the server was initializing.
A client session to a server (or cluster of servers).
The error notification interface for a session.
Default
Session.ErrorHandler implementation which simply logs errors
at error level.The optional listener interface for a session which may be used to
receive state notifications.
Default
Session.Listener implementation which simply logs events at
debug level.Encapsulates the detail of a reported error.
A session lock is a server-managed resource that can be used to
coordinate exclusive access to shared resources across sessions.
Values for the
scope parameter of
Session.lock(String, SessionLockScope).Session state.
Session Attributes.
The transports available to Java clients.
The session is closed.
There was a problem when establishing a Session.
Represents a transient problem when establishing a session.
General class of exceptions indicating a
Session specific
failure.Factory for client
sessions.A unique
Session identifier, allocated by the server.The session operation failed due to a security constraint.
This feature allows a client session to configure session trees.
A session tree branch mapping.
A session tree branch mapping table.
Builder for
SessionTrees.BranchMappingTable instances.Exception indicating an invalid
SessionTrees.BranchMapping or
SessionTrees.BranchMappingTable.An extension of
Callback that allows many callbacks for each call
context.Abstract default callback.
This feature allows a session to subscribe or unsubscribe other sessions to
topics, on a single server or across a cluster.
Result used by CompletableFuture variants of
subscribeByFilter and
unsubscribeByFilter.This feature allows a client session to query and update the system
authentication store.
Action to be taken by the system authentication handler for connection
attempts that do not provide a principal name and credentials.
A script builder may be used to create a script of commands to apply to
the system authentication store at the server.
Defines the validation for a trusted client proposed session property.
Defines regular expression based validation for a trusted client
proposed session property.
Defines values based validation for a trusted client proposed session
property.
Snapshot of information from the system authentication store.
A principal in the system authentication store.
This feature allows a session to update and query time series topics.
An event in a time series.
Time series event metadata.
Exception used to report a query that is invalid for the time series.
Exception used to report a time series topic does not have an original
event with the sequence number provided by an
edit operation.A configured query.
Query result providing a
stream of events.Describes the structural properties of a stream.
Builder for queries that select a range of events from a time series.
This feature allows a session to manage topics.
Exception thrown to report a failure to add a topic.
Used to report the result of adding a topic.
Exception thrown to report a topic could not be added because an existing
topic with a different specification is bound to the topic path.
Exception thrown to report that a topic exists at the same path that is
managed by a component that has exclusive control over the topic.
Exception thrown to report a topic could not be added because there is an
existing topic that is incompatible with the request.
Exception thrown to report a topic could not be added because the topic
path supplied is invalid.
Exception thrown to report a topic could not be added because the
specification is invalid.
Notification that a session has made a subscription request using a
selector that does not match any topics.
Stream called when a session subscribes using a topic selector that
matches no topics.
Exception thrown to report a topic could not be added because a licence
limit has been exceeded.
Reports the number of topics removed by a call to
TopicControl.removeTopics(com.pushtechnology.diffusion.client.topics.TopicSelector).Result indicating whether the operation caused a topic to be created or if
it already existed.
This feature allows a client session to receive notifications about changes
to selected topics.
The NotificationRegistration represents the registration state of the
associated listener on the server.
Listener for topic notifications.
Default listener.
The type of notification that has been received.
A selector that selects a single topic path.
This feature allows a client session to subscribe to topics to receive
streamed topic updates, fetch the state of topics and/or update topics with
new values.
A parameterised query that can be used to search the topic tree.
Encapsulates the results from a fetch operation issued to the server.
Encapsulates the result of a
fetch invocation for a single selected topic.Base subscriber stream interface.
Default
Topics.SubscriberStream implementation.The reason that an unsubscription occurred.
Stream interface that can be registered to receive subscription and value
events whenever an update is received from the server.
Default
Topics.ValueStream implementation.A topic selection that represents either a subscription (selection) or an
unsubscription (deselection).
Topic selector type.
A
TopicSelector is a value that identifies one or more topics.Topic selector type.
Convert strings to
TopicSelectors.Topic specifications provide the information required to create a topic.
The topic type determines the type of the data values a topic publishes to
subscribers.
This feature provides a client session with the ability to update topics.
Exception thrown to report that applying a JSON Patch failed.
Exception thrown to report that a JSON Patch was invalid.
Description of a topic view that has been created.
This feature allows a client session to manage topic views.
Exception used to report a message was not delivered to an application
handler.
Exception used to report that a constraint was not satisfied.
A constraint to be applied to an update operation or the creation of an
update stream.
Factory for the constraint types.
An operator used in a constraint comparison.
A constraint requiring the current value of a
JSON
topic to match the partially described value.Exception used to report a topic update failed.
An update stream provides a method for updating a specific topic.
Builder for
update stream to use for updating a
specific topic.Exception used to report the update stream buffer have exceeded its limit.
Exception used to report the number of retry attempts have exceeded the limit.