- abort() - Method in interface com.pushtechnology.diffusion.client.session.reconnect.ReconnectionStrategy.ReconnectionAttempt
-
Abort the reconnection attempt.
- abstain() - Method in interface com.pushtechnology.diffusion.client.security.authentication.Authenticator.Callback
-
The authentication has neither passed nor failed.
- abstainAnonymousConnections() - Method in interface com.pushtechnology.diffusion.client.features.control.clients.SystemAuthenticationControl.ScriptBuilder
-
Instruct the system authentication handler to defer authentication
decisions for anonymous connections to subsequent handlers.
- ACCESS_DENIED - Static variable in class com.pushtechnology.diffusion.client.callbacks.ErrorReason
-
The request was rejected because the caller has insufficient permissions.
- add(String, int, String...) - Method in interface com.pushtechnology.diffusion.datatype.recordv2.model.MutableRecordModel
-
Adds new values to the end of a variable length field list.
- add(String...) - Method in interface com.pushtechnology.diffusion.datatype.recordv2.model.MutableRecordModel
-
Adds new values to the end of a variable length field list.
- addAndSet(String, TopicSpecification, Class<T>, T) - Method in interface com.pushtechnology.diffusion.client.features.TopicUpdate
-
Ensures a topic exists and sets its value.
- addAndSet(String, TopicSpecification, Class<T>, T, UpdateConstraint) - Method in interface com.pushtechnology.diffusion.client.features.TopicUpdate
-
Ensures a topic exists and sets its value.
- addBranchMapping(String, String) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.SessionTrees.BranchMappingTable.Builder
-
Add a new branch mapping.
- addFallbackStream(Class<? extends V>, Topics.ValueStream<V>) - Method in interface com.pushtechnology.diffusion.client.features.Topics
-
Add a fallback stream.
- addFields(Collection<String>) - Method in interface com.pushtechnology.diffusion.datatype.recordv2.RecordV2Builder
-
Adds one or more field values.
- addFields(String...) - Method in interface com.pushtechnology.diffusion.datatype.recordv2.RecordV2Builder
-
Adds one or more field values.
- addListener(TopicNotifications.TopicNotificationListener) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.TopicNotifications
-
Register a listener to receive topic notifications.
- addListener(Session.Listener) - Method in interface com.pushtechnology.diffusion.client.session.Session
-
Add a session listener.
- addMissingTopicHandler(String, TopicControl.MissingTopicNotificationStream) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.TopicControl
-
- addMissingTopicHandler(String, TopicControl.MissingTopicHandler) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.TopicControl
-
- addPrincipal(String, String, Set<String>) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.SystemAuthenticationControl.ScriptBuilder
-
Add a new principal.
- addPrincipal(String, String, Set<String>, String) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.SystemAuthenticationControl.ScriptBuilder
-
Add a new locked principal.
- addRecord() - Method in interface com.pushtechnology.diffusion.datatype.recordv2.model.MutableRecordModel
-
Adds a new initialized record occurrence to the end of a variable
multiplicity record list.
- addRecord(Collection<String>) - Method in interface com.pushtechnology.diffusion.datatype.recordv2.RecordV2Builder
-
Adds a new record comprising the specified field values.
- addRecord(String...) - Method in interface com.pushtechnology.diffusion.datatype.recordv2.RecordV2Builder
-
Adds a new record comprising the specified field values.
- addRequestHandler(String, Class<? extends T>, Class<? super R>, Messaging.RequestHandler<T, R>, String...) - Method in interface com.pushtechnology.diffusion.client.features.Messaging
-
Register a request handler to handle requests from other client sessions
for a branch of the message path hierarchy.
- addRoutingSubscriptionHandler(String, SubscriptionControl.RoutingSubscriptionRequest.RoutingHandler) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.SubscriptionControl
-
- addRoutingSubscriptionHandler(String, SubscriptionControl.RoutingSubscriptionRequest.Handler) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.SubscriptionControl
-
- addStream(TopicSelector, Class<? extends V>, Topics.ValueStream<V>) - Method in interface com.pushtechnology.diffusion.client.features.Topics
-
Add a value stream to receive topic events for topics that match a given
TopicSelector and have a value class that matches a specified
type.
- addStream(String, Class<? extends V>, Topics.ValueStream<V>) - Method in interface com.pushtechnology.diffusion.client.features.Topics
-
Add a value stream to receive topic events for topics that match a given
TopicSelector expression and have a value class that matches a
specified type.
- addTimeSeriesStream(TopicSelector, Class<? extends V>, Topics.ValueStream<TimeSeries.Event<V>>) - Method in interface com.pushtechnology.diffusion.client.features.Topics
-
Add a value stream to receive topic events for time series topics that
match a given
TopicSelector and have a compatible time series
event value class.
- addTimeSeriesStream(String, Class<? extends V>, Topics.ValueStream<TimeSeries.Event<V>>) - Method in interface com.pushtechnology.diffusion.client.features.Topics
-
Add a value stream to receive topic events for time series topics that
match a given
TopicSelector expression and have a compatible time
series value class.
- addTopic(String, TopicType) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.TopicControl
-
Request creation of a topic.
- addTopic(String, TopicSpecification) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.TopicControl
-
Request creation of a topic.
- addTopic(String, TopicSpecification, C, TopicControl.AddContextCallback<C>) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.TopicControl
-
- addTopic(String, TopicSpecification, TopicControl.AddCallback) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.TopicControl
-
- AddTopicException(String) - Constructor for exception com.pushtechnology.diffusion.client.features.control.topics.TopicControl.AddTopicException
-
- after(String) - Method in interface com.pushtechnology.diffusion.client.features.Topics.FetchRequest
-
Specifies a logical start point within the topic tree.
- ALL_FIXED_PROPERTIES - Static variable in interface com.pushtechnology.diffusion.client.session.Session
-
This constant can be used instead of a property key in requests for
session property values to indicate that all fixed session
properties are required.
- ALL_TYPES - Static variable in interface com.pushtechnology.diffusion.client.features.Topics.FetchRequest
-
A constant set of all topic types that can be fetched.
- ALL_USER_PROPERTIES - Static variable in interface com.pushtechnology.diffusion.client.session.Session
-
This constant can be used instead of a property key in requests for
session property values to indicate that all user defined session
properties are required.
- allEdits() - Method in interface com.pushtechnology.diffusion.client.features.TimeSeries.RangeQuery
-
Return a copy of this RangeQuery configured to perform an edit range
query with the edit range that selects all edits in the entire time
series.
- allow(Map<String, String>) - Method in interface com.pushtechnology.diffusion.client.security.authentication.Authenticator.Callback
-
Authentication passed - allow the authentication request with
modified fixed session properties and/or specified user-defined
properties.
- allow() - Method in interface com.pushtechnology.diffusion.client.security.authentication.Authenticator.Callback
-
Authentication passed - allow the authentication request with fixed
properties as supplied but no user-defined properties.
- allowAnonymousConnections(Set<String>) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.SystemAuthenticationControl.ScriptBuilder
-
Instruct the system authentication handler to allow anonymous
connections.
- and(UpdateConstraint) - Method in interface com.pushtechnology.diffusion.client.features.UpdateConstraint
-
Returns a composed constraint that represents a logical AND of this
constraint and another.
- ANONYMOUS - Static variable in interface com.pushtechnology.diffusion.client.session.Session
-
- anyOf(String...) - Method in interface com.pushtechnology.diffusion.client.topics.TopicSelectors
-
- anyOf(TopicSelector...) - Method in interface com.pushtechnology.diffusion.client.topics.TopicSelectors
-
Create a SELECTOR_SET selector that matches if any of the
provided selectors match.
- append(SecurityControl.ScriptBuilder) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.SecurityControl.ScriptBuilder
-
Append all the operations of other to this ScriptBuilder.
- append(SystemAuthenticationControl.ScriptBuilder) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.SystemAuthenticationControl.ScriptBuilder
-
Append all the operations of other to this ScriptBuilder.
- append(String, Class<V>, V) - Method in interface com.pushtechnology.diffusion.client.features.TimeSeries
-
Update a time series topic by appending a new value.
- append(String, Class<V>, V, Instant) - Method in interface com.pushtechnology.diffusion.client.features.TimeSeries
-
Update a time series topic by appending a new value with a supplied
timestamp.
- apply(BinaryDelta) - Method in interface com.pushtechnology.diffusion.datatype.binary.Binary
-
Apply a binary delta to this value to create a new value.
- apply(V, D) - Method in interface com.pushtechnology.diffusion.datatype.DeltaType
-
Apply a delta to a value.
- apply(BinaryDelta) - Method in interface com.pushtechnology.diffusion.datatype.json.JSON
-
Apply a binary delta to this JSON value to create a new value.
- applyJsonPatch(String, String) - Method in interface com.pushtechnology.diffusion.client.features.TopicUpdate
-
Applies a JSON Patch to a JSON topic.
- applyJsonPatch(String, String, UpdateConstraint) - Method in interface com.pushtechnology.diffusion.client.features.TopicUpdate
-
Applies a JSON Patch to a JSON topic.
- as(Class<T>) - Method in interface com.pushtechnology.diffusion.client.features.TimeSeries.RangeQuery
-
Return a copy of this RangeQuery with a different query value type.
- asFields() - Method in interface com.pushtechnology.diffusion.datatype.recordv2.RecordV2
-
Returns the data value as a list of fields.
- asInputStream() - Method in interface com.pushtechnology.diffusion.datatype.Bytes
-
Returns a stream that provides the data.
- asJSONString() - Method in interface com.pushtechnology.diffusion.datatype.recordv2.schema.Schema
-
Returns the schema in a JSON format.
- asModel(Schema) - Method in interface com.pushtechnology.diffusion.datatype.recordv2.RecordV2
-
Parses the value into a model based upon a specified schema.
- asRecords() - Method in interface com.pushtechnology.diffusion.datatype.recordv2.RecordV2
-
Returns the data value as a list of lists of strings.
- assignRoles(String, Set<String>) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.SystemAuthenticationControl.ScriptBuilder
-
Change a principal's assigned roles.
- asValidatedModel(Schema) - Method in interface com.pushtechnology.diffusion.datatype.recordv2.RecordV2
-
Parses the value into a model based upon a specified schema.
- asValue() - Method in interface com.pushtechnology.diffusion.datatype.recordv2.model.RecordModel
-
Creates an immutable
RecordV2 object generated from the
model.
- authenticate(String, Credentials, Map<String, String>, Map<String, String>, Authenticator.Callback) - Method in interface com.pushtechnology.diffusion.client.security.authentication.Authenticator
-
Processes an authentication request.
- AuthenticationControl - Interface in com.pushtechnology.diffusion.client.features.control.clients
-
This feature allows a client session to authenticate the credentials of other
sessions.
- AuthenticationControl.ControlAuthenticator - Interface in com.pushtechnology.diffusion.client.features.control.clients
-
A control authenticator.
- AuthenticationException - Exception in com.pushtechnology.diffusion.client.session
-
The session operation failed due to an authentication failure.
- AuthenticationException() - Constructor for exception com.pushtechnology.diffusion.client.session.AuthenticationException
-
Constructor.
- AuthenticationException(String) - Constructor for exception com.pushtechnology.diffusion.client.session.AuthenticationException
-
- AuthenticationException(String, Throwable) - Constructor for exception com.pushtechnology.diffusion.client.session.AuthenticationException
-
- Authenticator - Interface in com.pushtechnology.diffusion.client.security.authentication
-
An authentication handler that processes authentication requests from the
server.
- Authenticator.Callback - Interface in com.pushtechnology.diffusion.client.security.authentication
-
- author() - Method in interface com.pushtechnology.diffusion.client.features.TimeSeries.EventMetadata
-
Server-authenticated identity of the session that created the event.
- Callback - Interface in com.pushtechnology.diffusion.client.callbacks
-
Callback interface that provides responses from the server.
- Callback - Interface in com.pushtechnology.diffusion.client.features
-
- Callback.Default - Class in com.pushtechnology.diffusion.client.callbacks
-
Abstract default callback.
- Callback.Default - Class in com.pushtechnology.diffusion.client.features
-
Deprecated.
Abstract default callback.
- CALLBACK_EXCEPTION - Static variable in class com.pushtechnology.diffusion.client.callbacks.ErrorReason
-
An application callback threw an exception.
- cancel() - Method in interface com.pushtechnology.diffusion.client.features.control.topics.TopicControl.MissingTopicNotification
-
- canReadAs(Class<T>) - Method in interface com.pushtechnology.diffusion.datatype.DataType
-
Test whether this data type is compatible with classOfT.
- changePrincipal(String, Credentials) - Method in interface com.pushtechnology.diffusion.client.features.Security
-
Change the security principal associated with the session.
- changePrincipal(String, Credentials, Security.ChangePrincipalCallback) - Method in interface com.pushtechnology.diffusion.client.features.Security
-
- changePrincipal(String, Credentials, C, Security.ChangePrincipalContextCallback<C>) - Method in interface com.pushtechnology.diffusion.client.features.Security
-
- changeRoles(SessionId, Set<String>, Set<String>) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.ClientControl
-
Changes the assigned roles of another session.
- changeRoles(String, Set<String>, Set<String>) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.ClientControl
-
Allows a session to change the assigned roles of all sessions that
satisfy a given session filter.
- changes(Schema) - Method in interface com.pushtechnology.diffusion.datatype.recordv2.RecordV2Delta
-
Returns a list of the changes represented by the delta with reference to
a specified schema.
- checkRemoteServer(String) - Method in interface com.pushtechnology.diffusion.client.features.control.RemoteServers
-
Check the current state of a named remote server.
- clear() - Method in interface com.pushtechnology.diffusion.datatype.recordv2.RecordV2Builder
-
Clears all current values from the builder allowing it to be reused to
generate new data.
- clearVariableFields(String, int) - Method in interface com.pushtechnology.diffusion.datatype.recordv2.model.MutableRecordModel
-
Remove all optional instances of a variable multiplicity field.
- clearVariableRecords() - Method in interface com.pushtechnology.diffusion.datatype.recordv2.model.MutableRecordModel
-
Removes all optional instances of a variable multiplicity record.
- CLIENT_IP - Static variable in interface com.pushtechnology.diffusion.client.session.Session
-
Session property key for client IP address.
- CLIENT_TYPE - Static variable in interface com.pushtechnology.diffusion.client.session.Session
-
Session property key for client type.
- ClientControl - Interface in com.pushtechnology.diffusion.client.features.control.clients
-
This feature provides the ability for a client session to control other
client sessions.
- ClientControl.ClientCallback - Interface in com.pushtechnology.diffusion.client.features.control.clients
-
- ClientControl.ClientCallback.Default - Class in com.pushtechnology.diffusion.client.features.control.clients
-
Deprecated.
- ClientControl.ClientContextCallback<C> - Interface in com.pushtechnology.diffusion.client.features.control.clients
-
- ClientControl.ClientContextCallback.Default<C> - Class in com.pushtechnology.diffusion.client.features.control.clients
-
Deprecated.
- ClientControl.CloseReason - Enum in com.pushtechnology.diffusion.client.features.control.clients
-
The server's view of why a client session was closed.
- ClientControl.QueueEventHandler - Interface in com.pushtechnology.diffusion.client.features.control.clients
-
- ClientControl.QueueEventHandler.Default - Class in com.pushtechnology.diffusion.client.features.control.clients
-
Deprecated.
- ClientControl.QueueEventStream - Interface in com.pushtechnology.diffusion.client.features.control.clients
-
Handler for client queue events.
- ClientControl.QueueEventStream.Default - Class in com.pushtechnology.diffusion.client.features.control.clients
-
- ClientControl.SessionFilterOperationResult - Interface in com.pushtechnology.diffusion.client.features.control.clients
-
Result of ClientControl operations that identify sessions using a client
filter and provide a result through a
CompletableFuture.
- ClientControl.SessionPropertiesCallback - Interface in com.pushtechnology.diffusion.client.features.control.clients
-
- ClientControl.SessionPropertiesContextCallback<C> - Interface in com.pushtechnology.diffusion.client.features.control.clients
-
- ClientControl.SessionPropertiesListener - Interface in com.pushtechnology.diffusion.client.features.control.clients
-
- ClientControl.SessionPropertiesListener.Default - Class in com.pushtechnology.diffusion.client.features.control.clients
-
Deprecated.
- ClientControl.SessionPropertiesListener.EventType - Enum in com.pushtechnology.diffusion.client.features.control.clients
-
Deprecated.
Event type.
- ClientControl.SessionPropertiesStream - Interface in com.pushtechnology.diffusion.client.features.control.clients
-
The handler for session properties listener notifications.
- ClientControl.SessionPropertiesStream.Default - Class in com.pushtechnology.diffusion.client.features.control.clients
-
- ClientControl.SessionPropertiesStream.EventType - Enum in com.pushtechnology.diffusion.client.features.control.clients
-
Event type.
- close() - Method in interface com.pushtechnology.diffusion.client.callbacks.Registration
-
Request that the handler is unregistered from the server.
- close(SessionId) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.ClientControl
-
Close a client session.
- close(String) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.ClientControl
-
Close all client sessions matching a given session filter.
- close(SessionId, ClientControl.ClientCallback) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.ClientControl
-
- close(SessionId, C, ClientControl.ClientContextCallback<C>) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.ClientControl
-
- close() - Method in interface com.pushtechnology.diffusion.client.features.RegisteredHandler
-
Deprecated.
Request that the handler is unregistered from the server.
- close() - Method in interface com.pushtechnology.diffusion.client.session.Session
-
Close the session.
- CLUSTER_REPARTITION - Static variable in class com.pushtechnology.diffusion.client.callbacks.ErrorReason
-
A cluster operation failed because partition ownership changed during
processing.
- CLUSTER_ROUTING - Static variable in class com.pushtechnology.diffusion.client.callbacks.ErrorReason
-
A cluster operation failed to be routed to a server within the cluster
due to a communication failure, or the server that owns a partition is
not currently known.
- ClusterRepartitionException - Exception in com.pushtechnology.diffusion.client.features
-
Indicates a cluster operation failed because partition ownership changed
during processing.
- ClusterRepartitionException() - Constructor for exception com.pushtechnology.diffusion.client.features.ClusterRepartitionException
-
Constructor.
- ClusterRepartitionException(String) - Constructor for exception com.pushtechnology.diffusion.client.features.ClusterRepartitionException
-
Constructor.
- ClusterRoutingException - Exception in com.pushtechnology.diffusion.client.features
-
Indicates a cluster operation failed to be routed to a server within the
cluster due to a communication failure, or the server that owns a partition
is not currently known.
- ClusterRoutingException() - Constructor for exception com.pushtechnology.diffusion.client.features.ClusterRoutingException
-
Constructor.
- ClusterRoutingException(String) - Constructor for exception com.pushtechnology.diffusion.client.features.ClusterRoutingException
-
Constructor.
- com.pushtechnology.diffusion.client - package com.pushtechnology.diffusion.client
-
Client API.
- com.pushtechnology.diffusion.client.callbacks - package com.pushtechnology.diffusion.client.callbacks
-
Client API : Callback Interfaces.
- com.pushtechnology.diffusion.client.features - package com.pushtechnology.diffusion.client.features
-
Client API : Standard Features.
- com.pushtechnology.diffusion.client.features.control - package com.pushtechnology.diffusion.client.features.control
-
Client API : Control Features.
- com.pushtechnology.diffusion.client.features.control.clients - package com.pushtechnology.diffusion.client.features.control.clients
-
Client API : Client Control Features.
- com.pushtechnology.diffusion.client.features.control.topics - package com.pushtechnology.diffusion.client.features.control.topics
-
Client API : Topic Control Features.
- com.pushtechnology.diffusion.client.features.control.topics.views - package com.pushtechnology.diffusion.client.features.control.topics.views
-
Client API : Topic View Features.
- com.pushtechnology.diffusion.client.security - package com.pushtechnology.diffusion.client.security
-
Client API : Security.
- com.pushtechnology.diffusion.client.security.authentication - package com.pushtechnology.diffusion.client.security.authentication
-
Client API : Security - Authentication.
- com.pushtechnology.diffusion.client.session - package com.pushtechnology.diffusion.client.session
-
Client API : Sessions.
- com.pushtechnology.diffusion.client.session.proxy - package com.pushtechnology.diffusion.client.session.proxy
-
Client API : Proxy.
- com.pushtechnology.diffusion.client.session.reconnect - package com.pushtechnology.diffusion.client.session.reconnect
-
Client API : Reconnect.
- com.pushtechnology.diffusion.client.topics - package com.pushtechnology.diffusion.client.topics
-
Client API : Topics.
- com.pushtechnology.diffusion.client.topics.details - package com.pushtechnology.diffusion.client.topics.details
-
Client API : Topic Specifications.
- com.pushtechnology.diffusion.client.types - package com.pushtechnology.diffusion.client.types
-
Client API : Common Types.
- com.pushtechnology.diffusion.datatype - package com.pushtechnology.diffusion.datatype
-
Data Types.
- com.pushtechnology.diffusion.datatype.binary - package com.pushtechnology.diffusion.datatype.binary
-
Binary Data Type.
- com.pushtechnology.diffusion.datatype.json - package com.pushtechnology.diffusion.datatype.json
-
JSON Data Type.
- com.pushtechnology.diffusion.datatype.recordv2 - package com.pushtechnology.diffusion.datatype.recordv2
-
RecordV2 Data Type.
- com.pushtechnology.diffusion.datatype.recordv2.model - package com.pushtechnology.diffusion.datatype.recordv2.model
-
RecordV2 Data Type : Data Model.
- com.pushtechnology.diffusion.datatype.recordv2.schema - package com.pushtechnology.diffusion.datatype.recordv2.schema
-
RecordV2 Data Type : Schemas.
- COMMUNICATION_FAILURE - Static variable in class com.pushtechnology.diffusion.client.callbacks.ErrorReason
-
Communication with the server failed.
- COMPRESSION - Static variable in interface com.pushtechnology.diffusion.client.topics.details.TopicSpecification
-
Key of the topic property that allows the compression policy to be set
on a per-topic basis.
- CONFLATION - Static variable in interface com.pushtechnology.diffusion.client.topics.details.TopicSpecification
-
Key of the topic property that specifies the conflation policy of the
topic.
- connectionOption(RemoteServers.RemoteServer.ConnectionOption, String) - Method in interface com.pushtechnology.diffusion.client.features.control.RemoteServers.RemoteServer.Builder
-
Specifies a single connection option.
- connectionOptions(Map<RemoteServers.RemoteServer.ConnectionOption, String>) - Method in interface com.pushtechnology.diffusion.client.features.control.RemoteServers.RemoteServer.Builder
-
- connectionTimeout(int) - Method in interface com.pushtechnology.diffusion.client.session.SessionFactory
-
Sets the connection timeout.
- CONNECTOR - Static variable in interface com.pushtechnology.diffusion.client.session.Session
-
Session property key for connector name.
- ContextCallback<C> - Interface in com.pushtechnology.diffusion.client.callbacks
-
- ContextCallback<C> - Interface in com.pushtechnology.diffusion.client.features
-
- ContextCallback.Default<C> - Class in com.pushtechnology.diffusion.client.callbacks
-
Deprecated.
Abstract default callback.
- ContextCallback.Default<C> - Class in com.pushtechnology.diffusion.client.features
-
Deprecated.
Abstract default callback.
- ContextStream<C> - Interface in com.pushtechnology.diffusion.client.callbacks
-
- ContextStream.Default<C> - Class in com.pushtechnology.diffusion.client.callbacks
-
Deprecated.
Abstract default callback.
- copyTo(OutputStream) - Method in interface com.pushtechnology.diffusion.datatype.Bytes
-
Write the bytes to an output stream.
- COUNTRY - Static variable in interface com.pushtechnology.diffusion.client.session.Session
-
Session property key for country code.
- create(String, String) - Method in interface com.pushtechnology.diffusion.client.features.control.Metrics.SessionMetricCollector.Builder
-
- create(String, String) - Method in interface com.pushtechnology.diffusion.client.features.control.Metrics.TopicMetricCollector.Builder
-
- create(String, String) - Method in interface com.pushtechnology.diffusion.client.features.control.RemoteServers.RemoteServer.Builder
-
Creates a remote server object using the current values known to
this builder.
- create(String) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.SessionTrees.BranchMappingTable.Builder
-
Create a new branch mapping table.
- createHandler(SessionAttributes) - Method in interface com.pushtechnology.diffusion.client.session.proxy.HTTPProxyAuthentication
-
Create a challenge handler using this proxy authentication scheme.
- createMutableModel() - Method in interface com.pushtechnology.diffusion.datatype.recordv2.schema.Schema
-
Create a mutable model based upon the schema.
- createRemoteServer(RemoteServers.RemoteServer) - Method in interface com.pushtechnology.diffusion.client.features.control.RemoteServers
-
Create a new remote server instance at the server.
- createRemoteServer(String, String, String, Credentials) - Method in interface com.pushtechnology.diffusion.client.features.control.RemoteServers
-
- createRemoteServer(String, String, String, Credentials, Map<RemoteServers.RemoteServer.ConnectionOption, String>) - Method in interface com.pushtechnology.diffusion.client.features.control.RemoteServers
-
- createTopicView(String, String) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.views.TopicViews
-
Create a new named topic view.
- createUpdateStream(String, Class<T>) - Method in interface com.pushtechnology.diffusion.client.features.TopicUpdate
-
- createUpdateStream(String, Class<T>, UpdateConstraint) - Method in interface com.pushtechnology.diffusion.client.features.TopicUpdate
-
- createUpdateStream(String, TopicSpecification, Class<T>) - Method in interface com.pushtechnology.diffusion.client.features.TopicUpdate
-
Creates an
update stream to use for creating and
updating a specific topic.
- createUpdateStream(String, TopicSpecification, Class<T>, UpdateConstraint) - Method in interface com.pushtechnology.diffusion.client.features.TopicUpdate
-
Creates an
update stream to use for creating and
updating a specific topic.
- credentials() - Static method in enum com.pushtechnology.diffusion.client.Diffusion
-
Returns shared credentials factory to use for creating credentials.
- credentials(Credentials) - Method in interface com.pushtechnology.diffusion.client.features.control.RemoteServers.RemoteServer.Builder
-
Specifies the credentials to use when connecting to the primary
server.
- credentials(Credentials) - Method in interface com.pushtechnology.diffusion.client.session.SessionFactory
-
Set credentials.
- Credentials - Interface in com.pushtechnology.diffusion.client.types
-
Immutable value containing the proof material to support an authentication
request.
- Credentials.Factory - Interface in com.pushtechnology.diffusion.client.types
-
Factory for the standard credential types.
- Credentials.Type - Enum in com.pushtechnology.diffusion.client.types
-
Type code indicated the type of the credentials.
- custom(byte[]) - Method in interface com.pushtechnology.diffusion.client.types.Credentials.Factory
-
- customCredentials(byte[]) - Method in interface com.pushtechnology.diffusion.client.session.SessionFactory
-
- DataType<V> - Interface in com.pushtechnology.diffusion.datatype
-
A data type is specified for a particular class (its value class).
- dataTypes() - Static method in enum com.pushtechnology.diffusion.client.Diffusion
-
Returns data type implementations.
- DataTypes - Interface in com.pushtechnology.diffusion.datatype
-
Diffusion data type implementations.
- decimal(String, int) - Method in interface com.pushtechnology.diffusion.datatype.recordv2.schema.SchemaBuilder
-
Add a single occurrence decimal field to the current record.
- decimal(String, int, int) - Method in interface com.pushtechnology.diffusion.datatype.recordv2.schema.SchemaBuilder
-
Add a fixed multiplicity decimal field to the current record.
- decimal(String, int, int, int) - Method in interface com.pushtechnology.diffusion.datatype.recordv2.schema.SchemaBuilder
-
Add a decimal field to the current record.
- Default() - Constructor for class com.pushtechnology.diffusion.client.callbacks.Callback.Default
-
- Default() - Constructor for class com.pushtechnology.diffusion.client.callbacks.ContextCallback.Default
-
Deprecated.
- Default() - Constructor for class com.pushtechnology.diffusion.client.callbacks.ContextStream.Default
-
Deprecated.
- Default() - Constructor for class com.pushtechnology.diffusion.client.callbacks.ServerHandler.Default
-
Deprecated.
- Default() - Constructor for class com.pushtechnology.diffusion.client.callbacks.Stream.Default
-
- Default() - Constructor for class com.pushtechnology.diffusion.client.features.Callback.Default
-
Deprecated.
- Default() - Constructor for class com.pushtechnology.diffusion.client.features.ContextCallback.Default
-
Deprecated.
- Default() - Constructor for class com.pushtechnology.diffusion.client.features.control.clients.ClientControl.ClientCallback.Default
-
Deprecated.
- Default() - Constructor for class com.pushtechnology.diffusion.client.features.control.clients.ClientControl.ClientContextCallback.Default
-
Deprecated.
- Default() - Constructor for class com.pushtechnology.diffusion.client.features.control.clients.ClientControl.QueueEventHandler.Default
-
Deprecated.
- Default() - Constructor for class com.pushtechnology.diffusion.client.features.control.clients.ClientControl.QueueEventStream.Default
-
- Default() - Constructor for class com.pushtechnology.diffusion.client.features.control.clients.ClientControl.SessionPropertiesListener.Default
-
Deprecated.
- Default() - Constructor for class com.pushtechnology.diffusion.client.features.control.clients.ClientControl.SessionPropertiesStream.Default
-
- Default() - Constructor for class com.pushtechnology.diffusion.client.features.control.topics.SubscriptionControl.RoutingSubscriptionRequest.Handler.Default
-
Deprecated.
- Default() - Constructor for class com.pushtechnology.diffusion.client.features.control.topics.SubscriptionControl.RoutingSubscriptionRequest.RoutingHandler.Default
-
Deprecated.
- Default() - Constructor for class com.pushtechnology.diffusion.client.features.control.topics.SubscriptionControl.SubscriptionByFilterCallback.Default
-
Deprecated.
- Default() - Constructor for class com.pushtechnology.diffusion.client.features.control.topics.SubscriptionControl.SubscriptionByFilterContextCallback.Default
-
Deprecated.
- Default() - Constructor for class com.pushtechnology.diffusion.client.features.control.topics.SubscriptionControl.SubscriptionCallback.Default
-
Deprecated.
- Default() - Constructor for class com.pushtechnology.diffusion.client.features.control.topics.SubscriptionControl.SubscriptionContextCallback.Default
-
Deprecated.
- Default() - Constructor for class com.pushtechnology.diffusion.client.features.control.topics.TopicControl.AddCallback.Default
-
Deprecated.
- Default() - Constructor for class com.pushtechnology.diffusion.client.features.control.topics.TopicControl.AddContextCallback.Default
-
Deprecated.
- Default() - Constructor for class com.pushtechnology.diffusion.client.features.control.topics.TopicControl.MissingTopicHandler.Default
-
Deprecated.
- Default() - Constructor for class com.pushtechnology.diffusion.client.features.control.topics.TopicControl.MissingTopicNotificationStream.Default
-
- Default() - Constructor for class com.pushtechnology.diffusion.client.features.control.topics.TopicControl.RemovalCallback.Default
-
Deprecated.
- Default() - Constructor for class com.pushtechnology.diffusion.client.features.control.topics.TopicControl.RemovalContextCallback.Default
-
Deprecated.
- Default() - Constructor for class com.pushtechnology.diffusion.client.features.control.topics.TopicNotifications.TopicNotificationListener.Default
-
- Default() - Constructor for class com.pushtechnology.diffusion.client.features.Messaging.FilteredRequestCallback.Default
-
- Default() - Constructor for class com.pushtechnology.diffusion.client.features.Pings.PingCallback.Default
-
Deprecated.
- Default() - Constructor for class com.pushtechnology.diffusion.client.features.Pings.PingContextCallback.Default
-
Deprecated.
- Default() - Constructor for class com.pushtechnology.diffusion.client.features.Security.ChangePrincipalCallback.Default
-
Deprecated.
- Default() - Constructor for class com.pushtechnology.diffusion.client.features.Security.ChangePrincipalContextCallback.Default
-
Deprecated.
- Default() - Constructor for class com.pushtechnology.diffusion.client.features.ServerHandler.Default
-
Deprecated.
- Default() - Constructor for class com.pushtechnology.diffusion.client.features.Topics.CompletionCallback.Default
-
Deprecated.
- Default() - Constructor for class com.pushtechnology.diffusion.client.features.Topics.CompletionContextCallback.Default
-
Deprecated.
- Default() - Constructor for class com.pushtechnology.diffusion.client.features.Topics.SubscriberStream.Default
-
- Default() - Constructor for class com.pushtechnology.diffusion.client.features.Topics.ValueStream.Default
-
- Default() - Constructor for class com.pushtechnology.diffusion.client.features.TopicTreeHandler.Default
-
Deprecated.
- Default() - Constructor for class com.pushtechnology.diffusion.client.session.Session.ErrorHandler.Default
-
- Default() - Constructor for class com.pushtechnology.diffusion.client.session.Session.Listener.Default
-
- DEFAULT_CONNECTION_TIMEOUT - Static variable in interface com.pushtechnology.diffusion.client.session.SessionAttributes
-
The default connection timeout = 2 seconds.
- DEFAULT_INPUT_BUFFER_SIZE - Static variable in interface com.pushtechnology.diffusion.client.session.SessionAttributes
-
The default size of socket and message input buffers in bytes.
- DEFAULT_MAXIMUM_MESSAGE_SIZE - Static variable in interface com.pushtechnology.diffusion.client.session.SessionAttributes
-
The default maximum message size in bytes.
- DEFAULT_MAXIMUM_QUEUE_SIZE - Static variable in interface com.pushtechnology.diffusion.client.session.SessionAttributes
-
The default maximum outbound queue size in messages.
- DEFAULT_OUTPUT_BUFFER_SIZE - Static variable in interface com.pushtechnology.diffusion.client.session.SessionAttributes
-
The default size of socket and message output buffers in bytes.
- DEFAULT_RECONNECTION_TIMEOUT - Static variable in interface com.pushtechnology.diffusion.client.session.SessionAttributes
-
The default reconnection timeout = 60 seconds.
- DEFAULT_RECOVERY_BUFFER_SIZE - Static variable in interface com.pushtechnology.diffusion.client.session.SessionAttributes
-
The default recovery buffer size in messages.
- DEFAULT_REQUEST_PATH - Static variable in interface com.pushtechnology.diffusion.client.session.SessionAttributes
-
The default request path.
- DEFAULT_WRITE_TIMEOUT - Static variable in interface com.pushtechnology.diffusion.client.session.SessionAttributes
-
The default write timeout for blocking writes = 2 seconds.
- defer() - Method in interface com.pushtechnology.diffusion.client.features.control.topics.SubscriptionControl.RoutingSubscriptionRequest
-
Deprecated.
Defer the handling of this subscription request.
- deisolatePath(String) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.SecurityControl.ScriptBuilder
-
Re-instate inheritance of path permission assignments from parents of
the given path.
- deltaType(String) - Method in interface com.pushtechnology.diffusion.datatype.DataType
-
- deltaType(Class<D>) - Method in interface com.pushtechnology.diffusion.datatype.DataType
-
- DeltaType<V,D> - Interface in com.pushtechnology.diffusion.datatype
-
Optional extension provided by
DataType implementations that support
incremental changes to values.
- deny() - Method in interface com.pushtechnology.diffusion.client.security.authentication.Authenticator.Callback
-
Authentication failed - deny the authentication request.
- denyAnonymousConnections() - Method in interface com.pushtechnology.diffusion.client.features.control.clients.SystemAuthenticationControl.ScriptBuilder
-
Instruct the system authentication handler to deny anonymous
connections.
- descendants(String) - Method in interface com.pushtechnology.diffusion.datatype.json.JSONDelta.ChangeMap
-
Returns a view of the portion of this map whose keys are descendants
of pointer.
- deselect(TopicSelector) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.TopicNotifications.NotificationRegistration
-
Request to stop receiving notifications for all topics matched by the
given selector.
- deselect(String) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.TopicNotifications.NotificationRegistration
-
Request to stop receiving notifications for all topics matched by the
given selector.
- diff(Binary) - Method in interface com.pushtechnology.diffusion.datatype.binary.Binary
-
Compare this value with an earlier version to calculate a binary delta.
- diff(V, V) - Method in interface com.pushtechnology.diffusion.datatype.DeltaType
-
Create a delta from two values.
- diff(JSON) - Method in interface com.pushtechnology.diffusion.datatype.json.JSON
-
Compare this JSON value with an earlier version to calculate a structural
delta.
- diff(RecordV2) - Method in interface com.pushtechnology.diffusion.datatype.recordv2.RecordV2
-
Compare this value with an earlier version to calculate a structural
delta.
- Diffusion - Enum in com.pushtechnology.diffusion.client
-
Provides facilities that are shared between sessions.
- Diffusion.Implementation - Interface in com.pushtechnology.diffusion.client
-
The contract with the implementation.
- DONT_RETAIN_VALUE - Static variable in interface com.pushtechnology.diffusion.client.topics.details.TopicSpecification
-
Key of the topic property that specifies a topic should not retain its
last value.
- DOUBLE_DATATYPE_NAME - Static variable in interface com.pushtechnology.diffusion.datatype.DataTypes
-
Double data type name.
- doubleFloat() - Method in interface com.pushtechnology.diffusion.datatype.DataTypes
-
Data type that supports double-precision floating point numbers.
- GATEWAY_ID - Static variable in interface com.pushtechnology.diffusion.client.session.Session
-
Session property key for gateway client identifier.
- GATEWAY_TYPE - Static variable in interface com.pushtechnology.diffusion.client.session.Session
-
Session property key for gateway client type.
- get() - Method in interface com.pushtechnology.diffusion.client.features.UpdateStream
-
Return the latest value of the topic set using this update stream.
- get(String, int, String, int) - Method in interface com.pushtechnology.diffusion.datatype.recordv2.model.RecordModel
-
Get a field value.
- get(String) - Method in interface com.pushtechnology.diffusion.datatype.recordv2.model.RecordModel
-
Get a field value.
- getAnonymousAction() - Method in interface com.pushtechnology.diffusion.client.features.control.clients.SystemAuthenticationControl.SystemAuthenticationConfiguration
-
Returns the action to take for anonymous connection attempts.
- getAssignedRoles() - Method in interface com.pushtechnology.diffusion.client.features.control.clients.SystemAuthenticationControl.SystemPrincipal
-
Returns the roles that the system authentication handler will assign
to the principal.
- getAttributes() - Method in interface com.pushtechnology.diffusion.client.session.Session
-
Returns the session attributes.
- getBranchMappings() - Method in interface com.pushtechnology.diffusion.client.features.control.topics.SessionTrees.BranchMappingTable
-
Returns the branch mappings.
- getBranchMappingTable(String) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.SessionTrees
-
Retrieve a branch mapping table from the server.
- getByClass(Class<V>) - Method in interface com.pushtechnology.diffusion.datatype.DataTypes
-
Obtain a
DataType implementation by class.
- getByName(String) - Method in interface com.pushtechnology.diffusion.datatype.DataTypes
-
Obtain a
DataType implementation by type name.
- getColumn() - Method in interface com.pushtechnology.diffusion.client.types.ErrorReport
-
- getConnectionOptions() - Method in interface com.pushtechnology.diffusion.client.features.control.RemoteServers.RemoteServer
-
Return the remote server connection options.
- getConnectionState() - Method in interface com.pushtechnology.diffusion.client.features.control.RemoteServers.CheckRemoteServerResult
-
Returns the connection state of the remote server.
- getConnectionTimeout() - Method in interface com.pushtechnology.diffusion.client.session.SessionAttributes
-
Returns the connection timeout value.
- getCredentialsFactory() - Method in interface com.pushtechnology.diffusion.client.Diffusion.Implementation
-
- getDataTypes() - Method in interface com.pushtechnology.diffusion.client.Diffusion.Implementation
-
- getDefaultPathPermissions() - Method in interface com.pushtechnology.diffusion.client.features.control.clients.SecurityControl.Role
-
Returns the set of default path permissions assigned to the role.
- getDefaultTopicPermissions() - Method in interface com.pushtechnology.diffusion.client.features.control.clients.SecurityControl.Role
-
- getDescription() - Method in class com.pushtechnology.diffusion.client.callbacks.ErrorReason
-
Description of the error reason, may be context-specific.
- getExpression() - Method in interface com.pushtechnology.diffusion.client.topics.TopicSelector
-
The expression associated with this selector.
- getExpressionPrefix() - Method in enum com.pushtechnology.diffusion.client.topics.TopicSelector.Type
-
The expression prefix character used for this type.
- getFailureMessage() - Method in interface com.pushtechnology.diffusion.client.features.control.RemoteServers.CheckRemoteServerResult
-
- getFields() - Method in interface com.pushtechnology.diffusion.datatype.recordv2.schema.Schema.Record
-
Returns an immutable, ordered list of field definitions.
- getGlobalPermissions() - Method in interface com.pushtechnology.diffusion.client.features.control.clients.SecurityControl.Role
-
Returns the set of global permissions assigned to the role.
- getGlobalPermissions() - Method in interface com.pushtechnology.diffusion.client.features.Security
-
Query the global permissions assigned to the calling session.
- getGroupByProperties() - Method in interface com.pushtechnology.diffusion.client.features.control.Metrics.SessionMetricCollector
-
Returns the list of properties to group by.
- getHttpProxyAuth() - Method in interface com.pushtechnology.diffusion.client.session.SessionAttributes
-
Returns the proxy authenticator used to route a connection to the server
via an HTTP proxy.
- getHttpProxyHost() - Method in interface com.pushtechnology.diffusion.client.session.SessionAttributes
-
Returns the proxy host name used to route a connection to the server via
an HTTP proxy.
- getHttpProxyPort() - Method in interface com.pushtechnology.diffusion.client.session.SessionAttributes
-
Returns the proxy port used to route a connection to the server via an
HTTP proxy.
- getIncludedRoles() - Method in interface com.pushtechnology.diffusion.client.features.control.clients.SecurityControl.Role
-
Returns a set of roles included within the role.
- getInputBufferSize() - Method in interface com.pushtechnology.diffusion.client.session.SessionAttributes
-
Returns the input buffer size for socket connection buffers and message
receiving buffers.
- getIsolatedPaths() - Method in interface com.pushtechnology.diffusion.client.features.control.clients.SecurityControl.SecurityConfiguration
-
Returns the set of isolated paths.
- getLine() - Method in interface com.pushtechnology.diffusion.client.types.ErrorReport
-
- getLocalSocketAddress() - Method in interface com.pushtechnology.diffusion.client.session.SessionAttributes
-
Returns the local socket address.
- getLockingPrincipal() - Method in interface com.pushtechnology.diffusion.client.features.control.clients.SecurityControl.Role
-
Returns an
Optional, if the role is locked this will return
the name of the principal that can update the role.
- getLockingPrincipal() - Method in interface com.pushtechnology.diffusion.client.features.control.clients.SystemAuthenticationControl.SystemPrincipal
-
Returns the name of the principal this principal is locked by.
- getMax() - Method in interface com.pushtechnology.diffusion.datatype.recordv2.schema.Schema.Node
-
Returns maximum number of occurrences.
- getMaximumConversations() - Method in interface com.pushtechnology.diffusion.client.session.proxy.HTTPProxyAuthentication.ChallengeHandler
-
This method returns the maximum number of HTTP transactions permitted
by the authentication method before authentication fails.
- getMaximumMessageSize() - Method in interface com.pushtechnology.diffusion.client.session.SessionAttributes
-
Returns the maximum message size that will be accepted by this session.
- getMaximumQueueSize() - Method in interface com.pushtechnology.diffusion.client.session.SessionAttributes
-
Returns the maximum size of the outbound message queue for the
connection.
- getMessage() - Method in interface com.pushtechnology.diffusion.client.session.Session.SessionError
-
Returns a description of the error.
- getMessage() - Method in interface com.pushtechnology.diffusion.client.types.ErrorReport
-
- getMin() - Method in interface com.pushtechnology.diffusion.datatype.recordv2.schema.Schema.Node
-
Returns minimum number of occurrences.
- getMissingTopicNotificationFilter() - Method in interface com.pushtechnology.diffusion.client.features.control.RemoteServers.RemoteServer
-
Return the missing topic notification filter expression or null if
one has not been specified.
- getName() - Method in interface com.pushtechnology.diffusion.client.features.control.clients.SecurityControl.Role
-
Returns the role name.
- getName() - Method in interface com.pushtechnology.diffusion.client.features.control.clients.SystemAuthenticationControl.SystemPrincipal
-
Returns the system principal name.
- getName() - Method in interface com.pushtechnology.diffusion.client.features.control.Metrics.MetricCollector
-
Returns the name of the metric collector.
- getName() - Method in interface com.pushtechnology.diffusion.client.features.control.RemoteServers.RemoteServer
-
Return the remote server name.
- getName() - Method in interface com.pushtechnology.diffusion.client.features.control.topics.views.TopicView
-
The name of the topic view.
- getName() - Method in interface com.pushtechnology.diffusion.client.session.Session.SessionLock
-
- getName() - Method in interface com.pushtechnology.diffusion.datatype.DeltaType
-
Returns the external identifier for this delta type.
- getName() - Method in interface com.pushtechnology.diffusion.datatype.recordv2.schema.Schema.Node
-
Returns the node name.
- getOutputBufferSize() - Method in interface com.pushtechnology.diffusion.client.session.SessionAttributes
-
Returns the output buffer size for socket connection buffers and message
sending buffers.
- getPath() - Method in interface com.pushtechnology.diffusion.client.features.Messaging.RequestHandler.RequestContext
-
Returns the message path of the request.
- getPath() - Method in interface com.pushtechnology.diffusion.client.topics.TopicPathSelector
-
Return the associated topic path.
- getPathPermissions() - Method in interface com.pushtechnology.diffusion.client.features.control.clients.SecurityControl.Role
-
Returns a map of path to path permission assignments for the
role.
- getPathPermissions(String) - Method in interface com.pushtechnology.diffusion.client.features.Security
-
- getPathPrefix() - Method in interface com.pushtechnology.diffusion.client.topics.TopicSelector
-
Get the topic path prefix from this selector pattern.
- getPermissionsForPath(String) - Method in interface com.pushtechnology.diffusion.client.features.Security
-
Query the path permissions assigned to the calling session on a given
path.
- getPrincipal() - Method in interface com.pushtechnology.diffusion.client.features.control.RemoteServers.RemoteServer
-
Return the principal used for the remote server connection.
- getPrincipal() - Method in interface com.pushtechnology.diffusion.client.session.Session
-
Returns the name of the security principal requested when opening the
session.
- getPrincipals() - Method in interface com.pushtechnology.diffusion.client.features.control.clients.SystemAuthenticationControl.SystemAuthenticationConfiguration
-
Returns the system principals stored on the server.
- getProperties() - Method in interface com.pushtechnology.diffusion.client.topics.details.TopicSpecification
-
Returns the topic properties.
- getProxyAuthenticationFactory() - Method in interface com.pushtechnology.diffusion.client.Diffusion.Implementation
-
- getReasonCode() - Method in class com.pushtechnology.diffusion.client.callbacks.ErrorReason
-
A code that uniquely identifies this reason.
- getReconnectionStrategy() - Method in interface com.pushtechnology.diffusion.client.session.SessionAttributes
-
Returns the reconnection strategy.
- getReconnectionTimeout() - Method in interface com.pushtechnology.diffusion.client.session.SessionAttributes
-
Returns the reconnection timeout.
- getRecords() - Method in interface com.pushtechnology.diffusion.datatype.recordv2.schema.Schema
-
Returns an immutable, ordered list of record definitions.
- getRecoveryBufferSize() - Method in interface com.pushtechnology.diffusion.client.session.SessionAttributes
-
Returns the maximum number of sent messages that can be recovered on
reconnection.
- getRegex() - Method in interface com.pushtechnology.diffusion.client.features.control.clients.SystemAuthenticationControl.SessionPropertyValidation.MatchesSessionPropertyValidation
-
Returns the regular expression.
- getRemovedCount() - Method in interface com.pushtechnology.diffusion.client.features.control.topics.TopicControl.TopicRemovalResult
-
The integer returned represents the number of topics removed by the
operation.
- getReports() - Method in exception com.pushtechnology.diffusion.client.features.ErrorReportsException
-
- getRequestedTransports() - Method in interface com.pushtechnology.diffusion.client.session.SessionAttributes
-
Returns the transports the session will use to connect to the server.
- getRequestPath() - Method in interface com.pushtechnology.diffusion.client.session.SessionAttributes
-
Returns the path used for any HTTP requests made by the session.
- getResponse(Map<String, String>) - Method in interface com.pushtechnology.diffusion.client.session.proxy.HTTPProxyAuthentication.ChallengeHandler
-
Called when a challenge from the proxy is received.
- getRoles() - Method in interface com.pushtechnology.diffusion.client.features.control.clients.SecurityControl.SecurityConfiguration
-
Returns a list of the roles defined including their permissions
assignments and included roles.
- getRoles() - Method in interface com.pushtechnology.diffusion.client.features.control.topics.views.TopicView
-
The roles used by the view when evaluating permissions.
- getRolesForAnonymousSessions() - Method in interface com.pushtechnology.diffusion.client.features.control.clients.SecurityControl.SecurityConfiguration
-
Returns the default set of roles to be assigned to anonymous
sessions.
- getRolesForAnonymousSessions() - Method in interface com.pushtechnology.diffusion.client.features.control.clients.SystemAuthenticationControl.SystemAuthenticationConfiguration
-
Returns the roles the system authentication handler will assign to
anonymous sessions.
- getRolesForNamedSessions() - Method in interface com.pushtechnology.diffusion.client.features.control.clients.SecurityControl.SecurityConfiguration
-
Returns the default set of roles to be assigned to named sessions.
- getRoundTripTime() - Method in interface com.pushtechnology.diffusion.client.features.Pings.PingDetails
-
Round trip time in milliseconds from when the ping was sent to
the time the response was received.
- getScale() - Method in interface com.pushtechnology.diffusion.datatype.recordv2.schema.Schema.Field
-
Returns the scale of a
decimal field or 0 for
other types.
- getScope() - Method in interface com.pushtechnology.diffusion.client.session.Session.SessionLock
-
The scope of the lock.
- getSecurity() - Method in interface com.pushtechnology.diffusion.client.features.control.clients.SecurityControl
-
Obtain the current contents of the security store.
- getSecurity(SecurityControl.ConfigurationCallback) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.SecurityControl
-
- getSecurity(C, SecurityControl.ConfigurationContextCallback<C>) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.SecurityControl
-
- getSequence() - Method in interface com.pushtechnology.diffusion.client.session.Session.SessionLock
-
A value that identifies the acquisition of the lock with the given
name.
- getServerHost() - Method in interface com.pushtechnology.diffusion.client.session.SessionAttributes
-
Returns the host name or IP of the server the session will connect to.
- getServerNames() - Method in interface com.pushtechnology.diffusion.client.features.control.topics.TopicControl.MissingTopicNotification
-
Returns a list of the names of the servers through which the
notification has been routed.
- getServerPort() - Method in interface com.pushtechnology.diffusion.client.session.SessionAttributes
-
Returns the port of the server the session will connect to.
- getServerURL() - Method in interface com.pushtechnology.diffusion.client.session.SessionAttributes
-
Returns the URL used to create the session.
- getSession() - Method in interface com.pushtechnology.diffusion.client.session.Feature
-
This returns the session that the feature applies to.
- getSessionFactory() - Method in interface com.pushtechnology.diffusion.client.Diffusion.Implementation
-
- getSessionFilter() - Method in interface com.pushtechnology.diffusion.client.features.control.Metrics.SessionMetricCollector
-
Returns the session filter.
- getSessionFilter() - Method in interface com.pushtechnology.diffusion.client.features.control.topics.SessionTrees.BranchMapping
-
Returns the session filter.
- getSessionId() - Method in interface com.pushtechnology.diffusion.client.features.control.topics.SubscriptionControl.RoutingSubscriptionRequest
-
Deprecated.
Identifies the session making the subscription request.
- getSessionId() - Method in interface com.pushtechnology.diffusion.client.features.control.topics.TopicControl.MissingTopicNotification
-
Returns the identity of the session that made the request.
- getSessionId() - Method in interface com.pushtechnology.diffusion.client.features.Messaging.RequestHandler.RequestContext
-
SessionId of the session that sent the request.
- getSessionId() - Method in interface com.pushtechnology.diffusion.client.session.Session
-
Returns the unique identifier for the session as assigned by the (first)
server it connects to.
- getSessionProperties(SessionId, Collection<String>) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.ClientControl
-
Query the server for property values of a specified client session.
- getSessionProperties(SessionId, Collection<String>, ClientControl.SessionPropertiesCallback) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.ClientControl
-
- getSessionProperties(SessionId, Collection<String>, C, ClientControl.SessionPropertiesContextCallback<C>) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.ClientControl
-
- getSessionProperties() - Method in interface com.pushtechnology.diffusion.client.features.control.topics.TopicControl.MissingTopicNotification
-
Returns the session properties of the session that made the request.
- getSessionProperties() - Method in interface com.pushtechnology.diffusion.client.features.Messaging.RequestHandler.RequestContext
-
Session properties of the session that sent the request.
- getSessionTreeBranch() - Method in interface com.pushtechnology.diffusion.client.features.control.topics.SessionTrees.BranchMappingTable
-
Returns the branch of the session tree to which this table is bound.
- getSpecification() - Method in interface com.pushtechnology.diffusion.client.features.control.topics.views.TopicView
-
- getSslContext() - Method in interface com.pushtechnology.diffusion.client.session.SessionAttributes
-
Returns the SSL context for secure connections.
- getState() - Method in interface com.pushtechnology.diffusion.client.session.Session
-
Returns the current state of the session.
- getSystemAuthentication() - Method in interface com.pushtechnology.diffusion.client.features.control.clients.SystemAuthenticationControl
-
Obtain the current contents of the store.
- getSystemAuthentication(SystemAuthenticationControl.ConfigurationCallback) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.SystemAuthenticationControl
-
- getSystemAuthentication(C, SystemAuthenticationControl.ConfigurationContextCallback<C>) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.SystemAuthenticationControl
-
- getTimestamp() - Method in interface com.pushtechnology.diffusion.client.features.Pings.PingDetails
-
Timestamp when the ping was sent.
- getTopicPath() - Method in interface com.pushtechnology.diffusion.client.features.control.topics.SubscriptionControl.RoutingSubscriptionRequest
-
Deprecated.
Identifies the subscribed routing topic.
- getTopicPath() - Method in interface com.pushtechnology.diffusion.client.features.control.topics.TopicControl.MissingTopicNotification
-
Returns the topic path derived from the requested topic selector.
- getTopicPermissions() - Method in interface com.pushtechnology.diffusion.client.features.control.clients.SecurityControl.Role
-
- getTopicSelector() - Method in interface com.pushtechnology.diffusion.client.features.control.Metrics.TopicMetricCollector
-
Returns the topic selector.
- getTopicSelector() - Method in interface com.pushtechnology.diffusion.client.features.control.topics.TopicControl.MissingTopicNotification
-
- getTopicSelectors() - Method in interface com.pushtechnology.diffusion.client.Diffusion.Implementation
-
- getTopicTreeBranch() - Method in interface com.pushtechnology.diffusion.client.features.control.topics.SessionTrees.BranchMapping
-
Returns the target branch in the topic tree for sessions matching the
session filter.
- getTopicView(String) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.views.TopicViews
-
Get a named Topic View.
- getTrustedClientProposedProperties() - Method in interface com.pushtechnology.diffusion.client.features.control.clients.SystemAuthenticationControl.SystemAuthenticationConfiguration
-
Returns the map of trusted client proposed properties, where the key
is the permitted property name and the value defines the validation
applied to the property.
- getType() - Method in interface com.pushtechnology.diffusion.client.topics.details.TopicSpecification
-
Returns the topic type.
- getType() - Method in interface com.pushtechnology.diffusion.client.topics.TopicSelector
-
The type of this selector.
- getType() - Method in interface com.pushtechnology.diffusion.client.types.Credentials
-
Return the type of credentials.
- getType() - Method in interface com.pushtechnology.diffusion.datatype.recordv2.schema.Schema.Field
-
Returns the field type.
- getTypeName() - Method in interface com.pushtechnology.diffusion.datatype.DataType
-
Returns the external type identifier.
- getUrl() - Method in interface com.pushtechnology.diffusion.client.features.control.RemoteServers.RemoteServer
-
Returns the url for connection to primary server.
- getValues() - Method in interface com.pushtechnology.diffusion.client.features.control.clients.SystemAuthenticationControl.SessionPropertyValidation.ValuesSessionPropertyValidation
-
Returns the set of permitted values.
- getWriteTimeout() - Method in interface com.pushtechnology.diffusion.client.session.SessionAttributes
-
Returns the write timeout value.
- GlobalPermission - Enum in com.pushtechnology.diffusion.client.types
-
Permissions that protect globally scoped, access-controlled operations.
- groupByPathPrefixParts(int) - Method in interface com.pushtechnology.diffusion.client.features.control.Metrics.TopicMetricCollector.Builder
-
Specifies the number of leading parts of the topic path the
metric collector should use to group results.
- groupByPathPrefixParts() - Method in interface com.pushtechnology.diffusion.client.features.control.Metrics.TopicMetricCollector
-
Returns the number of leading parts of the topic path to group by.
- groupByProperties(List<String>) - Method in interface com.pushtechnology.diffusion.client.features.control.Metrics.SessionMetricCollector.Builder
-
Specifies a list of session property names to group by, replacing
any current list known to this builder.
- groupByProperty(String) - Method in interface com.pushtechnology.diffusion.client.features.control.Metrics.SessionMetricCollector.Builder
-
Adds the name of a session property to group by to the list known
to this builder.
- groupByTopicType(boolean) - Method in interface com.pushtechnology.diffusion.client.features.control.Metrics.TopicMetricCollector.Builder
-
Specifies whether the metric collector should group by topic
type.
- groupsByTopicType() - Method in interface com.pushtechnology.diffusion.client.features.control.Metrics.TopicMetricCollector
-
Indicates whether the collector groups by topic type.
- ignoreClientProposedProperty(String) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.SystemAuthenticationControl.ScriptBuilder
-
Specifies the name of a client proposed session property that should
now be ignored by the system authenticator.
- INCOMPATIBLE_DATATYPE - Static variable in class com.pushtechnology.diffusion.client.callbacks.ErrorReason
-
A datatype operation has failed due to incompatibility.
- INCOMPATIBLE_STATE - Static variable in class com.pushtechnology.diffusion.client.callbacks.ErrorReason
-
A topic update could not be performed because the topic is managed by a
component (for example, fan-out) which prohibits external updates.
- IncompatibleDatatypeException - Exception in com.pushtechnology.diffusion.client.features
-
Exception used to report that an operation has failed
because the receiver could not process the supplied data.
- IncompatibleDatatypeException(String) - Constructor for exception com.pushtechnology.diffusion.client.features.IncompatibleDatatypeException
-
Constructor.
- IncompatibleExistingTopicException(String) - Constructor for exception com.pushtechnology.diffusion.client.features.control.topics.TopicControl.IncompatibleExistingTopicException
-
- IncompatibleParentTopicException(String) - Constructor for exception com.pushtechnology.diffusion.client.features.control.topics.TopicControl.IncompatibleParentTopicException
-
Deprecated.
- IncompatibleTopicException(String) - Constructor for exception com.pushtechnology.diffusion.client.features.control.topics.TopicControl.IncompatibleTopicException
-
- IncompatibleTopicException - Exception in com.pushtechnology.diffusion.client.features
-
Exception used to report a topic is incompatible with an operation.
- IncompatibleTopicException(String) - Constructor for exception com.pushtechnology.diffusion.client.features.IncompatibleTopicException
-
Constructor.
- IncompatibleTopicStateException - Exception in com.pushtechnology.diffusion.client.features
-
An operation could not be performed because the topic is managed by a
component (such as fan-out) that prohibits updates from the caller.
- IncompatibleTopicStateException(String) - Constructor for exception com.pushtechnology.diffusion.client.features.IncompatibleTopicStateException
-
Constructor.
- inputBufferSize(int) - Method in interface com.pushtechnology.diffusion.client.session.SessionFactory
-
Sets the input buffer size for socket connection buffers and message
receiving buffers.
- inserted() - Method in interface com.pushtechnology.diffusion.datatype.json.JSONDelta
-
Returns the parts of the second JSON value not found in the first JSON
value.
- int64() - Method in interface com.pushtechnology.diffusion.datatype.DataTypes
-
Data type that supports 64-bit, signed integer values.
- INT64_DATATYPE_NAME - Static variable in interface com.pushtechnology.diffusion.datatype.DataTypes
-
INT64 data type name.
- integer(String) - Method in interface com.pushtechnology.diffusion.datatype.recordv2.schema.SchemaBuilder
-
Add a single occurrence integer field to the current record.
- integer(String, int) - Method in interface com.pushtechnology.diffusion.datatype.recordv2.schema.SchemaBuilder
-
Add a fixed multiplicity integer field to the current record.
- integer(String, int, int) - Method in interface com.pushtechnology.diffusion.datatype.recordv2.schema.SchemaBuilder
-
Add an integer field to the current record.
- intersection(String) - Method in interface com.pushtechnology.diffusion.datatype.json.JSONDelta.ChangeMap
-
Returns a view of the portion of this map whose keys are descendants
or parents of pointer.
- INVALID_DATA - Static variable in class com.pushtechnology.diffusion.client.callbacks.ErrorReason
-
An operation failed because invalid data was received.
- INVALID_PATH - Static variable in class com.pushtechnology.diffusion.client.callbacks.ErrorReason
-
An invalid path was supplied.
- InvalidBranchMappingException(String) - Constructor for exception com.pushtechnology.diffusion.client.features.control.topics.SessionTrees.InvalidBranchMappingException
-
Constructor.
- InvalidDataException - Exception in com.pushtechnology.diffusion.datatype
-
Unchecked exception indicating that binary data could not be parsed as a
value.
- InvalidDataException(Exception) - Constructor for exception com.pushtechnology.diffusion.datatype.InvalidDataException
-
Constructor.
- InvalidDataException(String) - Constructor for exception com.pushtechnology.diffusion.datatype.InvalidDataException
-
Constructor.
- InvalidFilterException - Exception in com.pushtechnology.diffusion.client.features
-
Exception used to report a filter expression is invalid.
- InvalidFilterException(String, List<ErrorReport>) - Constructor for exception com.pushtechnology.diffusion.client.features.InvalidFilterException
-
Constructor.
- InvalidPatchException(String) - Constructor for exception com.pushtechnology.diffusion.client.features.TopicUpdate.InvalidPatchException
-
- InvalidPatchException(String, Throwable) - Constructor for exception com.pushtechnology.diffusion.client.features.TopicUpdate.InvalidPatchException
-
- InvalidQueryException(String) - Constructor for exception com.pushtechnology.diffusion.client.features.TimeSeries.InvalidQueryException
-
Constructor.
- InvalidTopicPathException(String) - Constructor for exception com.pushtechnology.diffusion.client.features.control.topics.TopicControl.InvalidTopicPathException
-
- InvalidTopicSpecificationException(String) - Constructor for exception com.pushtechnology.diffusion.client.features.control.topics.TopicControl.InvalidTopicSpecificationException
-
- InvalidUpdateStreamException - Exception in com.pushtechnology.diffusion.client.features
-
Exception used to report an operation was performed with an invalid
update stream.
- InvalidUpdateStreamException(String) - Constructor for exception com.pushtechnology.diffusion.client.features.InvalidUpdateStreamException
-
Constructor.
- InvalidUpdateStreamException(Throwable) - Constructor for exception com.pushtechnology.diffusion.client.features.InvalidUpdateStreamException
-
Constructor.
- isClosed() - Method in enum com.pushtechnology.diffusion.client.session.Session.State
-
Returns true if a disconnected state.
- isComplete() - Method in interface com.pushtechnology.diffusion.client.features.TimeSeries.QueryResult
-
Returns whether this result includes all events selected by the
query.
- isConflated() - Method in interface com.pushtechnology.diffusion.client.features.control.clients.MessageQueuePolicy
-
- isConnected() - Method in enum com.pushtechnology.diffusion.client.session.Session.State
-
Returns true if a connected state.
- isEditEvent() - Method in interface com.pushtechnology.diffusion.client.features.TimeSeries.Event
-
Return whether this is an edit event.
- isEmpty() - Method in interface com.pushtechnology.diffusion.client.features.Topics.FetchResult
-
Returns true if the result contains zero elements.
- isolatePath(String) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.SecurityControl.ScriptBuilder
-
Set a path not to inherit path permissions from its parent paths or
the default path permissions.
- isOwned() - Method in interface com.pushtechnology.diffusion.client.session.Session.SessionLock
-
Test whether the session lock is still owned.
- isRecovering() - Method in enum com.pushtechnology.diffusion.client.session.Session.State
-
Returns true if a recovering state.
- isTransportSecure() - Method in interface com.pushtechnology.diffusion.client.session.SessionAttributes
-
Indicates whether the session will use transport layer security to
connect to Diffusion.
- isValueCheaper(V, D) - Method in interface com.pushtechnology.diffusion.datatype.DeltaType
-
Calculate if value is cheaper than delta.
- isVariable() - Method in interface com.pushtechnology.diffusion.datatype.recordv2.schema.Schema.Node
-
Returns true of the node has variable multiplicity.
i.e.
- onActive(RegisteredHandler) - Method in class com.pushtechnology.diffusion.client.features.ServerHandler.Default
-
Deprecated.
- onActive(RegisteredHandler) - Method in interface com.pushtechnology.diffusion.client.features.ServerHandler
-
Deprecated.
Called when the handler has been registered at the server and is now
active.
- onActive(String, RegisteredHandler) - Method in class com.pushtechnology.diffusion.client.features.TopicTreeHandler.Default
-
Deprecated.
- onActive(String, RegisteredHandler) - Method in interface com.pushtechnology.diffusion.client.features.TopicTreeHandler
-
Deprecated.
Called when the handler has been registered at the server and is now
active.
- onAuthenticationFailure() - Method in class com.pushtechnology.diffusion.client.features.Security.ChangePrincipalCallback.Default
-
Deprecated.
- onAuthenticationFailure() - Method in interface com.pushtechnology.diffusion.client.features.Security.ChangePrincipalCallback
-
Deprecated.
This will be called if an attempt to change the session principal
failed because authentication failed at the server.
- onAuthenticationFailure(C) - Method in class com.pushtechnology.diffusion.client.features.Security.ChangePrincipalContextCallback.Default
-
Deprecated.
- onAuthenticationFailure(C) - Method in interface com.pushtechnology.diffusion.client.features.Security.ChangePrincipalContextCallback
-
Deprecated.
This will be called if an attempt to change the session principal
failed because authentication failed at the server.
- onClose(C) - Method in class com.pushtechnology.diffusion.client.callbacks.ContextStream.Default
-
Deprecated.
- onClose(C) - Method in interface com.pushtechnology.diffusion.client.callbacks.ContextStream
-
Deprecated.
Notification that a call context was closed normally.
- onClose() - Method in class com.pushtechnology.diffusion.client.callbacks.ServerHandler.Default
-
Deprecated.
- onClose() - Method in interface com.pushtechnology.diffusion.client.callbacks.ServerHandler
-
Deprecated.
Called if the handler is closed.
- onClose() - Method in class com.pushtechnology.diffusion.client.callbacks.Stream.Default
-
- onClose() - Method in interface com.pushtechnology.diffusion.client.callbacks.Stream
-
Notification that a stream context was closed normally.
- onClose() - Method in interface com.pushtechnology.diffusion.client.features.Messaging.FilteredRequestCallback
-
- onClose() - Method in class com.pushtechnology.diffusion.client.features.ServerHandler.Default
-
Deprecated.
- onClose() - Method in interface com.pushtechnology.diffusion.client.features.ServerHandler
-
Deprecated.
Called if the handler is closed.
- onClose(String) - Method in class com.pushtechnology.diffusion.client.features.TopicTreeHandler.Default
-
Deprecated.
- onClose(String) - Method in interface com.pushtechnology.diffusion.client.features.TopicTreeHandler
-
Deprecated.
Called if the handler is closed.
- onComplete() - Method in class com.pushtechnology.diffusion.client.features.control.clients.ClientControl.ClientCallback.Default
-
Deprecated.
- onComplete() - Method in interface com.pushtechnology.diffusion.client.features.control.clients.ClientControl.ClientCallback
-
Deprecated.
This is called to indicate that a requested operation has been
handled by the server.
- onComplete(C) - Method in class com.pushtechnology.diffusion.client.features.control.clients.ClientControl.ClientContextCallback.Default
-
Deprecated.
- onComplete(C) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.ClientControl.ClientContextCallback
-
Deprecated.
This is called to indicate that a requested operation has been
handled by the server.
- onComplete(int) - Method in class com.pushtechnology.diffusion.client.features.control.topics.SubscriptionControl.SubscriptionByFilterCallback.Default
-
Deprecated.
- onComplete(int) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.SubscriptionControl.SubscriptionByFilterCallback
-
Deprecated.
Called to indicate successful processing of the request at the
server.
- onComplete(C, int) - Method in class com.pushtechnology.diffusion.client.features.control.topics.SubscriptionControl.SubscriptionByFilterContextCallback.Default
-
Deprecated.
- onComplete(C, int) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.SubscriptionControl.SubscriptionByFilterContextCallback
-
Deprecated.
Called to indicate successful processing of the request at the
server.
- onComplete() - Method in class com.pushtechnology.diffusion.client.features.control.topics.SubscriptionControl.SubscriptionCallback.Default
-
Deprecated.
- onComplete() - Method in interface com.pushtechnology.diffusion.client.features.control.topics.SubscriptionControl.SubscriptionCallback
-
Deprecated.
Called to indicate that the requested operation has been processed by
the server.
- onComplete(C) - Method in class com.pushtechnology.diffusion.client.features.control.topics.SubscriptionControl.SubscriptionContextCallback.Default
-
Deprecated.
- onComplete(C) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.SubscriptionControl.SubscriptionContextCallback
-
Deprecated.
Called to indicate that the requested operation has been processed by
the server.
- onComplete() - Method in class com.pushtechnology.diffusion.client.features.Topics.CompletionCallback.Default
-
Deprecated.
- onComplete() - Method in interface com.pushtechnology.diffusion.client.features.Topics.CompletionCallback
-
Deprecated.
Called to indicate that the requested operation has been processed by
the server.
- onComplete(C) - Method in class com.pushtechnology.diffusion.client.features.Topics.CompletionContextCallback.Default
-
Deprecated.
- onComplete(C) - Method in interface com.pushtechnology.diffusion.client.features.Topics.CompletionContextCallback
-
Deprecated.
Called to indicate that a requested operation has been processed by
the server.
- onDescendantNotification(String, TopicNotifications.TopicNotificationListener.NotificationType) - Method in class com.pushtechnology.diffusion.client.features.control.topics.TopicNotifications.TopicNotificationListener.Default
-
- onDescendantNotification(String, TopicNotifications.TopicNotificationListener.NotificationType) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.TopicNotifications.TopicNotificationListener
-
Notification for an immediate descendant of a selected topic path.
- onDiscard() - Method in class com.pushtechnology.diffusion.client.features.Callback.Default
-
Deprecated.
- onDiscard() - Method in interface com.pushtechnology.diffusion.client.features.Callback
-
Deprecated.
This is called to notify that a call context was closed prematurely,
typically due to a timeout or the session being closed.
- onDiscard(C) - Method in class com.pushtechnology.diffusion.client.features.ContextCallback.Default
-
Deprecated.
- onDiscard(C) - Method in interface com.pushtechnology.diffusion.client.features.ContextCallback
-
Deprecated.
Notification that a call context was closed prematurely, typically due to
a timeout or the session being closed.
- onError(ErrorReason) - Method in class com.pushtechnology.diffusion.client.callbacks.Callback.Default
-
- onError(ErrorReason) - Method in interface com.pushtechnology.diffusion.client.callbacks.Callback
-
Notification of a contextual error related to this callback.
- onError(C, ErrorReason) - Method in class com.pushtechnology.diffusion.client.callbacks.ContextCallback.Default
-
Deprecated.
- onError(C, ErrorReason) - Method in interface com.pushtechnology.diffusion.client.callbacks.ContextCallback
-
Deprecated.
Notification of a contextual error related to this callback.
- onError(ErrorReason) - Method in class com.pushtechnology.diffusion.client.callbacks.ServerHandler.Default
-
Deprecated.
- onError(ErrorReason) - Method in interface com.pushtechnology.diffusion.client.callbacks.ServerHandler
-
Deprecated.
Notification of a contextual error related to this handler.
- onError(ErrorReason) - Method in interface com.pushtechnology.diffusion.client.features.Messaging.FilteredRequestCallback
-
- onError(Session, Session.SessionError) - Method in class com.pushtechnology.diffusion.client.session.Session.ErrorHandler.Default
-
- onError(Session, Session.SessionError) - Method in interface com.pushtechnology.diffusion.client.session.Session.ErrorHandler
-
Called when an error has occurred.
- onLowerThresholdCrossed(SessionId, MessageQueuePolicy) - Method in class com.pushtechnology.diffusion.client.features.control.clients.ClientControl.QueueEventHandler.Default
-
Deprecated.
- onLowerThresholdCrossed(SessionId, MessageQueuePolicy) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.ClientControl.QueueEventHandler
-
Deprecated.
The configured lower threshold for a client's queue has been reached.
- onLowerThresholdCrossed(SessionId, MessageQueuePolicy) - Method in class com.pushtechnology.diffusion.client.features.control.clients.ClientControl.QueueEventStream.Default
-
- onLowerThresholdCrossed(SessionId, MessageQueuePolicy) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.ClientControl.QueueEventStream
-
The configured lower threshold for a client's queue has been reached.
- onMissingTopic(TopicControl.MissingTopicNotification) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.TopicControl.MissingTopicHandler
-
Deprecated.
Called when a session subscribes using a topic selector that matches
no existing topics.
- onMissingTopic(TopicControl.MissingTopicNotification) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.TopicControl.MissingTopicNotificationStream
-
Called when a session requests a topic that does not exist, and the
topic path belongs to part of the topic tree for which this handler
was registered.
- onOpened(Session) - Method in interface com.pushtechnology.diffusion.client.session.SessionFactory.OpenCallback
-
Deprecated.
Called when a session has been successfully opened.
- onOpened(C, Session) - Method in interface com.pushtechnology.diffusion.client.session.SessionFactory.OpenContextCallback
-
Deprecated.
Called when a session has been successfully opened.
- onPingResponse(Pings.PingDetails) - Method in class com.pushtechnology.diffusion.client.features.Pings.PingCallback.Default
-
Deprecated.
- onPingResponse(Pings.PingDetails) - Method in interface com.pushtechnology.diffusion.client.features.Pings.PingCallback
-
Deprecated.
Called with ping response from the server.
- onPingResponse(C, Pings.PingDetails) - Method in class com.pushtechnology.diffusion.client.features.Pings.PingContextCallback.Default
-
Deprecated.
- onPingResponse(C, Pings.PingDetails) - Method in interface com.pushtechnology.diffusion.client.features.Pings.PingContextCallback
-
Deprecated.
Called with ping response from the server.
- onPrincipalChanged() - Method in class com.pushtechnology.diffusion.client.features.Security.ChangePrincipalCallback.Default
-
Deprecated.
- onPrincipalChanged() - Method in interface com.pushtechnology.diffusion.client.features.Security.ChangePrincipalCallback
-
Deprecated.
This will be called when the session principal has been successfully
changed.
- onPrincipalChanged(C) - Method in class com.pushtechnology.diffusion.client.features.Security.ChangePrincipalContextCallback.Default
-
Deprecated.
- onPrincipalChanged(C) - Method in interface com.pushtechnology.diffusion.client.features.Security.ChangePrincipalContextCallback
-
Deprecated.
Notification that a request to change the session principal was
successful.
- onRegistered(Registration) - Method in class com.pushtechnology.diffusion.client.callbacks.ServerHandler.Default
-
Deprecated.
- onRegistered(Registration) - Method in interface com.pushtechnology.diffusion.client.callbacks.ServerHandler
-
Deprecated.
Called when the handler has been successfully registered with the server.
- onRejected(Collection<ErrorReport>) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.SecurityStoreFeature.UpdateStoreCallback
-
Deprecated.
The script was rejected.
- onRejected(C, Collection<ErrorReport>) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.SecurityStoreFeature.UpdateStoreContextCallback
-
Deprecated.
The script was rejected.
- onRejected(Collection<ErrorReport>) - Method in class com.pushtechnology.diffusion.client.features.control.topics.SubscriptionControl.SubscriptionByFilterCallback.Default
-
Deprecated.
- onRejected(Collection<ErrorReport>) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.SubscriptionControl.SubscriptionByFilterCallback
-
Deprecated.
The filter was rejected.
- onRejected(C, Collection<ErrorReport>) - Method in class com.pushtechnology.diffusion.client.features.control.topics.SubscriptionControl.SubscriptionByFilterContextCallback.Default
-
Deprecated.
- onRejected(C, Collection<ErrorReport>) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.SubscriptionControl.SubscriptionByFilterContextCallback
-
Deprecated.
The filter was rejected.
- onReply(SessionId, Map<String, String>) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.ClientControl.SessionPropertiesCallback
-
Deprecated.
Called to return requested session properties.
- onReply(C, SessionId, Map<String, String>) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.ClientControl.SessionPropertiesContextCallback
-
Deprecated.
Called to return requested session properties.
- onReply(SecurityControl.SecurityConfiguration) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.SecurityControl.ConfigurationCallback
-
Deprecated.
This is called to return the requested security configuration.
- onReply(C, SecurityControl.SecurityConfiguration) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.SecurityControl.ConfigurationContextCallback
-
Deprecated.
This is called to return the requested security configuration.
- onReply(SystemAuthenticationControl.SystemAuthenticationConfiguration) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.SystemAuthenticationControl.ConfigurationCallback
-
Deprecated.
This is called to return the requested system authentication
configuration.
- onReply(C, SystemAuthenticationControl.SystemAuthenticationConfiguration) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.SystemAuthenticationControl.ConfigurationContextCallback
-
Deprecated.
This is called to return the requested system authentication
configuration.
- onRequest(T, Messaging.RequestHandler.RequestContext, Messaging.RequestHandler.Responder<R>) - Method in interface com.pushtechnology.diffusion.client.features.Messaging.RequestHandler
-
Called to indicate a request has been received.
- onRequest(String, T, Messaging.RequestStream.Responder<R>) - Method in interface com.pushtechnology.diffusion.client.features.Messaging.RequestStream
-
Called to indicate a request has been received.
- onResponse(SessionId, R) - Method in class com.pushtechnology.diffusion.client.features.Messaging.FilteredRequestCallback.Default
-
- onResponse(SessionId, R) - Method in interface com.pushtechnology.diffusion.client.features.Messaging.FilteredRequestCallback
-
Called when a response has been received.
- onResponseError(SessionId, Throwable) - Method in class com.pushtechnology.diffusion.client.features.Messaging.FilteredRequestCallback.Default
-
- onResponseError(SessionId, Throwable) - Method in interface com.pushtechnology.diffusion.client.features.Messaging.FilteredRequestCallback
-
Called when a response from a session results in an error.
- onSessionClose(SessionId, Map<String, String>, ClientControl.CloseReason) - Method in class com.pushtechnology.diffusion.client.features.control.clients.ClientControl.SessionPropertiesListener.Default
-
Deprecated.
- onSessionClose(SessionId, Map<String, String>, ClientControl.CloseReason) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.ClientControl.SessionPropertiesListener
-
Deprecated.
Notification that a client session has closed.
- onSessionClose(SessionId, Map<String, String>, ClientControl.CloseReason) - Method in class com.pushtechnology.diffusion.client.features.control.clients.ClientControl.SessionPropertiesStream.Default
-
- onSessionClose(SessionId, Map<String, String>, ClientControl.CloseReason) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.ClientControl.SessionPropertiesStream
-
Notification that a client session has closed.
- onSessionEvent(SessionId, ClientControl.SessionPropertiesListener.EventType, Map<String, String>, Map<String, String>) - Method in class com.pushtechnology.diffusion.client.features.control.clients.ClientControl.SessionPropertiesListener.Default
-
Deprecated.
- onSessionEvent(SessionId, ClientControl.SessionPropertiesListener.EventType, Map<String, String>, Map<String, String>) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.ClientControl.SessionPropertiesListener
-
Deprecated.
Notification of a session event that can result in a change of
properties.
- onSessionEvent(SessionId, ClientControl.SessionPropertiesStream.EventType, Map<String, String>, Map<String, String>) - Method in class com.pushtechnology.diffusion.client.features.control.clients.ClientControl.SessionPropertiesStream.Default
-
- onSessionEvent(SessionId, ClientControl.SessionPropertiesStream.EventType, Map<String, String>, Map<String, String>) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.ClientControl.SessionPropertiesStream
-
Notification of a session event that can result in a change of
properties.
- onSessionOpen(SessionId, Map<String, String>) - Method in class com.pushtechnology.diffusion.client.features.control.clients.ClientControl.SessionPropertiesListener.Default
-
Deprecated.
- onSessionOpen(SessionId, Map<String, String>) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.ClientControl.SessionPropertiesListener
-
Deprecated.
Notification that a new client session has been opened.
- onSessionOpen(SessionId, Map<String, String>) - Method in class com.pushtechnology.diffusion.client.features.control.clients.ClientControl.SessionPropertiesStream.Default
-
- onSessionOpen(SessionId, Map<String, String>) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.ClientControl.SessionPropertiesStream
-
Notification that a new client session has been opened.
- onSessionStateChanged(Session, Session.State, Session.State) - Method in class com.pushtechnology.diffusion.client.session.Session.Listener.Default
-
- onSessionStateChanged(Session, Session.State, Session.State) - Method in interface com.pushtechnology.diffusion.client.session.Session.Listener
-
Called whenever the state of a session changes.
- onSubscription(String, TopicSpecification) - Method in class com.pushtechnology.diffusion.client.features.Topics.SubscriberStream.Default
-
- onSubscription(String, TopicSpecification) - Method in interface com.pushtechnology.diffusion.client.features.Topics.SubscriberStream
-
Subscription notification.
- onSubscriptionRequest(SubscriptionControl.RoutingSubscriptionRequest) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.SubscriptionControl.RoutingSubscriptionRequest.Handler
-
Deprecated.
A request to subscribe to a specific routing topic.
- onSubscriptionRequest(SubscriptionControl.RoutingSubscriptionRequest) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.SubscriptionControl.RoutingSubscriptionRequest.RoutingHandler
-
Deprecated.
A request to subscribe to a specific routing topic.
- onSuccess() - Method in interface com.pushtechnology.diffusion.client.features.control.clients.SecurityStoreFeature.UpdateStoreCallback
-
Deprecated.
The script was applied successfully.
- onSuccess(C) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.SecurityStoreFeature.UpdateStoreContextCallback
-
Deprecated.
The script was applied successfully.
- onTopicAdded(String) - Method in class com.pushtechnology.diffusion.client.features.control.topics.TopicControl.AddCallback.Default
-
Deprecated.
- onTopicAdded(String) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.TopicControl.AddCallback
-
Deprecated.
This will be called when the topic has been successfully added.
- onTopicAdded(C, String) - Method in class com.pushtechnology.diffusion.client.features.control.topics.TopicControl.AddContextCallback.Default
-
Deprecated.
- onTopicAdded(C, String) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.TopicControl.AddContextCallback
-
Deprecated.
This will be called when the topic has been successfully added.
- onTopicAddFailed(String, TopicAddFailReason) - Method in class com.pushtechnology.diffusion.client.features.control.topics.TopicControl.AddCallback.Default
-
Deprecated.
- onTopicAddFailed(String, TopicAddFailReason) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.TopicControl.AddCallback
-
Deprecated.
This will be called if an attempt to add a topic has failed.
- onTopicAddFailed(C, String, TopicAddFailReason) - Method in class com.pushtechnology.diffusion.client.features.control.topics.TopicControl.AddContextCallback.Default
-
Deprecated.
- onTopicAddFailed(C, String, TopicAddFailReason) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.TopicControl.AddContextCallback
-
Deprecated.
This will be called if an attempt to add a topic has failed.
- onTopicNotification(String, TopicSpecification, TopicNotifications.TopicNotificationListener.NotificationType) - Method in class com.pushtechnology.diffusion.client.features.control.topics.TopicNotifications.TopicNotificationListener.Default
-
- onTopicNotification(String, TopicSpecification, TopicNotifications.TopicNotificationListener.NotificationType) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.TopicNotifications.TopicNotificationListener
-
A notification for a selected topic.
- onTopicsRemoved() - Method in class com.pushtechnology.diffusion.client.features.control.topics.TopicControl.RemovalCallback.Default
-
Deprecated.
- onTopicsRemoved() - Method in interface com.pushtechnology.diffusion.client.features.control.topics.TopicControl.RemovalCallback
-
Deprecated.
Called to indicate that the requested remove operation has been
actioned at the server.
- onTopicsRemoved(C) - Method in class com.pushtechnology.diffusion.client.features.control.topics.TopicControl.RemovalContextCallback.Default
-
Deprecated.
- onTopicsRemoved(C) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.TopicControl.RemovalContextCallback
-
Deprecated.
Called to indicate that the requested remove operation has been
actioned at the server.
- onUnknownSession(SessionId) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.ClientControl.SessionPropertiesCallback
-
Deprecated.
Called to indicate that the session indicated in a request is not
known by the server.
- onUnknownSession(C, SessionId) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.ClientControl.SessionPropertiesContextCallback
-
Deprecated.
Called to indicate that the session indicated in a request is not
known by the server.
- onUnsubscription(String, TopicSpecification, Topics.UnsubscribeReason) - Method in class com.pushtechnology.diffusion.client.features.Topics.SubscriberStream.Default
-
- onUnsubscription(String, TopicSpecification, Topics.UnsubscribeReason) - Method in interface com.pushtechnology.diffusion.client.features.Topics.SubscriberStream
-
Unsubscription notification.
- onUpperThresholdCrossed(SessionId, MessageQueuePolicy) - Method in class com.pushtechnology.diffusion.client.features.control.clients.ClientControl.QueueEventHandler.Default
-
Deprecated.
- onUpperThresholdCrossed(SessionId, MessageQueuePolicy) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.ClientControl.QueueEventHandler
-
Deprecated.
The configured upper threshold for a client's queue has been reached.
- onUpperThresholdCrossed(SessionId, MessageQueuePolicy) - Method in class com.pushtechnology.diffusion.client.features.control.clients.ClientControl.QueueEventStream.Default
-
- onUpperThresholdCrossed(SessionId, MessageQueuePolicy) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.ClientControl.QueueEventStream
-
The configured upper threshold for a client's queue has been reached.
- onValue(String, TopicSpecification, V, V) - Method in class com.pushtechnology.diffusion.client.features.Topics.ValueStream.Default
-
- onValue(String, TopicSpecification, V, V) - Method in interface com.pushtechnology.diffusion.client.features.Topics.ValueStream
-
Notifies an update to a topic value from the server.
- open(String) - Method in interface com.pushtechnology.diffusion.client.session.SessionFactory
-
Open a connection to a server and request a new client session.
- open(String, SessionFactory.OpenCallback) - Method in interface com.pushtechnology.diffusion.client.session.SessionFactory
-
- open(String, C, SessionFactory.OpenContextCallback<C>) - Method in interface com.pushtechnology.diffusion.client.session.SessionFactory
-
- open() - Method in interface com.pushtechnology.diffusion.client.session.SessionFactory
-
Open a connection to a server and request a new session.
- open(SessionFactory.OpenCallback) - Method in interface com.pushtechnology.diffusion.client.session.SessionFactory
-
- open(C, SessionFactory.OpenContextCallback<C>) - Method in interface com.pushtechnology.diffusion.client.session.SessionFactory
-
- openAsync() - Method in interface com.pushtechnology.diffusion.client.session.SessionFactory
-
Open a connection to a server and request a new session.
- openAsync(String) - Method in interface com.pushtechnology.diffusion.client.session.SessionFactory
-
Open a connection to a server and request a new session.
- originalEvent() - Method in interface com.pushtechnology.diffusion.client.features.TimeSeries.Event
-
If this is an edit event, returns the metadata of the original event
that this event replaces; otherwise returns this event.
- outputBufferSize(int) - Method in interface com.pushtechnology.diffusion.client.session.SessionFactory
-
Sets the output buffer size for socket connection buffers and message
sending buffers.
- OWNER - Static variable in interface com.pushtechnology.diffusion.client.topics.details.TopicSpecification
-
Key of the topic property that allows the creator of a topic to extend
READ_TOPIC, MODIFY_TOPIC, and UPDATE_TOPIC permissions to a specific
principal, in addition to the permissions granted by the authorisation
rules in the security store.
- parse(String) - Method in interface com.pushtechnology.diffusion.client.topics.TopicSelectors
-
Parse an expression to create a selector.
- parseSchema(String) - Method in interface com.pushtechnology.diffusion.datatype.recordv2.RecordV2DataType
-
Parse a schema from a JSON string.
- password(String) - Method in interface com.pushtechnology.diffusion.client.session.SessionFactory
-
- password(String) - Method in interface com.pushtechnology.diffusion.client.types.Credentials.Factory
-
- path() - Method in interface com.pushtechnology.diffusion.client.features.Topics.FetchResult.TopicResult
-
Returns the topic path.
- PATH_PREFIX - Static variable in interface com.pushtechnology.diffusion.client.topics.TopicSelector
-
Prefix used for
PATH expressions.
- PathPermission - Enum in com.pushtechnology.diffusion.client.types
-
Permissions protecting access-controlled operations that are evaluated for a
specific path.
- performReconnection(ReconnectionStrategy.ReconnectionAttempt) - Method in interface com.pushtechnology.diffusion.client.session.reconnect.ReconnectionStrategy
-
This method is called before each reconnection attempt.
- Permission - Interface in com.pushtechnology.diffusion.client.types
-
A permission protects an access-controlled operation.
- PermissionsException - Exception in com.pushtechnology.diffusion.client.session
-
The session operation failed due to a permissions failure.
- PermissionsException() - Constructor for exception com.pushtechnology.diffusion.client.session.PermissionsException
-
Constructor.
- PermissionsException(String) - Constructor for exception com.pushtechnology.diffusion.client.session.PermissionsException
-
- PermissionsException(String, Throwable) - Constructor for exception com.pushtechnology.diffusion.client.session.PermissionsException
-
- PERSISTENT - Static variable in interface com.pushtechnology.diffusion.client.topics.details.TopicSpecification
-
Key of the topic property that can be used to prevent a topic from being
persisted when the server is configured to enable persistence.
- Pings - Interface in com.pushtechnology.diffusion.client.features
-
This feature provides a client session with the ability to test its
connection to the server.
- Pings.PingCallback - Interface in com.pushtechnology.diffusion.client.features
-
- Pings.PingCallback.Default - Class in com.pushtechnology.diffusion.client.features
-
Deprecated.
- Pings.PingContextCallback<C> - Interface in com.pushtechnology.diffusion.client.features
-
- Pings.PingContextCallback.Default<C> - Class in com.pushtechnology.diffusion.client.features
-
Deprecated.
- Pings.PingDetails - Interface in com.pushtechnology.diffusion.client.features
-
Server response to a ping.
- pingServer() - Method in interface com.pushtechnology.diffusion.client.features.Pings
-
Send a ping request to the server.
- pingServer(Pings.PingCallback) - Method in interface com.pushtechnology.diffusion.client.features.Pings
-
- pingServer(C, Pings.PingContextCallback<C>) - Method in interface com.pushtechnology.diffusion.client.features.Pings
-
- previous(long) - Method in interface com.pushtechnology.diffusion.client.features.TimeSeries.RangeQuery
-
Return a copy of this RangeQuery with the span of the current range
configured to select a range of events preceding the anchor.
- previous(Duration) - Method in interface com.pushtechnology.diffusion.client.features.TimeSeries.RangeQuery
-
Return a copy of this RangeQuery with the span of the current range
configured to select a temporal range of events preceding the anchor.
- previousMillis(long) - Method in interface com.pushtechnology.diffusion.client.features.TimeSeries.RangeQuery
-
Return a copy of this RangeQuery with the span of the current range
configured to select a temporal range of events preceding the anchor.
- principal(String) - Method in interface com.pushtechnology.diffusion.client.features.control.RemoteServers.RemoteServer.Builder
-
Specifies the name of a principal used by the remote server to
connect to the primary server.
- PRINCIPAL - Static variable in interface com.pushtechnology.diffusion.client.session.Session
-
Session property key for principal.
- principal(String) - Method in interface com.pushtechnology.diffusion.client.session.SessionFactory
-
Sets the security principal.
- PRIORITY - Static variable in interface com.pushtechnology.diffusion.client.topics.details.TopicSpecification
-
Key of the topic property that specifies the topic delivery priority.
- proceed() - Method in interface com.pushtechnology.diffusion.client.features.control.topics.TopicControl.MissingTopicNotification
-
- properties(Map<String, String>) - Method in interface com.pushtechnology.diffusion.client.session.SessionFactory
-
Sets user-defined session property values.
- property(String, String) - Method in interface com.pushtechnology.diffusion.client.session.SessionFactory
-
Sets a user-defined session property value.
- proxyAuthentication() - Static method in enum com.pushtechnology.diffusion.client.Diffusion
-
Returns a proxy authentication scheme factory.
- ProxyAuthenticationFactory - Interface in com.pushtechnology.diffusion.client.session.proxy
-
- PUBLISH_VALUES_ONLY - Static variable in interface com.pushtechnology.diffusion.client.topics.details.TopicSpecification
-
Key of the topic property that specifies whether a topic should publish
only values.
- putBranchMappingTable(SessionTrees.BranchMappingTable) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.SessionTrees
-
Create or replace a branch mapping table.
- putSessionMetricCollector(Metrics.SessionMetricCollector) - Method in interface com.pushtechnology.diffusion.client.features.control.Metrics
-
Add a session metric collector, replacing any with the same name.
- putTopicMetricCollector(Metrics.TopicMetricCollector) - Method in interface com.pushtechnology.diffusion.client.features.control.Metrics
-
Add a topic metric collector, replacing any with the same name.
- rangeQuery() - Method in interface com.pushtechnology.diffusion.client.features.TimeSeries
-
Return a default range query that performs a value range query of an
entire time series.
- readAs(Class<T>, byte[], int, int) - Method in interface com.pushtechnology.diffusion.datatype.binary.BinaryDataType
-
Create a value of a compatible class from a binary.
- readAs(Class<T>, byte[]) - Method in interface com.pushtechnology.diffusion.datatype.binary.BinaryDataType
-
Create a value of a compatible class from binary.
- readAs(Class<T>, Bytes) - Method in interface com.pushtechnology.diffusion.datatype.binary.BinaryDataType
-
Create a value of a compatible class from binary.
- readAs(Class<T>, byte[], int, int) - Method in interface com.pushtechnology.diffusion.datatype.DataType
-
Create a value of a compatible class from a binary.
- readAs(Class<T>, byte[]) - Method in interface com.pushtechnology.diffusion.datatype.DataType
-
Create a value of a compatible class from binary.
- readAs(Class<T>, Bytes) - Method in interface com.pushtechnology.diffusion.datatype.DataType
-
Create a value of a compatible class from binary.
- readDelta(byte[], int, int) - Method in interface com.pushtechnology.diffusion.datatype.DeltaType
-
Create a delta from binary.
- readDelta(byte[]) - Method in interface com.pushtechnology.diffusion.datatype.DeltaType
-
Create a delta from binary.
- readDelta(Bytes) - Method in interface com.pushtechnology.diffusion.datatype.DeltaType
-
Create a delta from binary.
- readValue(byte[], int, int) - Method in interface com.pushtechnology.diffusion.datatype.binary.BinaryDataType
-
Create a value from binary.
- readValue(byte[]) - Method in interface com.pushtechnology.diffusion.datatype.binary.BinaryDataType
-
Create a value from binary.
- readValue(Bytes) - Method in interface com.pushtechnology.diffusion.datatype.binary.BinaryDataType
-
Create a value from binary.
- readValue(byte[], int, int) - Method in interface com.pushtechnology.diffusion.datatype.DataType
-
Create a value from binary.
- readValue(byte[]) - Method in interface com.pushtechnology.diffusion.datatype.DataType
-
Create a value from binary.
- readValue(Bytes) - Method in interface com.pushtechnology.diffusion.datatype.DataType
-
Create a value from binary.
- readValue(byte[], int, int) - Method in interface com.pushtechnology.diffusion.datatype.json.JSONDataType
-
Parse a value from CBOR-format binary.
- readValue(byte[]) - Method in interface com.pushtechnology.diffusion.datatype.json.JSONDataType
-
Parse a value from CBOR-format binary.
- readValue(Bytes) - Method in interface com.pushtechnology.diffusion.datatype.json.JSONDataType
-
Parse a value from CBOR-format binary.
- readValue(byte[], int, int) - Method in interface com.pushtechnology.diffusion.datatype.recordv2.RecordV2DataType
-
Parse a value from a
RecordV2 format byte array.
- readValue(byte[]) - Method in interface com.pushtechnology.diffusion.datatype.recordv2.RecordV2DataType
-
Parse a value from a
RecordV2 format byte array.
- ReconnectionStrategy - Interface in com.pushtechnology.diffusion.client.session.reconnect
-
Interface that defines a reconnection strategy.
- reconnectionStrategy(ReconnectionStrategy) - Method in interface com.pushtechnology.diffusion.client.session.SessionFactory
-
Sets the reconnection strategy.
- ReconnectionStrategy.ReconnectionAttempt - Interface in com.pushtechnology.diffusion.client.session.reconnect
-
A single reconnection attempt that can either be started or aborted.
- reconnectionTimeout(int) - Method in interface com.pushtechnology.diffusion.client.session.SessionFactory
-
Sets the reconnection timeout.
- record(String) - Method in interface com.pushtechnology.diffusion.datatype.recordv2.schema.SchemaBuilder
-
Add a new single occurrence record to the schema.
- record(String, int) - Method in interface com.pushtechnology.diffusion.datatype.recordv2.schema.SchemaBuilder
-
Add a new fixed multiplicity record to the schema.
- record(String, int, int) - Method in interface com.pushtechnology.diffusion.datatype.recordv2.schema.SchemaBuilder
-
Add a new record to the schema.
- RECORD_V2_DATATYPE_NAME - Static variable in interface com.pushtechnology.diffusion.datatype.DataTypes
-
RecordV2 data type name.
- recordCount(String) - Method in interface com.pushtechnology.diffusion.datatype.recordv2.model.RecordModel
-
Returns the actual number of occurrences of a named record.
- recordIndex() - Method in interface com.pushtechnology.diffusion.datatype.recordv2.RecordV2Delta.Change
-
Returns the index of the affected record.
- RecordModel - Interface in com.pushtechnology.diffusion.datatype.recordv2.model
-
- recordName() - Method in interface com.pushtechnology.diffusion.datatype.recordv2.RecordV2Delta.Change
-
Returns the name of the affected record.
- recordV2() - Method in interface com.pushtechnology.diffusion.datatype.DataTypes
-
Data type that supports data in the form of records and fields.
- RecordV2 - Interface in com.pushtechnology.diffusion.datatype.recordv2
-
An immutable value representing a list of records.
- RecordV2Builder - Interface in com.pushtechnology.diffusion.datatype.recordv2
-
- RecordV2DataType - Interface in com.pushtechnology.diffusion.datatype.recordv2
-
Record-based data type.
- RecordV2Delta - Interface in com.pushtechnology.diffusion.datatype.recordv2
-
- RecordV2Delta.Change - Interface in com.pushtechnology.diffusion.datatype.recordv2
-
Represents a single change between one record value and another.
- RecordV2Delta.Change.Type - Enum in com.pushtechnology.diffusion.datatype.recordv2
-
Indicates the type of change.
- recoveryBufferSize(int) - Method in interface com.pushtechnology.diffusion.client.session.SessionFactory
-
Set the recovery buffer size.
- RegisteredHandler - Interface in com.pushtechnology.diffusion.client.features
-
- Registration - Interface in com.pushtechnology.diffusion.client.callbacks
-
A reference to a registered handler.
- reject(String) - Method in interface com.pushtechnology.diffusion.client.features.Messaging.RequestHandler.Responder
-
Reject a request.
- reject(String) - Method in interface com.pushtechnology.diffusion.client.features.Messaging.RequestStream.Responder
-
Reject a request.
- RejectedRequestException - Exception in com.pushtechnology.diffusion.client.features
-
Exception used to report that a recipient session
has rejected a request.
- RejectedRequestException(String) - Constructor for exception com.pushtechnology.diffusion.client.features.RejectedRequestException
-
Constructor.
- RemoteServerExistsException(String) - Constructor for exception com.pushtechnology.diffusion.client.features.control.RemoteServers.RemoteServerExistsException
-
Constructor.
- RemoteServerOptionsException(String, List<ErrorReport>) - Constructor for exception com.pushtechnology.diffusion.client.features.control.RemoteServers.RemoteServerOptionsException
-
Constructor.
- RemoteServers - Interface in com.pushtechnology.diffusion.client.features.control
-
This feature allows a client session to manage remote servers.
- RemoteServers.CheckRemoteServerResult - Interface in com.pushtechnology.diffusion.client.features.control
-
- RemoteServers.CheckRemoteServerResult.ConnectionState - Enum in com.pushtechnology.diffusion.client.features.control
-
Represents the current connection state of the remote server.
- RemoteServers.RemoteServer - Interface in com.pushtechnology.diffusion.client.features.control
-
Interface for a Remote Server specification.
- RemoteServers.RemoteServer.Builder - Interface in com.pushtechnology.diffusion.client.features.control
-
A remote server builder.
- RemoteServers.RemoteServer.ConnectionOption - Enum in com.pushtechnology.diffusion.client.features.control
-
Connection option key.
- RemoteServers.RemoteServerExistsException - Exception in com.pushtechnology.diffusion.client.features.control
-
Exception thrown when an attempt has been made to create a remote server
when one with the same name is already defined.
- RemoteServers.RemoteServerOptionsException - Exception in com.pushtechnology.diffusion.client.features.control
-
Exception thrown when one or more of the options specified when creating
a remote server have been found to be invalid.
- REMOVAL - Static variable in interface com.pushtechnology.diffusion.client.topics.details.TopicSpecification
-
Key of the topic property that specifies a removal policy for automatic
removal of the topic (and/or other topics).
- remove(String, TopicControl.RemovalCallback) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.TopicControl
-
- remove(String, C, TopicControl.RemovalContextCallback<C>) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.TopicControl
-
- removed() - Method in interface com.pushtechnology.diffusion.datatype.json.JSONDelta
-
Returns the parts of the first JSON value not found in the second JSON
value.
- removeField(String, int, int) - Method in interface com.pushtechnology.diffusion.datatype.recordv2.model.MutableRecordModel
-
Removes the specified occurrence of a variable multiplicity field.
- removeListener(Session.Listener) - Method in interface com.pushtechnology.diffusion.client.session.Session
-
Remove a session listener.
- removeMetricsWithNoMatches(boolean) - Method in interface com.pushtechnology.diffusion.client.features.control.Metrics.SessionMetricCollector.Builder
-
Specifies whether the metric collector should remove any metrics
that have no matches.
- removePathPermissions(String, String) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.SecurityControl.ScriptBuilder
-
Removes any path permissions previously assigned to a particular path
for a given role.
- removePrincipal(String) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.SystemAuthenticationControl.ScriptBuilder
-
Remove a principal.
- removeRecord(int) - Method in interface com.pushtechnology.diffusion.datatype.recordv2.model.MutableRecordModel
-
Removes the specified occurrence of a variable multiplicity record.
- removeRemoteServer(String) - Method in interface com.pushtechnology.diffusion.client.features.control.RemoteServers
-
Remove a named remote server if it exists.
- removeRequestStream(String) - Method in interface com.pushtechnology.diffusion.client.features.Messaging
-
Remove the request stream at a particular path.
- removeSessionMetricCollector(String) - Method in interface com.pushtechnology.diffusion.client.features.control.Metrics
-
Removes any session metric collector with the given name, if it exists.
- removesMetricsWithNoMatches() - Method in interface com.pushtechnology.diffusion.client.features.control.Metrics.SessionMetricCollector
-
Indicates whether metrics with no matches should be removed.
- removeStream(Stream) - Method in interface com.pushtechnology.diffusion.client.features.Topics
-
Remove a stream.
- removeTopicMetricCollector(String) - Method in interface com.pushtechnology.diffusion.client.features.control.Metrics
-
Removes any topic metric collector with the given name, if it exists.
- removeTopicPermissions(String, String) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.SecurityControl.ScriptBuilder
-
- removeTopics(TopicSelector) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.TopicControl
-
Send a request to remove one or more topics.
- removeTopics(String) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.TopicControl
-
Send a request to remove one or more topics.
- removeTopicView(String) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.views.TopicViews
-
Remove a named topic view if it exists.
- REQUEST_TIME_OUT - Static variable in class com.pushtechnology.diffusion.client.callbacks.ErrorReason
-
Communication with the server failed because a service request timed out.
- requestPath(String) - Method in interface com.pushtechnology.diffusion.client.session.SessionFactory
-
Set the path used for HTTP requests.
- reset() - Method in interface com.pushtechnology.diffusion.client.features.control.Metrics.Builder
-
Reset the builder.
- reset() - Method in interface com.pushtechnology.diffusion.client.features.control.RemoteServers.RemoteServer.Builder
-
Reset the builder.
- reset() - Method in interface com.pushtechnology.diffusion.client.features.control.topics.SessionTrees.BranchMappingTable.Builder
-
Reset the builder.
- respond(R) - Method in interface com.pushtechnology.diffusion.client.features.Messaging.RequestHandler.Responder
-
Dispatch a response to a request.
- respond(R) - Method in interface com.pushtechnology.diffusion.client.features.Messaging.RequestStream.Responder
-
Dispatch a response to a request.
- results() - Method in interface com.pushtechnology.diffusion.client.features.Topics.FetchResult
-
Returns the results from the fetch operation.
- ROLES - Static variable in interface com.pushtechnology.diffusion.client.session.Session
-
Session property key for session roles.
- rolesToString(Set<String>) - Method in interface com.pushtechnology.diffusion.client.Diffusion.Implementation
-
Formats set of roles into a string.
- rolesToString(Set<String>) - Static method in enum com.pushtechnology.diffusion.client.Diffusion
-
Utility method which converts a set of authorisation roles to the string
format required by the
$Roles session property.
- route(String) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.SubscriptionControl.RoutingSubscriptionRequest
-
Deprecated.
Resolve a subscription request by providing the path of a source
topic to which the requesting session will be subscribed via the
routing topic.
- route(String, SubscriptionControl.SubscriptionCallback) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.SubscriptionControl.RoutingSubscriptionRequest
-
Deprecated.
Resolve a subscription request by providing the path of a source
topic to which the requesting session will be subscribed via the
routing topic.
- route(String, C, SubscriptionControl.SubscriptionContextCallback<C>) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.SubscriptionControl.RoutingSubscriptionRequest
-
Deprecated.
Provide the path of a source topic to which the requesting session
will be subscribed via the routing topic, with a contextual object.
- RoutingSubscriptionException - Exception in com.pushtechnology.diffusion.client.features.control.topics
-
- RoutingSubscriptionException(String) - Constructor for exception com.pushtechnology.diffusion.client.features.control.topics.RoutingSubscriptionException
-
Deprecated.
Constructor.
- SCHEMA - Static variable in interface com.pushtechnology.diffusion.client.topics.details.TopicSpecification
-
Key of the topic property that specifies a schema which constrains topic
values.
- Schema - Interface in com.pushtechnology.diffusion.datatype.recordv2.schema
-
- Schema.Field - Interface in com.pushtechnology.diffusion.datatype.recordv2.schema
-
Field Definition.
- Schema.Field.Type - Enum in com.pushtechnology.diffusion.datatype.recordv2.schema
-
Field Type.
- Schema.Node - Interface in com.pushtechnology.diffusion.datatype.recordv2.schema
-
- Schema.Record - Interface in com.pushtechnology.diffusion.datatype.recordv2.schema
-
Record Definition.
- schemaBuilder() - Method in interface com.pushtechnology.diffusion.datatype.recordv2.RecordV2DataType
-
Creates a new schema builder.
- SchemaBuilder - Interface in com.pushtechnology.diffusion.datatype.recordv2.schema
-
Used to build an immutable
Schema.
- SchemaParseException - Exception in com.pushtechnology.diffusion.datatype.recordv2.schema
-
Indicates a problem that has occurred when parsing a
Schema.
- SchemaParseException(String, Throwable) - Constructor for exception com.pushtechnology.diffusion.datatype.recordv2.schema.SchemaParseException
-
Constructor.
- SchemaParseException(String) - Constructor for exception com.pushtechnology.diffusion.datatype.recordv2.schema.SchemaParseException
-
Constructor.
- SchemaViolationException - Exception in com.pushtechnology.diffusion.datatype.recordv2.schema
-
Indicates a problem that has occurred when building a
Schema.
- SchemaViolationException(String, Throwable) - Constructor for exception com.pushtechnology.diffusion.datatype.recordv2.schema.SchemaViolationException
-
Constructor.
- SchemaViolationException(String) - Constructor for exception com.pushtechnology.diffusion.datatype.recordv2.schema.SchemaViolationException
-
Constructor.
- script() - Method in interface com.pushtechnology.diffusion.client.features.control.clients.SecurityControl.ScriptBuilder
-
Create a script.
- script() - Method in interface com.pushtechnology.diffusion.client.features.control.clients.SystemAuthenticationControl.ScriptBuilder
-
Create a script.
- scriptBuilder() - Method in interface com.pushtechnology.diffusion.client.features.control.clients.SecurityControl
-
Returns a builder that can be used to create scripts for use with
updateStore.
- scriptBuilder() - Method in interface com.pushtechnology.diffusion.client.features.control.clients.SystemAuthenticationControl
-
Returns a builder that can be used to create scripts for use with
updateStore.
- ScriptException - Exception in com.pushtechnology.diffusion.client.features
-
Exception used to report problems evaluating a script.
- ScriptException(String, List<ErrorReport>) - Constructor for exception com.pushtechnology.diffusion.client.features.ScriptException
-
Constructor.
- secureTransport(boolean) - Method in interface com.pushtechnology.diffusion.client.session.SessionFactory
-
Set if a secure transport should be used.
- Security - Interface in com.pushtechnology.diffusion.client.features
-
This feature provides a client session with the ability to change its
associated principal as well as to query permissions assigned to it.
- Security.ChangePrincipalCallback - Interface in com.pushtechnology.diffusion.client.features
-
- Security.ChangePrincipalCallback.Default - Class in com.pushtechnology.diffusion.client.features
-
Deprecated.
- Security.ChangePrincipalContextCallback<C> - Interface in com.pushtechnology.diffusion.client.features
-
- Security.ChangePrincipalContextCallback.Default<C> - Class in com.pushtechnology.diffusion.client.features
-
Deprecated.
- SecurityControl - Interface in com.pushtechnology.diffusion.client.features.control.clients
-
This feature allows a client session to query and update the security store.
- SecurityControl.ConfigurationCallback - Interface in com.pushtechnology.diffusion.client.features.control.clients
-
- SecurityControl.ConfigurationContextCallback<C> - Interface in com.pushtechnology.diffusion.client.features.control.clients
-
- SecurityControl.Role - Interface in com.pushtechnology.diffusion.client.features.control.clients
-
Encapsulates the defined details for an individual role.
- SecurityControl.ScriptBuilder - Interface in com.pushtechnology.diffusion.client.features.control.clients
-
A script builder may be used to create a script of commands to apply to
the security store at the server.
- SecurityControl.SecurityConfiguration - Interface in com.pushtechnology.diffusion.client.features.control.clients
-
Snapshot of information from the security store.
- SecurityStoreFeature - Interface in com.pushtechnology.diffusion.client.features.control.clients
-
The super interface for features that update security stores.
- SecurityStoreFeature.UpdateStoreCallback - Interface in com.pushtechnology.diffusion.client.features.control.clients
-
- SecurityStoreFeature.UpdateStoreContextCallback<C> - Interface in com.pushtechnology.diffusion.client.features.control.clients
-
- select(TopicSelector) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.TopicNotifications.NotificationRegistration
-
Request to receive notifications for all topics matched by the
provided topic selector.
- select(String) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.TopicNotifications.NotificationRegistration
-
Request to receive notifications for all topics matched by the
provided selector.
- selected() - Method in interface com.pushtechnology.diffusion.client.features.control.clients.ClientControl.SessionFilterOperationResult
-
- selectedCount() - Method in interface com.pushtechnology.diffusion.client.features.TimeSeries.QueryResult
-
Returns the number of events selected by the query.
- selectFrom(String) - Method in interface com.pushtechnology.diffusion.client.features.TimeSeries.Query
-
Evaluate this query for a time series topic.
- SELECTOR_SET_PREFIX - Static variable in interface com.pushtechnology.diffusion.client.topics.TopicSelector
-
Prefix used for
SET expressions.
- selects(String) - Method in interface com.pushtechnology.diffusion.client.topics.TopicSelector
-
Evaluate this selector against a topic path.
- sendRequest(String, T, Class<T>, Class<R>) - Method in interface com.pushtechnology.diffusion.client.features.Messaging
-
Send a request.
- sendRequest(SessionId, String, T, Class<T>, Class<R>) - Method in interface com.pushtechnology.diffusion.client.features.Messaging
-
Send a request to a session.
- sendRequestToFilter(String, String, T, Class<T>, Class<R>, Messaging.FilteredRequestCallback<? super R>) - Method in interface com.pushtechnology.diffusion.client.features.Messaging
-
Send a request to all sessions that satisfy a given session filter.
- sequence() - Method in interface com.pushtechnology.diffusion.client.features.TimeSeries.EventMetadata
-
Sequence number identifying this event within its time series.
- SERVER_NAME - Static variable in interface com.pushtechnology.diffusion.client.session.Session
-
Session property key for server name.
- ServerHandler - Interface in com.pushtechnology.diffusion.client.callbacks
-
- ServerHandler - Interface in com.pushtechnology.diffusion.client.features
-
- ServerHandler.Default - Class in com.pushtechnology.diffusion.client.callbacks
-
Deprecated.
Skeleton server handler implementation.
- ServerHandler.Default - Class in com.pushtechnology.diffusion.client.features
-
Deprecated.
Abstract default server handler.
- serverHost(String) - Method in interface com.pushtechnology.diffusion.client.session.SessionFactory
-
Set the host name of the server to connect the session to.
- ServerInitializingException - Exception in com.pushtechnology.diffusion.client.session
-
A session could not be established because the server was initializing.
- ServerInitializingException(String) - Constructor for exception com.pushtechnology.diffusion.client.session.ServerInitializingException
-
Constructor.
- serverPort(int) - Method in interface com.pushtechnology.diffusion.client.session.SessionFactory
-
Set the port of the server to connect the session to.
- Session - Interface in com.pushtechnology.diffusion.client.session
-
A client session to a server or cluster of servers.
- Session.ErrorHandler - Interface in com.pushtechnology.diffusion.client.session
-
The error notification interface for a session.
- Session.ErrorHandler.Default - Class in com.pushtechnology.diffusion.client.session
-
- Session.Listener - Interface in com.pushtechnology.diffusion.client.session
-
The optional listener interface for a session which may be used to
receive state notifications.
- Session.Listener.Default - Class in com.pushtechnology.diffusion.client.session
-
Default
Session.Listener implementation which simply logs events at
debug level.
- Session.SessionError - Interface in com.pushtechnology.diffusion.client.session
-
Encapsulates the detail of a reported error.
- Session.SessionLock - Interface in com.pushtechnology.diffusion.client.session
-
A session lock is a server-managed resource that can be used to
coordinate exclusive access to shared resources across sessions.
- Session.SessionLockScope - Enum in com.pushtechnology.diffusion.client.session
-
- Session.State - Enum in com.pushtechnology.diffusion.client.session
-
Session state.
- SESSION_CLOSED - Static variable in class com.pushtechnology.diffusion.client.callbacks.ErrorReason
-
Communication with the server failed because the session is closed.
- SESSION_ID - Static variable in interface com.pushtechnology.diffusion.client.session.Session
-
Session property key for session identifier.
- SessionAttributes - Interface in com.pushtechnology.diffusion.client.session
-
Session Attributes.
- SessionAttributes.Transport - Enum in com.pushtechnology.diffusion.client.session
-
The transports available to Java clients.
- SessionClosedException - Exception in com.pushtechnology.diffusion.client.session
-
The session is closed.
- SessionClosedException() - Constructor for exception com.pushtechnology.diffusion.client.session.SessionClosedException
-
Constructor.
- SessionClosedException(String) - Constructor for exception com.pushtechnology.diffusion.client.session.SessionClosedException
-
Constructor.
- SessionClosedException(Throwable) - Constructor for exception com.pushtechnology.diffusion.client.session.SessionClosedException
-
- SessionClosedException(String, Throwable) - Constructor for exception com.pushtechnology.diffusion.client.session.SessionClosedException
-
- SessionEstablishmentException - Exception in com.pushtechnology.diffusion.client.session
-
There was a problem when establishing a Session.
- SessionEstablishmentException(String) - Constructor for exception com.pushtechnology.diffusion.client.session.SessionEstablishmentException
-
Constructor.
- SessionEstablishmentException(Throwable) - Constructor for exception com.pushtechnology.diffusion.client.session.SessionEstablishmentException
-
- SessionEstablishmentException(String, Throwable) - Constructor for exception com.pushtechnology.diffusion.client.session.SessionEstablishmentException
-
- SessionEstablishmentTransientException - Exception in com.pushtechnology.diffusion.client.session
-
Represents a transient problem when establishing a session.
- SessionEstablishmentTransientException(String) - Constructor for exception com.pushtechnology.diffusion.client.session.SessionEstablishmentTransientException
-
Constructor.
- SessionEstablishmentTransientException(Throwable) - Constructor for exception com.pushtechnology.diffusion.client.session.SessionEstablishmentTransientException
-
Constructor.
- SessionException - Exception in com.pushtechnology.diffusion.client.session
-
General class of exceptions indicating a
Session specific
failure.
- SessionException() - Constructor for exception com.pushtechnology.diffusion.client.session.SessionException
-
- SessionException(String) - Constructor for exception com.pushtechnology.diffusion.client.session.SessionException
-
- SessionException(Throwable) - Constructor for exception com.pushtechnology.diffusion.client.session.SessionException
-
- SessionException(String, Throwable) - Constructor for exception com.pushtechnology.diffusion.client.session.SessionException
-
- SessionFactory - Interface in com.pushtechnology.diffusion.client.session
-
- SessionFactory.OpenCallback - Interface in com.pushtechnology.diffusion.client.session
-
- SessionFactory.OpenContextCallback<C> - Interface in com.pushtechnology.diffusion.client.session
-
- SessionId - Interface in com.pushtechnology.diffusion.client.session
-
A unique
Session identifier, allocated by the server.
- sessionIdFromString(String) - Method in interface com.pushtechnology.diffusion.client.Diffusion.Implementation
-
Parses a session id from a string.
- sessionIdFromString(String) - Static method in enum com.pushtechnology.diffusion.client.Diffusion
-
- sessionIdFromString(String) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.ClientControl
-
- sessions() - Static method in enum com.pushtechnology.diffusion.client.Diffusion
-
Returns the shared session factory.
- SessionSecurityException - Exception in com.pushtechnology.diffusion.client.session
-
The session operation failed due to a security constraint.
- SessionSecurityException() - Constructor for exception com.pushtechnology.diffusion.client.session.SessionSecurityException
-
Constructor.
- SessionSecurityException(String) - Constructor for exception com.pushtechnology.diffusion.client.session.SessionSecurityException
-
- SessionSecurityException(String, Throwable) - Constructor for exception com.pushtechnology.diffusion.client.session.SessionSecurityException
-
- SessionTrees - Interface in com.pushtechnology.diffusion.client.features.control.topics
-
This feature allows a client session to configure session trees.
- SessionTrees.BranchMapping - Interface in com.pushtechnology.diffusion.client.features.control.topics
-
A session tree branch mapping.
- SessionTrees.BranchMappingTable - Interface in com.pushtechnology.diffusion.client.features.control.topics
-
A session tree branch mapping table.
- SessionTrees.BranchMappingTable.Builder - Interface in com.pushtechnology.diffusion.client.features.control.topics
-
- SessionTrees.InvalidBranchMappingException - Exception in com.pushtechnology.diffusion.client.features.control.topics
-
- set(String, Class<T>, T) - Method in interface com.pushtechnology.diffusion.client.features.TopicUpdate
-
Sets the topic to a specified value.
- set(String, Class<T>, T, UpdateConstraint) - Method in interface com.pushtechnology.diffusion.client.features.TopicUpdate
-
Sets the topic to a specified value.
- set(T) - Method in interface com.pushtechnology.diffusion.client.features.UpdateStream
-
Sets the topic to a specified value.
- set(String, int, String, int, String) - Method in interface com.pushtechnology.diffusion.datatype.recordv2.model.MutableRecordModel
-
Sets a specified field value.
- set(String, String) - Method in interface com.pushtechnology.diffusion.datatype.recordv2.model.MutableRecordModel
-
Sets a specified field value.
- setAuthenticationHandler(String, AuthenticationControl.ControlAuthenticator) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.AuthenticationControl
-
Register an authentication handler for client authentication events.
- setConflated(SessionId, boolean) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.ClientControl
-
Control client queue conflation.
- setConflated(String, boolean) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.ClientControl
-
Control client queue conflation.
- setConflated(SessionId, boolean, ClientControl.ClientCallback) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.ClientControl
-
- setConflated(SessionId, boolean, C, ClientControl.ClientContextCallback<C>) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.ClientControl
-
- setDefaultPathPermissions(String, Set<PathPermission>) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.SecurityControl.ScriptBuilder
-
Sets the default path permissions to be assigned to a role.
- setDefaultTopicPermissions(String, Set<TopicPermission>) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.SecurityControl.ScriptBuilder
-
- setGlobalPermissions(String, Set<GlobalPermission>) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.SecurityControl.ScriptBuilder
-
Sets the global permissions to be assigned to a role.
- setPassword(String, String) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.SystemAuthenticationControl.ScriptBuilder
-
Set a principal's password.
- setPathPermissions(String, String, Set<PathPermission>) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.SecurityControl.ScriptBuilder
-
Sets specific path permissions to be assigned for a role for a path.
- setQueueEventHandler(ClientControl.QueueEventStream) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.ClientControl
-
Register a handler for client queue threshold events.
- setQueueEventHandler(ClientControl.QueueEventHandler) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.ClientControl
-
- setRequestStream(String, Class<? extends T>, Class<? super R>, Messaging.RequestStream<T, R>) - Method in interface com.pushtechnology.diffusion.client.features.Messaging
-
Set a request stream to handle requests to a specified path.
- setRoleIncludes(String, Set<String>) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.SecurityControl.ScriptBuilder
-
Sets the roles that are to be included within a specified role.
- setRoleLockedByPrincipal(String, String) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.SecurityControl.ScriptBuilder
-
Restrict a role so it can only be edited by a specific principal.
- setRolesForAnonymousSessions(Set<String>) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.SecurityControl.ScriptBuilder
-
Sets the roles to be assigned by default to all anonymous sessions.
- setRolesForNamedSessions(Set<String>) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.SecurityControl.ScriptBuilder
-
Sets the roles to be assigned by default to all named sessions.
- setSessionProperties(SessionId, Map<String, String>) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.ClientControl
-
Send a request to the server to change the user-defined session
properties for a session.
- setSessionProperties(String, Map<String, String>) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.ClientControl
-
Send a request to the server to set all sessions that satisfy a session
filter with the new user-defined session properties.
- setSessionPropertiesListener(ClientControl.SessionPropertiesStream, String...) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.ClientControl
-
Register a listener that will be notified when client sessions are
opened, disconnected, reconnected, closed or when selected session
property values are updated.
- setSessionPropertiesListener(ClientControl.SessionPropertiesListener, String...) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.ClientControl
-
- setTopicPermissions(String, String, Set<TopicPermission>) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.SecurityControl.ScriptBuilder
-
- size() - Method in interface com.pushtechnology.diffusion.client.features.Topics.FetchResult
-
The number of elements in the fetch result.
- specification() - Method in interface com.pushtechnology.diffusion.client.features.Topics.FetchResult.TopicResult
-
Returns the topic specification.
- SPLIT_PATH_PATTERN_PREFIX - Static variable in interface com.pushtechnology.diffusion.client.topics.TopicSelector
-
- sslContext(SSLContext) - Method in interface com.pushtechnology.diffusion.client.session.SessionFactory
-
Sets the SSL Context if a secure connection is required.
- start() - Method in interface com.pushtechnology.diffusion.client.session.reconnect.ReconnectionStrategy.ReconnectionAttempt
-
Start the reconnection attempt.
- START_TIME - Static variable in interface com.pushtechnology.diffusion.client.session.Session
-
Session property key for client start time.
- Stream - Interface in com.pushtechnology.diffusion.client.callbacks
-
An extension of
Callback that allows many callbacks for each call
context.
- stream() - Method in interface com.pushtechnology.diffusion.client.features.TimeSeries.QueryResult
-
- Stream.Default - Class in com.pushtechnology.diffusion.client.callbacks
-
Abstract default callback.
- streamStructure() - Method in interface com.pushtechnology.diffusion.client.features.TimeSeries.QueryResult
-
- string() - Method in interface com.pushtechnology.diffusion.datatype.DataTypes
-
Data type that supports string values.
- string(String) - Method in interface com.pushtechnology.diffusion.datatype.recordv2.schema.SchemaBuilder
-
Add a single occurrence string field to the current record.
- string(String, int) - Method in interface com.pushtechnology.diffusion.datatype.recordv2.schema.SchemaBuilder
-
Add a fixed multiplicity string field to the current record.
- string(String, int, int) - Method in interface com.pushtechnology.diffusion.datatype.recordv2.schema.SchemaBuilder
-
Add a string field to the current record.
- STRING_DATATYPE_NAME - Static variable in interface com.pushtechnology.diffusion.datatype.DataTypes
-
String data type name.
- stringToRoles(String) - Method in interface com.pushtechnology.diffusion.client.Diffusion.Implementation
-
Parses a string with roles to a mutable set.
- stringToRoles(String) - Static method in enum com.pushtechnology.diffusion.client.Diffusion
-
Utility method which converts a string of the format required by the
$Roles session property into a mutable set of
strings.
- subscribe(SessionId, String) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.SubscriptionControl
-
Subscribe another session to topics.
- subscribe(SessionId, TopicSelector) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.SubscriptionControl
-
Subscribe another session to topics.
- subscribe(SessionId, String, SubscriptionControl.SubscriptionCallback) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.SubscriptionControl
-
- subscribe(SessionId, TopicSelector, SubscriptionControl.SubscriptionCallback) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.SubscriptionControl
-
- subscribe(SessionId, String, C, SubscriptionControl.SubscriptionContextCallback<C>) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.SubscriptionControl
-
- subscribe(SessionId, TopicSelector, C, SubscriptionControl.SubscriptionContextCallback<C>) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.SubscriptionControl
-
- subscribe(TopicSelector) - Method in interface com.pushtechnology.diffusion.client.features.Topics
-
Request subscription to topics.
- subscribe(String) - Method in interface com.pushtechnology.diffusion.client.features.Topics
-
Request subscription to topics.
- subscribe(TopicSelector, Topics.CompletionCallback) - Method in interface com.pushtechnology.diffusion.client.features.Topics
-
- subscribe(String, Topics.CompletionCallback) - Method in interface com.pushtechnology.diffusion.client.features.Topics
-
- subscribe(TopicSelector, C, Topics.CompletionContextCallback<C>) - Method in interface com.pushtechnology.diffusion.client.features.Topics
-
- subscribe(String, C, Topics.CompletionContextCallback<C>) - Method in interface com.pushtechnology.diffusion.client.features.Topics
-
- subscribeByFilter(String, String) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.SubscriptionControl
-
Subscribe sessions that satisfy a given session filter to topics.
- subscribeByFilter(String, TopicSelector) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.SubscriptionControl
-
Subscribe sessions that satisfy a given session filter to topics.
- subscribeByFilter(String, String, SubscriptionControl.SubscriptionByFilterCallback) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.SubscriptionControl
-
- subscribeByFilter(String, TopicSelector, SubscriptionControl.SubscriptionByFilterCallback) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.SubscriptionControl
-
- subscribeByFilter(String, String, C, SubscriptionControl.SubscriptionByFilterContextCallback<C>) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.SubscriptionControl
-
- subscribeByFilter(String, TopicSelector, C, SubscriptionControl.SubscriptionByFilterContextCallback<C>) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.SubscriptionControl
-
- SubscriptionControl - Interface in com.pushtechnology.diffusion.client.features.control.topics
-
This feature allows a session to subscribe or unsubscribe other sessions to
topics.
- SubscriptionControl.RoutingSubscriptionRequest - Interface in com.pushtechnology.diffusion.client.features.control.topics
-
- SubscriptionControl.RoutingSubscriptionRequest.Handler - Interface in com.pushtechnology.diffusion.client.features.control.topics
-
- SubscriptionControl.RoutingSubscriptionRequest.Handler.Default - Class in com.pushtechnology.diffusion.client.features.control.topics
-
Deprecated.
Abstract handler implementation.
- SubscriptionControl.RoutingSubscriptionRequest.RoutingHandler - Interface in com.pushtechnology.diffusion.client.features.control.topics
-
- SubscriptionControl.RoutingSubscriptionRequest.RoutingHandler.Default - Class in com.pushtechnology.diffusion.client.features.control.topics
-
Deprecated.
Abstract handler implementation.
- SubscriptionControl.SubscriptionByFilterCallback - Interface in com.pushtechnology.diffusion.client.features.control.topics
-
- SubscriptionControl.SubscriptionByFilterCallback.Default - Class in com.pushtechnology.diffusion.client.features.control.topics
-
Deprecated.
- SubscriptionControl.SubscriptionByFilterContextCallback<C> - Interface in com.pushtechnology.diffusion.client.features.control.topics
-
- SubscriptionControl.SubscriptionByFilterContextCallback.Default<C> - Class in com.pushtechnology.diffusion.client.features.control.topics
-
Deprecated.
- SubscriptionControl.SubscriptionByFilterResult - Interface in com.pushtechnology.diffusion.client.features.control.topics
-
- SubscriptionControl.SubscriptionCallback - Interface in com.pushtechnology.diffusion.client.features.control.topics
-
- SubscriptionControl.SubscriptionCallback.Default - Class in com.pushtechnology.diffusion.client.features.control.topics
-
Deprecated.
- SubscriptionControl.SubscriptionContextCallback<C> - Interface in com.pushtechnology.diffusion.client.features.control.topics
-
- SubscriptionControl.SubscriptionContextCallback.Default<C> - Class in com.pushtechnology.diffusion.client.features.control.topics
-
Deprecated.
- SystemAuthenticationControl - Interface in com.pushtechnology.diffusion.client.features.control.clients
-
This feature allows a client session to query and update the system
authentication store.
- SystemAuthenticationControl.AnonymousConnectionAction - Enum in com.pushtechnology.diffusion.client.features.control.clients
-
Action to be taken by the system authentication handler for connection
attempts that do not provide a principal name and credentials.
- SystemAuthenticationControl.ConfigurationCallback - Interface in com.pushtechnology.diffusion.client.features.control.clients
-
- SystemAuthenticationControl.ConfigurationContextCallback<C> - Interface in com.pushtechnology.diffusion.client.features.control.clients
-
- SystemAuthenticationControl.ScriptBuilder - Interface in com.pushtechnology.diffusion.client.features.control.clients
-
A script builder may be used to create a script of commands to apply to
the system authentication store at the server.
- SystemAuthenticationControl.SessionPropertyValidation - Interface in com.pushtechnology.diffusion.client.features.control.clients
-
Defines the validation for a trusted client proposed session property.
- SystemAuthenticationControl.SessionPropertyValidation.MatchesSessionPropertyValidation - Interface in com.pushtechnology.diffusion.client.features.control.clients
-
Defines regular expression based validation for a trusted client
proposed session property.
- SystemAuthenticationControl.SessionPropertyValidation.ValuesSessionPropertyValidation - Interface in com.pushtechnology.diffusion.client.features.control.clients
-
Defines values based validation for a trusted client proposed session
property.
- SystemAuthenticationControl.SystemAuthenticationConfiguration - Interface in com.pushtechnology.diffusion.client.features.control.clients
-
Snapshot of information from the system authentication store.
- SystemAuthenticationControl.SystemPrincipal - Interface in com.pushtechnology.diffusion.client.features.control.clients
-
A principal in the system authentication store.
- TIDY_ON_UNSUBSCRIBE - Static variable in interface com.pushtechnology.diffusion.client.topics.details.TopicSpecification
-
Key of the topic property that specifies the 'tidy on unsubscribe' option
for a topic.
- TIME_SERIES_EVENT_VALUE_TYPE - Static variable in interface com.pushtechnology.diffusion.client.topics.details.TopicSpecification
-
Key of the topic property that specifies the event data type for a time
series topic.
- TIME_SERIES_RETAINED_RANGE - Static variable in interface com.pushtechnology.diffusion.client.topics.details.TopicSpecification
-
Key of the topic property that specifies the range of events retained by
a time series topic.
- TIME_SERIES_SUBSCRIPTION_RANGE - Static variable in interface com.pushtechnology.diffusion.client.topics.details.TopicSpecification
-
Key of the topic property that specifies the range of time series topic
events to send to new subscribers.
- TimeSeries - Interface in com.pushtechnology.diffusion.client.features
-
This feature allows a session to update and query time series topics.
- TimeSeries.Event<V> - Interface in com.pushtechnology.diffusion.client.features
-
An event in a time series.
- TimeSeries.EventMetadata - Interface in com.pushtechnology.diffusion.client.features
-
Time series event metadata.
- TimeSeries.InvalidQueryException - Exception in com.pushtechnology.diffusion.client.features
-
Exception used to report a query that is invalid for the time series.
- TimeSeries.NoSuchEventException - Exception in com.pushtechnology.diffusion.client.features
-
Exception used to report a time series topic does not have an original
event with the sequence number provided by an
edit operation.
- TimeSeries.Query<V> - Interface in com.pushtechnology.diffusion.client.features
-
A configured query.
- TimeSeries.QueryResult<V> - Interface in com.pushtechnology.diffusion.client.features
-
- TimeSeries.QueryResult.StreamStructure - Enum in com.pushtechnology.diffusion.client.features
-
Describes the structural properties of a stream.
- TimeSeries.RangeQuery<V> - Interface in com.pushtechnology.diffusion.client.features
-
Builder for queries that select a range of events from a time series.
- timestamp() - Method in interface com.pushtechnology.diffusion.client.features.TimeSeries.EventMetadata
-
Event timestamp.
- to(long) - Method in interface com.pushtechnology.diffusion.client.features.TimeSeries.RangeQuery
-
Return a copy of this RangeQuery with the span of the current range
configured to end at an absolute sequence number.
- to(Instant) - Method in interface com.pushtechnology.diffusion.client.features.TimeSeries.RangeQuery
-
Return a copy of this RangeQuery with the span of the current range
configured to end at an absolute time.
- to(Date) - Method in interface com.pushtechnology.diffusion.client.features.TimeSeries.RangeQuery
-
Return a copy of this RangeQuery with the span of the current range
configured to end at an absolute time.
- to(String) - Method in interface com.pushtechnology.diffusion.client.features.Topics.FetchRequest
-
Specifies a logical end point within the topic tree.
- toByteArray() - Method in interface com.pushtechnology.diffusion.datatype.Bytes
-
Returns a copy of the data as a byte array.
- toBytes() - Method in interface com.pushtechnology.diffusion.client.types.Credentials
-
Return the credential data as a byte array.
- toBytes(V) - Method in interface com.pushtechnology.diffusion.datatype.DataType
-
Returns the serialized form of
value as a
Bytes.
- toBytes(D) - Method in interface com.pushtechnology.diffusion.datatype.DeltaType
-
Returns the serialized form of
delta as a
Bytes.
- toJsonString() - Method in interface com.pushtechnology.diffusion.datatype.json.JSON
-
- TOPIC_TREE_REGISTRATION_CONFLICT - Static variable in class com.pushtechnology.diffusion.client.callbacks.ErrorReason
-
A conflicting registration exists on the same branch of the topic tree.
- TopicAddFailReason - Enum in com.pushtechnology.diffusion.client.features.control.topics
-
The reason for failure to add a topic.
- TopicControl - Interface in com.pushtechnology.diffusion.client.features.control.topics
-
This feature allows a session to manage topics.
- TopicControl.AddCallback - Interface in com.pushtechnology.diffusion.client.features.control.topics
-
- TopicControl.AddCallback.Default - Class in com.pushtechnology.diffusion.client.features.control.topics
-
Deprecated.
- TopicControl.AddContextCallback<C> - Interface in com.pushtechnology.diffusion.client.features.control.topics
-
- TopicControl.AddContextCallback.Default<C> - Class in com.pushtechnology.diffusion.client.features.control.topics
-
Deprecated.
- TopicControl.AddTopicException - Exception in com.pushtechnology.diffusion.client.features.control.topics
-
Exception thrown to report a failure to add a topic.
- TopicControl.AddTopicResult - Enum in com.pushtechnology.diffusion.client.features.control.topics
-
Used to report the result of adding a topic.
- TopicControl.ExistingTopicException - Exception in com.pushtechnology.diffusion.client.features.control.topics
-
Exception thrown to report a topic could not be added because an existing
topic with a different specification is bound to the topic path.
- TopicControl.IncompatibleExistingTopicException - Exception in com.pushtechnology.diffusion.client.features.control.topics
-
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.
- TopicControl.IncompatibleParentTopicException - Exception in com.pushtechnology.diffusion.client.features.control.topics
-
- TopicControl.IncompatibleTopicException - Exception in com.pushtechnology.diffusion.client.features.control.topics
-
Exception thrown to report a topic could not be added because there is an
existing topic that is incompatible with the request.
- TopicControl.InvalidTopicPathException - Exception in com.pushtechnology.diffusion.client.features.control.topics
-
Exception thrown to report a topic could not be added because the topic
path supplied is invalid.
- TopicControl.InvalidTopicSpecificationException - Exception in com.pushtechnology.diffusion.client.features.control.topics
-
Exception thrown to report a topic could not be added because the
specification is invalid.
- TopicControl.MissingTopicHandler - Interface in com.pushtechnology.diffusion.client.features.control.topics
-
- TopicControl.MissingTopicHandler.Default - Class in com.pushtechnology.diffusion.client.features.control.topics
-
Deprecated.
- TopicControl.MissingTopicNotification - Interface in com.pushtechnology.diffusion.client.features.control.topics
-
Notification that a session has made a subscription request using a
selector that does not match any topics.
- TopicControl.MissingTopicNotificationStream - Interface in com.pushtechnology.diffusion.client.features.control.topics
-
Stream called when a session subscribes using a topic selector that
matches no topics.
- TopicControl.MissingTopicNotificationStream.Default - Class in com.pushtechnology.diffusion.client.features.control.topics
-
- TopicControl.RemovalCallback - Interface in com.pushtechnology.diffusion.client.features.control.topics
-
- TopicControl.RemovalCallback.Default - Class in com.pushtechnology.diffusion.client.features.control.topics
-
Deprecated.
- TopicControl.RemovalContextCallback<C> - Interface in com.pushtechnology.diffusion.client.features.control.topics
-
- TopicControl.RemovalContextCallback.Default<C> - Class in com.pushtechnology.diffusion.client.features.control.topics
-
Deprecated.
- TopicControl.TopicLicenseLimitException - Exception in com.pushtechnology.diffusion.client.features.control.topics
-
Exception thrown to report a topic could not be added because a license
limit has been exceeded.
- TopicControl.TopicRemovalResult - Interface in com.pushtechnology.diffusion.client.features.control.topics
-
- TopicCreationResult - Enum in com.pushtechnology.diffusion.client.features
-
Result indicating whether the operation caused a topic to be created or if
it already existed.
- TopicLicenseLimitException(String) - Constructor for exception com.pushtechnology.diffusion.client.features.control.topics.TopicControl.TopicLicenseLimitException
-
- TopicNotifications - Interface in com.pushtechnology.diffusion.client.features.control.topics
-
This feature allows a client session to receive notifications about changes
to selected topics.
- TopicNotifications.NotificationRegistration - Interface in com.pushtechnology.diffusion.client.features.control.topics
-
The NotificationRegistration represents the registration state of the
associated listener on the server.
- TopicNotifications.TopicNotificationListener - Interface in com.pushtechnology.diffusion.client.features.control.topics
-
Listener for topic notifications.
- TopicNotifications.TopicNotificationListener.Default - Class in com.pushtechnology.diffusion.client.features.control.topics
-
Default listener.
- TopicNotifications.TopicNotificationListener.NotificationType - Enum in com.pushtechnology.diffusion.client.features.control.topics
-
The type of notification that has been received.
- TopicPathSelector - Interface in com.pushtechnology.diffusion.client.topics
-
A selector that selects a single topic path.
- TopicPermission - Enum in com.pushtechnology.diffusion.client.types
-
- Topics - Interface in com.pushtechnology.diffusion.client.features
-
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.
- Topics.CompletionCallback - Interface in com.pushtechnology.diffusion.client.features
-
- Topics.CompletionCallback.Default - Class in com.pushtechnology.diffusion.client.features
-
Deprecated.
- Topics.CompletionContextCallback<C> - Interface in com.pushtechnology.diffusion.client.features
-
- Topics.CompletionContextCallback.Default<C> - Class in com.pushtechnology.diffusion.client.features
-
Deprecated.
- Topics.FetchRequest<V> - Interface in com.pushtechnology.diffusion.client.features
-
A parameterised query that can be used to search the topic tree.
- Topics.FetchResult<V> - Interface in com.pushtechnology.diffusion.client.features
-
Encapsulates the results from a fetch operation issued to the server.
- Topics.FetchResult.TopicResult<V> - Interface in com.pushtechnology.diffusion.client.features
-
Encapsulates the result of a
fetch invocation for a single selected topic.
- Topics.SubscriberStream - Interface in com.pushtechnology.diffusion.client.features
-
Base subscriber stream interface.
- Topics.SubscriberStream.Default - Class in com.pushtechnology.diffusion.client.features
-
- Topics.UnsubscribeReason - Enum in com.pushtechnology.diffusion.client.features
-
The reason that an unsubscription occurred.
- Topics.ValueStream<V> - Interface in com.pushtechnology.diffusion.client.features
-
Stream interface that can be registered to receive subscription and value
events whenever an update is received from the server.
- Topics.ValueStream.Default<V> - Class in com.pushtechnology.diffusion.client.features
-
- TopicSelector - Interface in com.pushtechnology.diffusion.client.topics
-
A TopicSelector is a value that identifies one or more topics.
- TopicSelector.Type - Enum in com.pushtechnology.diffusion.client.topics
-
Topic selector type.
- topicSelectors() - Static method in enum com.pushtechnology.diffusion.client.Diffusion
-
Returns a parser for topic selector expressions.
- TopicSelectors - Interface in com.pushtechnology.diffusion.client.topics
-
- TopicSpecification - Interface in com.pushtechnology.diffusion.client.topics.details
-
Topic specifications provide the information required to create a topic.
- TopicTreeHandler - Interface in com.pushtechnology.diffusion.client.features
-
- TopicTreeHandler.Default - Class in com.pushtechnology.diffusion.client.features
-
Deprecated.
Abstract Default Topic Tree Handler.
- TopicType - Enum in com.pushtechnology.diffusion.client.topics.details
-
The topic type determines the type of the data values a topic publishes to
subscribers.
- topicTypes(Set<TopicType>) - Method in interface com.pushtechnology.diffusion.client.features.Topics.FetchRequest
-
Specifies that only topics of the specified topic types should be
returned.
- TopicUpdate - Interface in com.pushtechnology.diffusion.client.features
-
This feature provides a client session with the ability to update topics.
- TopicUpdate.FailedPatchException - Exception in com.pushtechnology.diffusion.client.features
-
Exception thrown to report that applying a JSON Patch failed.
- TopicUpdate.InvalidPatchException - Exception in com.pushtechnology.diffusion.client.features
-
Exception thrown to report that a JSON Patch was invalid.
- TopicUpdate.JsonPatchResult - Interface in com.pushtechnology.diffusion.client.features
-
- TopicView - Interface in com.pushtechnology.diffusion.client.features.control.topics.views
-
Description of a topic view that has been created.
- TopicViews - Interface in com.pushtechnology.diffusion.client.features.control.topics.views
-
This feature allows a client session to manage topic views.
- toStart() - Method in interface com.pushtechnology.diffusion.client.features.TimeSeries.RangeQuery
-
Return a copy of this RangeQuery with the span of the current range
configured to end at the start of the time series.
- toString() - Method in class com.pushtechnology.diffusion.client.callbacks.ErrorReason
-
- toString() - Method in interface com.pushtechnology.diffusion.client.session.Session.SessionError
-
Returns a string representation of the error.
- toString() - Method in interface com.pushtechnology.diffusion.client.session.SessionId
-
Returns a string representation of the session identifier.
- TRANSPORT - Static variable in interface com.pushtechnology.diffusion.client.session.Session
-
Session property key for transport.
- transports(SessionAttributes.Transport...) - Method in interface com.pushtechnology.diffusion.client.session.SessionFactory
-
Set the transports to use to connect the session to the server.
- trustClientProposedPropertyIn(String, Set<String>) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.SystemAuthenticationControl.ScriptBuilder
-
Specifies the name of a client proposed session property that should
be allowed by the system authenticator along with a set of
permissible values.
- trustClientProposedPropertyMatches(String, String) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.SystemAuthenticationControl.ScriptBuilder
-
Specifies the name of a client proposed session property that should
be allowed by the system authenticator along with a regular
expression to validate the property value.
- type() - Method in interface com.pushtechnology.diffusion.client.features.Topics.FetchResult.TopicResult
-
Returns the topic type.
- type() - Method in interface com.pushtechnology.diffusion.datatype.recordv2.RecordV2Delta.Change
-
Returns the change type.
- validate() - Method in interface com.pushtechnology.diffusion.client.features.UpdateStream
-
Validates the update stream.
- validate(V) - Method in interface com.pushtechnology.diffusion.datatype.DataType
-
Check whether a value is valid.
- validate() - Method in interface com.pushtechnology.diffusion.datatype.json.JSON
-
Check whether this instance is valid.
- VALIDATE_VALUES - Static variable in interface com.pushtechnology.diffusion.client.topics.details.TopicSpecification
-
Key of the topic property that specifies whether a topic should validate
inbound values.
- value() - Method in interface com.pushtechnology.diffusion.client.features.TimeSeries.Event
-
The value associated with the event.
- value() - Method in interface com.pushtechnology.diffusion.client.features.Topics.FetchResult.TopicResult
-
Returns the topic value.
- value(V) - Method in interface com.pushtechnology.diffusion.client.features.UpdateConstraint.Factory
-
Create a constraint requiring the current value of a topic to match
the supplied value.
- valueBuilder() - Method in interface com.pushtechnology.diffusion.datatype.recordv2.RecordV2DataType
-
- valueOf(String) - Static method in enum com.pushtechnology.diffusion.client.Diffusion
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.pushtechnology.diffusion.client.features.control.clients.ClientControl.CloseReason
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.pushtechnology.diffusion.client.features.control.clients.ClientControl.SessionPropertiesListener.EventType
-
Deprecated.
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.pushtechnology.diffusion.client.features.control.clients.ClientControl.SessionPropertiesStream.EventType
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.pushtechnology.diffusion.client.features.control.clients.SystemAuthenticationControl.AnonymousConnectionAction
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.pushtechnology.diffusion.client.features.control.RemoteServers.CheckRemoteServerResult.ConnectionState
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.pushtechnology.diffusion.client.features.control.RemoteServers.RemoteServer.ConnectionOption
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.pushtechnology.diffusion.client.features.control.topics.TopicAddFailReason
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.pushtechnology.diffusion.client.features.control.topics.TopicControl.AddTopicResult
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.pushtechnology.diffusion.client.features.control.topics.TopicNotifications.TopicNotificationListener.NotificationType
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.pushtechnology.diffusion.client.features.TimeSeries.QueryResult.StreamStructure
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.pushtechnology.diffusion.client.features.TopicCreationResult
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.pushtechnology.diffusion.client.features.Topics.UnsubscribeReason
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.pushtechnology.diffusion.client.session.Session.SessionLockScope
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.pushtechnology.diffusion.client.session.Session.State
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.pushtechnology.diffusion.client.session.SessionAttributes.Transport
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.pushtechnology.diffusion.client.topics.details.TopicType
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.pushtechnology.diffusion.client.topics.TopicSelector.Type
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.pushtechnology.diffusion.client.types.Credentials.Type
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.pushtechnology.diffusion.client.types.GlobalPermission
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.pushtechnology.diffusion.client.types.PathPermission
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.pushtechnology.diffusion.client.types.TopicPermission
-
Deprecated.
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.pushtechnology.diffusion.datatype.recordv2.RecordV2Delta.Change.Type
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.pushtechnology.diffusion.datatype.recordv2.schema.Schema.Field.Type
-
Returns the enum constant of this type with the specified name.
- values() - Static method in enum com.pushtechnology.diffusion.client.Diffusion
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.pushtechnology.diffusion.client.features.control.clients.ClientControl.CloseReason
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.pushtechnology.diffusion.client.features.control.clients.ClientControl.SessionPropertiesListener.EventType
-
Deprecated.
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.pushtechnology.diffusion.client.features.control.clients.ClientControl.SessionPropertiesStream.EventType
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.pushtechnology.diffusion.client.features.control.clients.SystemAuthenticationControl.AnonymousConnectionAction
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.pushtechnology.diffusion.client.features.control.RemoteServers.CheckRemoteServerResult.ConnectionState
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.pushtechnology.diffusion.client.features.control.RemoteServers.RemoteServer.ConnectionOption
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.pushtechnology.diffusion.client.features.control.topics.TopicAddFailReason
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.pushtechnology.diffusion.client.features.control.topics.TopicControl.AddTopicResult
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.pushtechnology.diffusion.client.features.control.topics.TopicNotifications.TopicNotificationListener.NotificationType
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.pushtechnology.diffusion.client.features.TimeSeries.QueryResult.StreamStructure
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.pushtechnology.diffusion.client.features.TopicCreationResult
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.pushtechnology.diffusion.client.features.Topics.UnsubscribeReason
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.pushtechnology.diffusion.client.session.Session.SessionLockScope
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.pushtechnology.diffusion.client.session.Session.State
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.pushtechnology.diffusion.client.session.SessionAttributes.Transport
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.pushtechnology.diffusion.client.topics.details.TopicType
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.pushtechnology.diffusion.client.topics.TopicSelector.Type
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.pushtechnology.diffusion.client.types.Credentials.Type
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.pushtechnology.diffusion.client.types.GlobalPermission
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.pushtechnology.diffusion.client.types.PathPermission
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.pushtechnology.diffusion.client.types.TopicPermission
-
Deprecated.
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.pushtechnology.diffusion.datatype.recordv2.RecordV2Delta.Change.Type
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.pushtechnology.diffusion.datatype.recordv2.schema.Schema.Field.Type
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- verifyPassword(String, String) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.SystemAuthenticationControl.ScriptBuilder
-
Assert that a principal's password is password.