Skip navigation links
DiffusionTM Android API 6.6.0-preview.1
A B C D E F G H I J K L M N O P R S T U V W 

A

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.
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
Register a TopicControl.MissingTopicNotificationStream to handle requests for a branch of the topic tree.
addMissingTopicHandler(String, TopicControl.MissingTopicHandler) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.TopicControl
Register a TopicControl.MissingTopicHandler to handle requests for a branch of the topic tree.
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>, MessagingControl.RequestHandler<T, R>, String...) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.MessagingControl
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
Adds a handler for routing topics that belong to a branch of the topic tree.
addRoutingSubscriptionHandler(String, SubscriptionControl.RoutingSubscriptionRequest.Handler) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.SubscriptionControl
Adds a handler for routing topics that belong to a branch of the topic tree.
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
Version of TopicControl.addTopic(String, TopicSpecification, AddCallback) that allows a user defined context to be provided.
addTopic(String, TopicSpecification, TopicControl.AddCallback) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.TopicControl
Send a request to the server to add a topic.
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
Value returned by Session.getPrincipal() if no principal name is associated with the session.
anyOf(String...) - Method in interface com.pushtechnology.diffusion.client.topics.TopicSelectors
Convenient wrapper of TopicSelectors.anyOf(TopicSelector...) that first parses the supplied expressions to create selectors.
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.
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
Single-use callback provided to the authenticate call.
author() - Method in interface com.pushtechnology.diffusion.client.features.TimeSeries.EventMetadata
Server-authenticated identity of the session that created the event.

B

basic(String, String) - Method in interface com.pushtechnology.diffusion.client.session.proxy.ProxyAuthenticationFactory
Provides an implementation of Basic proxy authentication.
before(String) - Method in interface com.pushtechnology.diffusion.client.features.Topics.FetchRequest
Specifies a logical end point within the topic tree.
Binary - Interface in com.pushtechnology.diffusion.datatype.binary
A read-only binary value with support for binary deltas.
binary() - Method in interface com.pushtechnology.diffusion.datatype.DataTypes
Data type that supports arbitrary binary data.
BINARY_DATATYPE_NAME - Static variable in interface com.pushtechnology.diffusion.datatype.DataTypes
Binary data type name.
BinaryDataType - Interface in com.pushtechnology.diffusion.datatype.binary
Binary data type.
BinaryDelta - Interface in com.pushtechnology.diffusion.datatype
Binary delta type.
binaryDeltaType() - Method in interface com.pushtechnology.diffusion.datatype.binary.BinaryDataType
Returns support for binary deltas.
binaryDeltaType() - Method in interface com.pushtechnology.diffusion.datatype.DataType
Returns the binary delta type for this data type, if any.
binaryDeltaType() - Method in interface com.pushtechnology.diffusion.datatype.json.JSONDataType
Returns support for binary deltas.
binaryDeltaType() - Method in interface com.pushtechnology.diffusion.datatype.recordv2.RecordV2DataType
Returns support for binary deltas.
binaryDiff(JSON) - Method in interface com.pushtechnology.diffusion.datatype.json.JSON
Compare this JSON value with an earlier version to create a binary delta.
build() - Method in interface com.pushtechnology.diffusion.datatype.recordv2.RecordV2Builder
Builds a RecordV2 object from the current builder state.
build() - Method in interface com.pushtechnology.diffusion.datatype.recordv2.schema.SchemaBuilder
Build an immutable Schema.
Bytes - Interface in com.pushtechnology.diffusion.datatype
Read-only interface for values that are internally represented as binary data.

C

Callback - Interface in com.pushtechnology.diffusion.client.callbacks
Callback interface that provides responses from the server.
Callback - Interface in com.pushtechnology.diffusion.client.features
A callback interface used to return results from a call to the server.
Callback.Default - Class in com.pushtechnology.diffusion.client.callbacks
Abstract default callback.
Callback.Default - Class in com.pushtechnology.diffusion.client.features
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
Deprecated.
since 6.4

In the future the behavior when a subscription selector matches with no topics will be to add the selector to the session's topic selections regardless of whether this is called, and this method will become a no-op and will eventually be removed.

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
Change the security principal associated with the session.
changePrincipal(String, Credentials, C, Security.ChangePrincipalContextCallback<C>) - Method in interface com.pushtechnology.diffusion.client.features.Security
Change the security principal associated with the session.
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
Callback interface for close, and setConflated.
ClientControl.ClientCallback.Default - Class in com.pushtechnology.diffusion.client.features.control.clients
Default implementation of ClientControl.ClientCallback.
ClientControl.ClientContextCallback<C> - Interface in com.pushtechnology.diffusion.client.features.control.clients
Contextual version of ClientControl.ClientCallback used with close and setConflated.
ClientControl.ClientContextCallback.Default<C> - Class in com.pushtechnology.diffusion.client.features.control.clients
Default implementation of ClientControl.ClientContextCallback.
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
Handler for client queue events.
ClientControl.QueueEventHandler.Default - Class in com.pushtechnology.diffusion.client.features.control.clients
This provides a default implementation of ClientControl.QueueEventHandler.
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
This provides a default implementation of ClientControl.QueueEventHandler.
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
The handler for session properties listener notifications.
ClientControl.SessionPropertiesListener.Default - Class in com.pushtechnology.diffusion.client.features.control.clients
This provides a default implementation of ClientControl.SessionPropertiesListener which will simply log session properties callbacks at debug level.
ClientControl.SessionPropertiesListener.EventType - Enum in com.pushtechnology.diffusion.client.features.control.clients
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
This provides a default implementation of ClientControl.SessionPropertiesListener which will simply log session properties callbacks at debug level.
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 a client session.
close(SessionId, C, ClientControl.ClientContextCallback<C>) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.ClientControl
Close a client session with a contextual callback.
close() - Method in interface com.pushtechnology.diffusion.client.features.RegisteredHandler
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.
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
Callback interface that provides responses from the server, together with an application supplied context object.
ContextCallback<C> - Interface in com.pushtechnology.diffusion.client.features
A callback interface used to return results from a call to the server with context supplied with the call.
ContextCallback.Default<C> - Class in com.pushtechnology.diffusion.client.callbacks
Abstract default callback.
ContextCallback.Default<C> - Class in com.pushtechnology.diffusion.client.features
Abstract default callback.
ContextStream<C> - Interface in com.pushtechnology.diffusion.client.callbacks
An extension of ContextCallback that allows many callbacks for each call context.
ContextStream.Default<C> - Class in com.pushtechnology.diffusion.client.callbacks
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.
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(String, String, String, Credentials) - Method in interface com.pushtechnology.diffusion.client.features.control.RemoteServers
Create a new remote server instance with default connection options.
createRemoteServer(String, String, String, Credentials, Map<RemoteServers.RemoteServer.ConnectionOption, String>) - Method in interface com.pushtechnology.diffusion.client.features.control.RemoteServers
Create a new remote server instance.
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
Creates an update stream to use for updating a specific topic.
createUpdateStream(String, Class<T>, UpdateConstraint) - Method in interface com.pushtechnology.diffusion.client.features.TopicUpdate
Creates an update stream to use for updating a specific topic.
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.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
Create a Credentials of type CUSTOM.
customCredentials(byte[]) - Method in interface com.pushtechnology.diffusion.client.session.SessionFactory
Set credentials of type Credentials.Type.CUSTOM.

D

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
 
Default() - Constructor for class com.pushtechnology.diffusion.client.callbacks.ContextStream.Default
 
Default() - Constructor for class com.pushtechnology.diffusion.client.callbacks.ServerHandler.Default
 
Default() - Constructor for class com.pushtechnology.diffusion.client.callbacks.Stream.Default
 
Default() - Constructor for class com.pushtechnology.diffusion.client.callbacks.TopicTreeHandler.Default
 
Default() - Constructor for class com.pushtechnology.diffusion.client.features.Callback.Default
 
Default() - Constructor for class com.pushtechnology.diffusion.client.features.ContextCallback.Default
 
Default() - Constructor for class com.pushtechnology.diffusion.client.features.control.clients.ClientControl.ClientCallback.Default
 
Default() - Constructor for class com.pushtechnology.diffusion.client.features.control.clients.ClientControl.ClientContextCallback.Default
 
Default() - Constructor for class com.pushtechnology.diffusion.client.features.control.clients.ClientControl.QueueEventHandler.Default
 
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
 
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.MessagingControl.FilteredRequestCallback.Default
Deprecated.
 
Default() - Constructor for class com.pushtechnology.diffusion.client.features.control.topics.SubscriptionControl.RoutingSubscriptionRequest.Handler.Default
 
Default() - Constructor for class com.pushtechnology.diffusion.client.features.control.topics.SubscriptionControl.RoutingSubscriptionRequest.RoutingHandler.Default
 
Default() - Constructor for class com.pushtechnology.diffusion.client.features.control.topics.SubscriptionControl.SubscriptionByFilterCallback.Default
 
Default() - Constructor for class com.pushtechnology.diffusion.client.features.control.topics.SubscriptionControl.SubscriptionByFilterContextCallback.Default
 
Default() - Constructor for class com.pushtechnology.diffusion.client.features.control.topics.SubscriptionControl.SubscriptionCallback.Default
 
Default() - Constructor for class com.pushtechnology.diffusion.client.features.control.topics.SubscriptionControl.SubscriptionContextCallback.Default
 
Default() - Constructor for class com.pushtechnology.diffusion.client.features.control.topics.TopicControl.AddCallback.Default
 
Default() - Constructor for class com.pushtechnology.diffusion.client.features.control.topics.TopicControl.AddContextCallback.Default
 
Default() - Constructor for class com.pushtechnology.diffusion.client.features.control.topics.TopicControl.MissingTopicHandler.Default
 
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
 
Default() - Constructor for class com.pushtechnology.diffusion.client.features.control.topics.TopicControl.RemovalContextCallback.Default
 
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
 
Default() - Constructor for class com.pushtechnology.diffusion.client.features.Pings.PingContextCallback.Default
 
Default() - Constructor for class com.pushtechnology.diffusion.client.features.Security.ChangePrincipalCallback.Default
 
Default() - Constructor for class com.pushtechnology.diffusion.client.features.Security.ChangePrincipalContextCallback.Default
 
Default() - Constructor for class com.pushtechnology.diffusion.client.features.ServerHandler.Default
 
Default() - Constructor for class com.pushtechnology.diffusion.client.features.Topics.CompletionCallback.Default
 
Default() - Constructor for class com.pushtechnology.diffusion.client.features.Topics.CompletionContextCallback.Default
 
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
 
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
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
Obtain a DeltaType by name.
deltaType(Class<D>) - Method in interface com.pushtechnology.diffusion.datatype.DataType
Obtain a DeltaType by class.
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.

E

edit(String, long, Class<V>, V) - Method in interface com.pushtechnology.diffusion.client.features.TimeSeries
Update a time series topic by appending a new value that overrides the value of an existing event.
editRange() - Method in interface com.pushtechnology.diffusion.client.features.TimeSeries.RangeQuery
Return a copy of this RangeQuery configured to perform a value range query with the edit range set to the entire time series.
equals(Object) - Method in class com.pushtechnology.diffusion.client.callbacks.ErrorReason
 
equals(Object) - Method in interface com.pushtechnology.diffusion.client.session.SessionId
Checks identifier against another object for equality.
errorHandler(Session.ErrorHandler) - Method in interface com.pushtechnology.diffusion.client.session.SessionFactory
Nominates an error handler for a session.
ErrorReason - Class in com.pushtechnology.diffusion.client.callbacks
Reason codes used to report error conditions.
ErrorReason(int, String) - Constructor for class com.pushtechnology.diffusion.client.callbacks.ErrorReason
Constructor.
ErrorReport - Interface in com.pushtechnology.diffusion.client.types
An error report.
ErrorReportsException - Exception in com.pushtechnology.diffusion.client.features
Thrown to report one or more ErrorReports}.
ErrorReportsException(String, List<ErrorReport>) - Constructor for exception com.pushtechnology.diffusion.client.features.ErrorReportsException
Constructor.
escape(String) - Static method in enum com.pushtechnology.diffusion.client.Diffusion
Escapes special characters in a string that is to be used within a topic property or a session filter.
escape(String) - Method in interface com.pushtechnology.diffusion.client.Diffusion.Implementation
Escapes special characters in a string.
ExclusiveUpdaterConflictException - Exception in com.pushtechnology.diffusion.client.features
Deprecated.
since 6.6

This exception is no longer used and will be removed in a future release.

ExclusiveUpdaterConflictException(String) - Constructor for exception com.pushtechnology.diffusion.client.features.ExclusiveUpdaterConflictException
Deprecated.
Constructor.
ExistingTopicException(String) - Constructor for exception com.pushtechnology.diffusion.client.features.control.topics.TopicControl.ExistingTopicException
 

F

failedOperation() - Method in interface com.pushtechnology.diffusion.client.features.TopicUpdate.JsonPatchResult
 
FailedPatchException(String) - Constructor for exception com.pushtechnology.diffusion.client.features.TopicUpdate.FailedPatchException
 
FailedPatchException(String, Throwable) - Constructor for exception com.pushtechnology.diffusion.client.features.TopicUpdate.FailedPatchException
 
Feature - Interface in com.pushtechnology.diffusion.client.session
This is the base interface for features that may be added directly to a client session.
feature(Class<T>) - Method in interface com.pushtechnology.diffusion.client.session.Session
Obtain a feature.
fetch(TopicSelector) - Method in interface com.pushtechnology.diffusion.client.features.Topics.FetchRequest
Sends a fetch request to the server.
fetch(String) - Method in interface com.pushtechnology.diffusion.client.features.Topics.FetchRequest
Sends a fetch request to the server.
fetchRequest() - Method in interface com.pushtechnology.diffusion.client.features.Topics
Creates an unconfigured fetch request.
fieldCount(String, int, String) - Method in interface com.pushtechnology.diffusion.datatype.recordv2.model.RecordModel
Returns the actual number of occurrences of a named field within a specified record occurrences.
fieldIndex() - Method in interface com.pushtechnology.diffusion.datatype.recordv2.RecordV2Delta.Change
Returns the index of the affected field.
fieldName() - Method in interface com.pushtechnology.diffusion.datatype.recordv2.RecordV2Delta.Change
Returns the name of the affected field.
first(int) - Method in interface com.pushtechnology.diffusion.client.features.Topics.FetchRequest
Specifies a maximum number of topic results to be returned from the start of the required range.
forEdits() - 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 view range set to the entire time series.
forValues() - Method in interface com.pushtechnology.diffusion.client.features.TimeSeries.RangeQuery
Return a copy of this RangeQuery configured to perform a value range query with the view range set to the entire time series.
from(long) - Method in interface com.pushtechnology.diffusion.client.features.TimeSeries.RangeQuery
Return a copy of this RangeQuery with the anchor of the current range configured to be an absolute sequence number.
from(Instant) - Method in interface com.pushtechnology.diffusion.client.features.TimeSeries.RangeQuery
Return a copy of this RangeQuery with the anchor of the current range configured to be an absolute time.
from(Date) - Method in interface com.pushtechnology.diffusion.client.features.TimeSeries.RangeQuery
Return a copy of this RangeQuery with the anchor of the current range configured to be an absolute time.
from(String) - Method in interface com.pushtechnology.diffusion.client.features.Topics.FetchRequest
Specifies a logical start point within the topic tree.
fromJsonString(String) - Method in interface com.pushtechnology.diffusion.datatype.json.JSONDataType
Parse a JSON string.
fromLast(long) - Method in interface com.pushtechnology.diffusion.client.features.TimeSeries.RangeQuery
Return a copy of this RangeQuery with the anchor of the current range configured to be a relative offset before the end of the time series.
fromLast(Duration) - Method in interface com.pushtechnology.diffusion.client.features.TimeSeries.RangeQuery
Return a copy of this RangeQuery with the anchor of the current range configured to be a relative time from the timestamp of the last event in the time series.
fromLastMillis(long) - Method in interface com.pushtechnology.diffusion.client.features.TimeSeries.RangeQuery
Return a copy of this RangeQuery with the anchor of the current range configured to be a relative time from the timestamp of the last event in the time series.
fromStart() - Method in interface com.pushtechnology.diffusion.client.features.TimeSeries.RangeQuery
Return a copy of this RangeQuery with the anchor of the current range configured to be the start of the time series.
FULL_PATH_PATTERN_PREFIX - Static variable in interface com.pushtechnology.diffusion.client.topics.TopicSelector
Prefix used for FULL_PATH_PATTERN expressions.

G

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.
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
Deprecated.
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.
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.
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.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.control.topics.MessagingControl.RequestHandler.RequestContext
Deprecated.
Returns the message path of the request.
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
Deprecated.
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.
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
Obtain the current contents of the security store.
getSecurity(C, SecurityControl.ConfigurationContextCallback<C>) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.SecurityControl
Obtain the current contents of the security store, with a contextual callback.
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.
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
 
getSessionId() - Method in interface com.pushtechnology.diffusion.client.features.control.topics.MessagingControl.RequestHandler.RequestContext
Deprecated.
SessionId of the session that sent the request.
getSessionId() - Method in interface com.pushtechnology.diffusion.client.features.control.topics.SubscriptionControl.RoutingSubscriptionRequest
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
Query the server for property values of a specified client session.
getSessionProperties(SessionId, Collection<String>, C, ClientControl.SessionPropertiesContextCallback<C>) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.ClientControl
Query the server for property values of a specified client session.
getSessionProperties() - Method in interface com.pushtechnology.diffusion.client.features.control.topics.MessagingControl.RequestHandler.RequestContext
Deprecated.
Session properties of the session that sent the request.
getSessionProperties() - Method in interface com.pushtechnology.diffusion.client.features.Messaging.RequestHandler.RequestContext
Session properties of the session that sent the request.
getSpecification() - Method in interface com.pushtechnology.diffusion.client.features.control.topics.views.TopicView
The specification of the topic view.
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
Obtain the current contents of the store.
getSystemAuthentication(C, SystemAuthenticationControl.ConfigurationContextCallback<C>) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.SystemAuthenticationControl
Query the store for all of the system principals, with a contextual callback.
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
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
Deprecated.
getTopicSelector() - Method in interface com.pushtechnology.diffusion.client.features.control.topics.TopicControl.MissingTopicNotification
Returns the TopicSelector that triggered this notification.
getTopicSelectors() - Method in interface com.pushtechnology.diffusion.client.Diffusion.Implementation
 
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.

H

HANDLER_CONFLICT - Static variable in class com.pushtechnology.diffusion.client.callbacks.ErrorReason
A conflicting registration exists.
HandlerConflictException - Exception in com.pushtechnology.diffusion.client.features
Thrown to indicate a handler could not be registered because it conflicts with an existing handler.
HandlerConflictException(String) - Constructor for exception com.pushtechnology.diffusion.client.features.HandlerConflictException
Constructor.
hasChanges() - Method in interface com.pushtechnology.diffusion.datatype.BinaryDelta
Returns whether the two values used to create this instance are different.
hasChanges() - Method in interface com.pushtechnology.diffusion.datatype.json.JSONDelta
Returns whether the two JSON values used to create this instance are different.
hashCode() - Method in class com.pushtechnology.diffusion.client.callbacks.ErrorReason
 
hashCode() - Method in interface com.pushtechnology.diffusion.client.session.SessionId
Returns hash code of session identifier.
hasMore() - Method in interface com.pushtechnology.diffusion.client.features.Topics.FetchResult
Indicates whether the fetch could have returned more results if it had not been constrained by the first, last or maximumResultSize limits.
httpProxy(String, int) - Method in interface com.pushtechnology.diffusion.client.session.SessionFactory
Set the address of the HTTP Proxy that should be used to make connections to the server.
httpProxy(String, int, HTTPProxyAuthentication) - Method in interface com.pushtechnology.diffusion.client.session.SessionFactory
A variant of SessionFactory.httpProxy(String, int) that provides authentication details to the HTTP proxy.
HTTPProxyAuthentication - Interface in com.pushtechnology.diffusion.client.session.proxy
Interface that defines a proxy authentication scheme.
HTTPProxyAuthentication.ChallengeHandler - Interface in com.pushtechnology.diffusion.client.session.proxy
Allows for an authentication implementation to be provided for connections routed via HTTP proxies.

I

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.
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.

J

json() - Method in interface com.pushtechnology.diffusion.datatype.DataTypes
JSON is "JavaScript Object Notation", a lightweight data-interchange format.
JSON - Interface in com.pushtechnology.diffusion.datatype.json
Immutable JSON data value.
JSON_DATATYPE_NAME - Static variable in interface com.pushtechnology.diffusion.datatype.DataTypes
JSON data type name.
JSONDataType - Interface in com.pushtechnology.diffusion.datatype.json
JSON data type.
JSONDelta - Interface in com.pushtechnology.diffusion.datatype.json
Structural delta type for JSON.
JSONDelta.ChangeMap - Interface in com.pushtechnology.diffusion.datatype.json
An unmodifiable map describing the changes to a JSON value.
jsonValue() - Method in interface com.pushtechnology.diffusion.client.features.UpdateConstraint.Factory
Create a constraint that partially matches the current topic value.

K

key() - Method in interface com.pushtechnology.diffusion.datatype.recordv2.RecordV2Delta.Change
Returns the string key representation of the affected item in the form recordName(recordIndex).fieldName(fieldIndex) or just recordName(recordIndex) in the case of RECORDS_ADDED or RECORDS_REMOVED.

L

LANGUAGE - Static variable in interface com.pushtechnology.diffusion.client.session.Session
Session property key for language code.
last(int) - Method in interface com.pushtechnology.diffusion.client.features.Topics.FetchRequest
Specifies a maximum number of topic results to be returned from the end of the required range.
latestEdits() - 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 latest edits in the entire time series.
LATITUDE - Static variable in interface com.pushtechnology.diffusion.client.session.Session
Session property key for client latitude.
length() - Method in interface com.pushtechnology.diffusion.datatype.BinaryDelta
 
length() - Method in interface com.pushtechnology.diffusion.datatype.Bytes
 
limit(long) - Method in interface com.pushtechnology.diffusion.client.features.TimeSeries.RangeQuery
Return a copy of this RangeQuery that returns at most count events.
limitDeepBranches(int, int) - Method in interface com.pushtechnology.diffusion.client.features.Topics.FetchRequest
Specifies a limit on the number of results returned for each deep branch.
listener(Session.Listener) - Method in interface com.pushtechnology.diffusion.client.session.SessionFactory
Nominates a listener for session events from a session.
listRemoteServers() - Method in interface com.pushtechnology.diffusion.client.features.control.RemoteServers
List all the remote servers that have been created.
listTopicViews() - Method in interface com.pushtechnology.diffusion.client.features.control.topics.views.TopicViews
List all the topic views that have been created.
localSocketAddress(SocketAddress) - Method in interface com.pushtechnology.diffusion.client.session.SessionFactory
Set the optional local socket address, used prior to connection.
lock(String) - Method in interface com.pushtechnology.diffusion.client.session.Session
Attempt to acquire a session lock.
lock(String, Session.SessionLockScope) - Method in interface com.pushtechnology.diffusion.client.session.Session
Variant of Session.lock(String) that provides control over when a lock will be released.
locked(Session.SessionLock) - Method in interface com.pushtechnology.diffusion.client.features.UpdateConstraint.Factory
Create a constraint requiring a lock to be held by the session.
LONGITUDE - Static variable in interface com.pushtechnology.diffusion.client.session.Session
Session property key for client longitude.

M

MAXIMUM_MESSAGE_SIZE_MIN - Static variable in interface com.pushtechnology.diffusion.client.session.SessionAttributes
The minimum value that the maximum message size can be set to in bytes.
maximumMessageSize(int) - Method in interface com.pushtechnology.diffusion.client.session.SessionFactory
Set the maximum message size.
maximumQueueSize(int) - Method in interface com.pushtechnology.diffusion.client.session.SessionFactory
Sets the maximum size of the outbound message queue for the connection.
maximumResultSize(int) - Method in interface com.pushtechnology.diffusion.client.features.Topics.FetchRequest
Specifies the maximum data size of the result set.
merge(TimeSeries.QueryResult<V>) - Method in interface com.pushtechnology.diffusion.client.features.TimeSeries.QueryResult
Merge this result with other, combining original events and edit events, to produce an TimeSeries.QueryResult of type VALUE_EVENT_STREAM
MessageQueuePolicy - Interface in com.pushtechnology.diffusion.client.features.control.clients
Policy for managing a client message queue.
Messaging - Interface in com.pushtechnology.diffusion.client.features
This feature provides a client session with request-response messaging capabilities that can be used to implement application services.
Messaging.FilteredRequestCallback<R> - Interface in com.pushtechnology.diffusion.client.features
Callback interface for requests dispatched through a filter.
Messaging.FilteredRequestCallback.Default<R> - Class in com.pushtechnology.diffusion.client.features
Default implementation of Messaging.FilteredRequestCallback.
Messaging.RequestHandler<T,R> - Interface in com.pushtechnology.diffusion.client.features
Interface which specifies a request handler to receive request notifications.
Messaging.RequestHandler.RequestContext - Interface in com.pushtechnology.diffusion.client.features
Context of the request received.
Messaging.RequestHandler.Responder<R> - Interface in com.pushtechnology.diffusion.client.features
Responder interface to dispatch responses to requests.
Messaging.RequestStream<T,R> - Interface in com.pushtechnology.diffusion.client.features
Interface which specifies a request stream to receive request notifications.
Messaging.RequestStream.Responder<R> - Interface in com.pushtechnology.diffusion.client.features
Responder interface to dispatch responses to requests.
MessagingControl - Interface in com.pushtechnology.diffusion.client.features.control.topics
Deprecated.
since 6.5. Use the Messaging feature instead. All methods and types have been moved there from this interface which will be removed in a future release.
MessagingControl.FilteredRequestCallback<R> - Interface in com.pushtechnology.diffusion.client.features.control.topics
MessagingControl.FilteredRequestCallback.Default<R> - Class in com.pushtechnology.diffusion.client.features.control.topics
Deprecated.
Default implementation of MessagingControl.FilteredRequestCallback.
MessagingControl.RequestHandler<T,R> - Interface in com.pushtechnology.diffusion.client.features.control.topics
Deprecated.
Since 6.5. Use Messaging.RequestHandler.
MessagingControl.RequestHandler.RequestContext - Interface in com.pushtechnology.diffusion.client.features.control.topics
Deprecated.
Context of the request received.
MessagingControl.RequestHandler.Responder<R> - Interface in com.pushtechnology.diffusion.client.features.control.topics
Deprecated.
Since 6.5. Use Messaging.RequestStream.Responder.
MutableRecordModel - Interface in com.pushtechnology.diffusion.datatype.recordv2.model
This is a mutable data model of RecordV2 data based upon a Schema.

N

newSpecification(TopicType) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.TopicControl
Create a new TopicSpecification for a given topic type.
newTopicSpecification(TopicType) - Method in interface com.pushtechnology.diffusion.client.Diffusion.Implementation
 
newTopicSpecification(TopicType) - Static method in enum com.pushtechnology.diffusion.client.Diffusion
Create a new TopicSpecification for a given topic type.
next(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 following the anchor.
next(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 following the anchor.
nextMillis(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 following the anchor.
NO_SUCH_SESSION - Static variable in class com.pushtechnology.diffusion.client.callbacks.ErrorReason
The session does not exist on the server.
noChange() - Method in interface com.pushtechnology.diffusion.datatype.DeltaType
Constant returned by DeltaType.diff(Object, Object) to indicate oldValue and newValue are equivalent.
noCredentials() - Method in interface com.pushtechnology.diffusion.client.session.SessionFactory
Set credentials to Credentials.Type.NONE.
noCredentials() - Method in interface com.pushtechnology.diffusion.client.types.Credentials.Factory
Create a Credentials of type NONE.
noReconnection() - Method in interface com.pushtechnology.diffusion.client.session.SessionFactory
Disable reconnection.
NoSuchEventException(String) - Constructor for exception com.pushtechnology.diffusion.client.features.TimeSeries.NoSuchEventException
Constructor.
NoSuchSessionException - Exception in com.pushtechnology.diffusion.client.features
Exception used to report there is no session for a given session ID.
NoSuchSessionException(String) - Constructor for exception com.pushtechnology.diffusion.client.features.NoSuchSessionException
Constructor.
NoSuchTopicException - Exception in com.pushtechnology.diffusion.client.features
Exception used to report there is no topic bound to a topic path.
NoSuchTopicException(String) - Constructor for exception com.pushtechnology.diffusion.client.features.NoSuchTopicException
Constructor.
noTopic() - Method in interface com.pushtechnology.diffusion.client.features.UpdateConstraint.Factory
Create a constraint requiring the path to have no topic.
noValue() - Method in interface com.pushtechnology.diffusion.client.features.UpdateConstraint.Factory
Create a constraint requiring the topic to have no value.
numberSelected() - Method in interface com.pushtechnology.diffusion.client.features.control.topics.SubscriptionControl.SubscriptionByFilterResult
 

O

onActive(RegisteredHandler) - Method in class com.pushtechnology.diffusion.client.features.ServerHandler.Default
 
onActive(RegisteredHandler) - Method in interface com.pushtechnology.diffusion.client.features.ServerHandler
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
 
onActive(String, RegisteredHandler) - Method in interface com.pushtechnology.diffusion.client.features.TopicTreeHandler
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
 
onAuthenticationFailure() - Method in interface com.pushtechnology.diffusion.client.features.Security.ChangePrincipalCallback
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
 
onAuthenticationFailure(C) - Method in interface com.pushtechnology.diffusion.client.features.Security.ChangePrincipalContextCallback
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
 
onClose(C) - Method in interface com.pushtechnology.diffusion.client.callbacks.ContextStream
Notification that a call context was closed normally.
onClose() - Method in class com.pushtechnology.diffusion.client.callbacks.ServerHandler.Default
 
onClose() - Method in interface com.pushtechnology.diffusion.client.callbacks.ServerHandler
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(String) - Method in class com.pushtechnology.diffusion.client.callbacks.TopicTreeHandler.Default
 
onClose(String) - Method in interface com.pushtechnology.diffusion.client.callbacks.TopicTreeHandler
Called if the handler is closed.
onClose() - Method in interface com.pushtechnology.diffusion.client.features.Messaging.FilteredRequestCallback
Deprecated.
since 6.5 this method is not called; in a future release, FilteredRequestCallback will no longer extend Stream.
onClose() - Method in class com.pushtechnology.diffusion.client.features.ServerHandler.Default
 
onClose() - Method in interface com.pushtechnology.diffusion.client.features.ServerHandler
Called if the handler is closed.
onClose(String) - Method in class com.pushtechnology.diffusion.client.features.TopicTreeHandler.Default
 
onClose(String) - Method in interface com.pushtechnology.diffusion.client.features.TopicTreeHandler
Called if the handler is closed.
onComplete() - Method in class com.pushtechnology.diffusion.client.features.control.clients.ClientControl.ClientCallback.Default
 
onComplete() - Method in interface com.pushtechnology.diffusion.client.features.control.clients.ClientControl.ClientCallback
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
 
onComplete(C) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.ClientControl.ClientContextCallback
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
 
onComplete(int) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.SubscriptionControl.SubscriptionByFilterCallback
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
 
onComplete(C, int) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.SubscriptionControl.SubscriptionByFilterContextCallback
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
 
onComplete() - Method in interface com.pushtechnology.diffusion.client.features.control.topics.SubscriptionControl.SubscriptionCallback
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
 
onComplete(C) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.SubscriptionControl.SubscriptionContextCallback
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
 
onComplete() - Method in interface com.pushtechnology.diffusion.client.features.Topics.CompletionCallback
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
 
onComplete(C) - Method in interface com.pushtechnology.diffusion.client.features.Topics.CompletionContextCallback
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
 
onDiscard() - Method in interface com.pushtechnology.diffusion.client.features.Callback
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
 
onDiscard(C) - Method in interface com.pushtechnology.diffusion.client.features.ContextCallback
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
 
onError(C, ErrorReason) - Method in interface com.pushtechnology.diffusion.client.callbacks.ContextCallback
Notification of a contextual error related to this callback.
onError(ErrorReason) - Method in class com.pushtechnology.diffusion.client.callbacks.ServerHandler.Default
 
onError(ErrorReason) - Method in interface com.pushtechnology.diffusion.client.callbacks.ServerHandler
Notification of a contextual error related to this handler.
onError(String, ErrorReason) - Method in class com.pushtechnology.diffusion.client.callbacks.TopicTreeHandler.Default
 
onError(String, ErrorReason) - Method in interface com.pushtechnology.diffusion.client.callbacks.TopicTreeHandler
Notification of a contextual error related to this handler.
onError(ErrorReason) - Method in interface com.pushtechnology.diffusion.client.features.Messaging.FilteredRequestCallback
Deprecated.
since 6.5 this method is no longer called; in a future release, FilteredRequestCallback will no longer extend Stream.
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
 
onLowerThresholdCrossed(SessionId, MessageQueuePolicy) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.ClientControl.QueueEventHandler
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
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.
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
Called when a session has been successfully opened.
onOpened(C, Session) - Method in interface com.pushtechnology.diffusion.client.session.SessionFactory.OpenContextCallback
Called when a session has been successfully opened.
onPingResponse(Pings.PingDetails) - Method in class com.pushtechnology.diffusion.client.features.Pings.PingCallback.Default
 
onPingResponse(Pings.PingDetails) - Method in interface com.pushtechnology.diffusion.client.features.Pings.PingCallback
Called with ping response from the server.
onPingResponse(C, Pings.PingDetails) - Method in class com.pushtechnology.diffusion.client.features.Pings.PingContextCallback.Default
 
onPingResponse(C, Pings.PingDetails) - Method in interface com.pushtechnology.diffusion.client.features.Pings.PingContextCallback
Called with ping response from the server.
onPrincipalChanged() - Method in class com.pushtechnology.diffusion.client.features.Security.ChangePrincipalCallback.Default
 
onPrincipalChanged() - Method in interface com.pushtechnology.diffusion.client.features.Security.ChangePrincipalCallback
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
 
onPrincipalChanged(C) - Method in interface com.pushtechnology.diffusion.client.features.Security.ChangePrincipalContextCallback
Notification that a request to change the session principal was successful.
onRegistered(Registration) - Method in class com.pushtechnology.diffusion.client.callbacks.ServerHandler.Default
 
onRegistered(Registration) - Method in interface com.pushtechnology.diffusion.client.callbacks.ServerHandler
Called when the handler has been successfully registered with the server.
onRegistered(String, Registration) - Method in class com.pushtechnology.diffusion.client.callbacks.TopicTreeHandler.Default
 
onRegistered(String, Registration) - Method in interface com.pushtechnology.diffusion.client.callbacks.TopicTreeHandler
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
The script was rejected.
onRejected(C, Collection<ErrorReport>) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.SecurityStoreFeature.UpdateStoreContextCallback
The script was rejected.
onRejected(Collection<ErrorReport>) - Method in class com.pushtechnology.diffusion.client.features.control.topics.SubscriptionControl.SubscriptionByFilterCallback.Default
 
onRejected(Collection<ErrorReport>) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.SubscriptionControl.SubscriptionByFilterCallback
The filter was rejected.
onRejected(C, Collection<ErrorReport>) - Method in class com.pushtechnology.diffusion.client.features.control.topics.SubscriptionControl.SubscriptionByFilterContextCallback.Default
 
onRejected(C, Collection<ErrorReport>) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.SubscriptionControl.SubscriptionByFilterContextCallback
The filter was rejected.
onReply(SessionId, Map<String, String>) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.ClientControl.SessionPropertiesCallback
Called to return requested session properties.
onReply(C, SessionId, Map<String, String>) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.ClientControl.SessionPropertiesContextCallback
Called to return requested session properties.
onReply(SecurityControl.SecurityConfiguration) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.SecurityControl.ConfigurationCallback
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
This is called to return the requested security configuration.
onReply(SystemAuthenticationControl.SystemAuthenticationConfiguration) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.SystemAuthenticationControl.ConfigurationCallback
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
This is called to return the requested system authentication configuration.
onRequest(T, MessagingControl.RequestHandler.RequestContext, MessagingControl.RequestHandler.Responder<R>) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.MessagingControl.RequestHandler
Deprecated.
Called to indicate a request has been received.
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.control.topics.MessagingControl.FilteredRequestCallback.Default
Deprecated.
 
onResponse(SessionId, R) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.MessagingControl.FilteredRequestCallback
Deprecated.
Called when a response 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.control.topics.MessagingControl.FilteredRequestCallback.Default
Deprecated.
 
onResponseError(SessionId, Throwable) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.MessagingControl.FilteredRequestCallback
Deprecated.
Called when a response from a session results in an error.
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
 
onSessionClose(SessionId, Map<String, String>, ClientControl.CloseReason) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.ClientControl.SessionPropertiesListener
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
 
onSessionEvent(SessionId, ClientControl.SessionPropertiesListener.EventType, Map<String, String>, Map<String, String>) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.ClientControl.SessionPropertiesListener
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
 
onSessionOpen(SessionId, Map<String, String>) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.ClientControl.SessionPropertiesListener
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
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
A request to subscribe to a specific routing topic.
onSuccess() - Method in interface com.pushtechnology.diffusion.client.features.control.clients.SecurityStoreFeature.UpdateStoreCallback
The script was applied successfully.
onSuccess(C) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.SecurityStoreFeature.UpdateStoreContextCallback
The script was applied successfully.
onTopicAdded(String) - Method in class com.pushtechnology.diffusion.client.features.control.topics.TopicControl.AddCallback.Default
 
onTopicAdded(String) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.TopicControl.AddCallback
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
 
onTopicAdded(C, String) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.TopicControl.AddContextCallback
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
 
onTopicAddFailed(String, TopicAddFailReason) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.TopicControl.AddCallback
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
 
onTopicAddFailed(C, String, TopicAddFailReason) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.TopicControl.AddContextCallback
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
 
onTopicsRemoved() - Method in interface com.pushtechnology.diffusion.client.features.control.topics.TopicControl.RemovalCallback
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
 
onTopicsRemoved(C) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.TopicControl.RemovalContextCallback
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
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
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
 
onUpperThresholdCrossed(SessionId, MessageQueuePolicy) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.ClientControl.QueueEventHandler
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 a connection to a server and request a new session.
open(String, C, SessionFactory.OpenContextCallback<C>) - Method in interface com.pushtechnology.diffusion.client.session.SessionFactory
Open a connection to a server and request a new session.
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 a connection to a server and request a new session.
open(C, SessionFactory.OpenContextCallback<C>) - Method in interface com.pushtechnology.diffusion.client.session.SessionFactory
Open a connection to a server and request a new session.
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.

P

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
Set credentials of type Credentials.Type.PLAIN_PASSWORD.
password(String) - Method in interface com.pushtechnology.diffusion.client.types.Credentials.Factory
Create a Credentials of type PLAIN_PASSWORD.
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.
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
Callback interface for Pings.pingServer(PingCallback).
Pings.PingCallback.Default - Class in com.pushtechnology.diffusion.client.features
Default implementation of Pings.PingCallback.
Pings.PingContextCallback<C> - Interface in com.pushtechnology.diffusion.client.features
Pings.PingContextCallback.Default<C> - Class in com.pushtechnology.diffusion.client.features
Default implementation of Pings.PingContextCallback.
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
Sends a ping request to the server.
pingServer(C, Pings.PingContextCallback<C>) - Method in interface com.pushtechnology.diffusion.client.features.Pings
Sends a ping request to the server.
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 - 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
Instruct the server to complete processing of the request.
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
Factory for proxy authentication instances.
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.

R

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.
readAs(Class<T>, byte[], int, int) - Method in interface com.pushtechnology.diffusion.datatype.json.JSONDataType
Create a value of a compatible class from a binary.
readAs(Class<T>, byte[]) - Method in interface com.pushtechnology.diffusion.datatype.json.JSONDataType
Create a value of a compatible class from binary.
readAs(Class<T>, Bytes) - Method in interface com.pushtechnology.diffusion.datatype.json.JSONDataType
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
RecordV2 data 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
Builds free format RecordV2 value.
RecordV2DataType - Interface in com.pushtechnology.diffusion.datatype.recordv2
Record-based data type.
RecordV2Delta - Interface in com.pushtechnology.diffusion.datatype.recordv2
RecordV2 structural delta.
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
A reference to a registered handler.
Registration - Interface in com.pushtechnology.diffusion.client.callbacks
A reference to a registered handler.
reject(String) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.MessagingControl.RequestHandler.Responder
Deprecated.
Reject a request.
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
Result returned from a RemoteServers.checkRemoteServer(java.lang.String) invocation.
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.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
Send a request to remove one or more topics.
remove(String, C, TopicControl.RemovalContextCallback<C>) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.TopicControl
Version of TopicControl.remove(String, RemovalCallback) that allows a user defined context to be provided.
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.
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.
removeStream(Stream) - Method in interface com.pushtechnology.diffusion.client.features.Topics
Remove a stream.
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.
respond(R) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.MessagingControl.RequestHandler.Responder
Deprecated.
Dispatch a response to a request.
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
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
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
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
Exception used to report a failure to establish a routing subscription.
RoutingSubscriptionException(String) - Constructor for exception com.pushtechnology.diffusion.client.features.control.topics.RoutingSubscriptionException
Constructor.

S

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
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 Node - A Schema.Record or a Schema.Field.
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
Default implementation of Security.ChangePrincipalCallback.
Security.ChangePrincipalContextCallback<C> - Interface in com.pushtechnology.diffusion.client.features
Security.ChangePrincipalContextCallback.Default<C> - Class in com.pushtechnology.diffusion.client.features
Default implementation of Security.ChangePrincipalContextCallback.
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
The callback interface for use with getSecurity .
SecurityControl.ConfigurationContextCallback<C> - Interface in com.pushtechnology.diffusion.client.features.control.clients
The contextual callback interface for use with getSecurity .
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
The callback interface for use with updateStore .
SecurityStoreFeature.UpdateStoreContextCallback<C> - Interface in com.pushtechnology.diffusion.client.features.control.clients
The contextual callback interface for use with updateStore .
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>, MessagingControl.FilteredRequestCallback<? super R>) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.MessagingControl
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
Common interface for callback handlers that establish a server side control presence for the client session.
ServerHandler - Interface in com.pushtechnology.diffusion.client.features
This is the base interface for all callback handlers registered via a client session that establish a server side control presence for the client.
ServerHandler.Default - Class in com.pushtechnology.diffusion.client.callbacks
Skeleton server handler implementation.
ServerHandler.Default - Class in com.pushtechnology.diffusion.client.features
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() - 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
Default Session.ErrorHandler implementation which simply logs errors at error level.
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
Values for the scope parameter of Session.lock(String, SessionLockScope).
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(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() - 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
 
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
Factory for client sessions.
SessionFactory.OpenCallback - Interface in com.pushtechnology.diffusion.client.session
Callback interface for non-blocking opening of sessions.
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.features.control.clients.ClientControl
Restore a SessionId from a string.
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(Throwable) - Constructor for exception com.pushtechnology.diffusion.client.session.SessionSecurityException
 
SessionSecurityException(String) - Constructor for exception com.pushtechnology.diffusion.client.session.SessionSecurityException
 
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
Control client queue conflation.
setConflated(SessionId, boolean, C, ClientControl.ClientContextCallback<C>) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.ClientControl
Control client queue conflation with a contextual callback.
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
Register a handler for client queue threshold events.
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
Register a listener that will be notified when client sessions are opened, disconnected, reconnected, closed or when selected session property values are updated.
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
Prefix used for SPLIT_PATH_PATTERN expressions.
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
Returns a description of the structure of the result stream.
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 another session to topics.
subscribe(SessionId, TopicSelector, SubscriptionControl.SubscriptionCallback) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.SubscriptionControl
Subscribe another session to topics.
subscribe(SessionId, String, C, SubscriptionControl.SubscriptionContextCallback<C>) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.SubscriptionControl
Subscribe another session to topics.
subscribe(SessionId, TopicSelector, C, SubscriptionControl.SubscriptionContextCallback<C>) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.SubscriptionControl
Subscribe another session to topics.
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
Request subscription to topics.
subscribe(String, Topics.CompletionCallback) - Method in interface com.pushtechnology.diffusion.client.features.Topics
Request subscription to topics.
subscribe(TopicSelector, C, Topics.CompletionContextCallback<C>) - Method in interface com.pushtechnology.diffusion.client.features.Topics
Request subscription to topics.
subscribe(String, C, Topics.CompletionContextCallback<C>) - Method in interface com.pushtechnology.diffusion.client.features.Topics
Request subscription to 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
Subscribe sessions that satisfy a given session filter to topics.
subscribeByFilter(String, TopicSelector, SubscriptionControl.SubscriptionByFilterCallback) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.SubscriptionControl
Subscribe sessions that satisfy a given session filter to topics.
subscribeByFilter(String, String, C, SubscriptionControl.SubscriptionByFilterContextCallback<C>) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.SubscriptionControl
Subscribe sessions that satisfy a given session filter to topics.
subscribeByFilter(String, TopicSelector, C, SubscriptionControl.SubscriptionByFilterContextCallback<C>) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.SubscriptionControl
Subscribe sessions that satisfy a given session filter to topics.
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
A single request from a session to subscribe to routing topic.
SubscriptionControl.RoutingSubscriptionRequest.Handler - Interface in com.pushtechnology.diffusion.client.features.control.topics
Handler for routing subscription requests registered with the older, callback-based addRoutingSubscriptionHandler(String, Handler) method.
SubscriptionControl.RoutingSubscriptionRequest.Handler.Default - Class in com.pushtechnology.diffusion.client.features.control.topics
Abstract handler implementation.
SubscriptionControl.RoutingSubscriptionRequest.RoutingHandler - Interface in com.pushtechnology.diffusion.client.features.control.topics
Handler for routing subscription requests.
SubscriptionControl.RoutingSubscriptionRequest.RoutingHandler.Default - Class in com.pushtechnology.diffusion.client.features.control.topics
Abstract handler implementation.
SubscriptionControl.SubscriptionByFilterCallback - Interface in com.pushtechnology.diffusion.client.features.control.topics
Callback interface for filtered subscriptions and unsubscriptions.
SubscriptionControl.SubscriptionByFilterCallback.Default - Class in com.pushtechnology.diffusion.client.features.control.topics
SubscriptionControl.SubscriptionByFilterContextCallback<C> - Interface in com.pushtechnology.diffusion.client.features.control.topics
Callback interface for filtered subscriptions and unsubscriptions that have an associated context.
SubscriptionControl.SubscriptionByFilterContextCallback.Default<C> - Class in com.pushtechnology.diffusion.client.features.control.topics
SubscriptionControl.SubscriptionByFilterResult - Interface in com.pushtechnology.diffusion.client.features.control.topics
Result used by CompletableFuture variants of subscribeByFilter and unsubscribeByFilter.
SubscriptionControl.SubscriptionCallback - Interface in com.pushtechnology.diffusion.client.features.control.topics
Callback interface to receive status notifications for subscription and unsubscription operations.
SubscriptionControl.SubscriptionCallback.Default - Class in com.pushtechnology.diffusion.client.features.control.topics
Default implementation of SubscriptionControl.SubscriptionCallback.
SubscriptionControl.SubscriptionContextCallback<C> - Interface in com.pushtechnology.diffusion.client.features.control.topics
Contextual callback interface to receive status notifications for subscription and unsubscription operations.
SubscriptionControl.SubscriptionContextCallback.Default<C> - Class in com.pushtechnology.diffusion.client.features.control.topics
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
The callback interface for getSystemAuthentication .
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.

T

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
Query result providing a stream of events.
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
Callback interface for adding topics when no context is provided.
TopicControl.AddCallback.Default - Class in com.pushtechnology.diffusion.client.features.control.topics
A default implementation of TopicControl.AddCallback.
TopicControl.AddContextCallback<C> - Interface in com.pushtechnology.diffusion.client.features.control.topics
Contextual callback interface for adding topics.
TopicControl.AddContextCallback.Default<C> - Class in com.pushtechnology.diffusion.client.features.control.topics
A default implementation of TopicControl.AddContextCallback.
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
Deprecated.
since 6.5

Since 6.5, this exception is no longer used. This exception will be removed in a future release.

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
Handler called when a session subscribes using a topic selector that matches no topics.
TopicControl.MissingTopicHandler.Default - Class in com.pushtechnology.diffusion.client.features.control.topics
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
Callback interface for remove requests when no context is used.
TopicControl.RemovalCallback.Default - Class in com.pushtechnology.diffusion.client.features.control.topics
A default implementation of TopicControl.RemovalCallback.
TopicControl.RemovalContextCallback<C> - Interface in com.pushtechnology.diffusion.client.features.control.topics
Contextual callback interface for remove requests.
TopicControl.RemovalContextCallback.Default<C> - Class in com.pushtechnology.diffusion.client.features.control.topics
A default implementation of TopicControl.RemovalContextCallback.
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.
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
Deprecated.
since 6.5. Replaced by the equivalent PathPermission. In previous releases, the path-scoped permissions were called "topic permissions". This was a source of confusion since some of the permissions apply to message paths or to session lock names, both of which are hierarchical but have nothing to do with topics in the topic tree. The term "topic permission" has been renamed "path permission" throughout the API. Additional methods have been added to reflect this renaming. The old methods are deprecated and will be removed in a future release.
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
Callback interface for success or failure notifications from subscription and unsubscription operations.
Topics.CompletionCallback.Default - Class in com.pushtechnology.diffusion.client.features
Default implementation of Topics.CompletionCallback.
Topics.CompletionContextCallback<C> - Interface in com.pushtechnology.diffusion.client.features
Contextual callback interface for success or failure notifications from subscription operations.
Topics.CompletionContextCallback.Default<C> - Class in com.pushtechnology.diffusion.client.features
Default implementation of Topics.CompletionContextCallback.
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
Default Topics.SubscriberStream implementation.
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
Default Topics.ValueStream implementation.
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
Convert strings to TopicSelectors.
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.callbacks
Common interface for callback handlers that establish a server side control presence for the client session at a particular branch of the topic tree.
TopicTreeHandler - Interface in com.pushtechnology.diffusion.client.features
Common base interface for callback handlers registered via the client session that establish a server side control presence for a branch of the topic tree.
TopicTreeHandler.Default - Class in com.pushtechnology.diffusion.client.callbacks
Skeleton topic tree handler implementation.
TopicTreeHandler.Default - Class in com.pushtechnology.diffusion.client.features
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.

U

UNHANDLED_MESSAGE - Static variable in class com.pushtechnology.diffusion.client.callbacks.ErrorReason
A message was not handled by the server.
UnhandledMessageException - Exception in com.pushtechnology.diffusion.client.features
Exception used to report a message was not delivered to an application handler.
UnhandledMessageException(String) - Constructor for exception com.pushtechnology.diffusion.client.features.UnhandledMessageException
Constructor.
unlock() - Method in interface com.pushtechnology.diffusion.client.session.Session.SessionLock
Release a session lock, if owned.
UnsatisfiedConstraintException - Exception in com.pushtechnology.diffusion.client.features
Exception used to report that a constraint was not satisfied.
UnsatisfiedConstraintException(String) - Constructor for exception com.pushtechnology.diffusion.client.features.UnsatisfiedConstraintException
Constructor.
unsubscribe(SessionId, String) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.SubscriptionControl
Unsubscribe another session from topics.
unsubscribe(SessionId, TopicSelector) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.SubscriptionControl
Unsubscribe another session from topics.
unsubscribe(SessionId, String, SubscriptionControl.SubscriptionCallback) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.SubscriptionControl
Unsubscribe another session from topics.
unsubscribe(SessionId, TopicSelector, SubscriptionControl.SubscriptionCallback) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.SubscriptionControl
Unsubscribe another session from topics.
unsubscribe(SessionId, String, C, SubscriptionControl.SubscriptionContextCallback<C>) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.SubscriptionControl
Unsubscribe another session from topics.
unsubscribe(SessionId, TopicSelector, C, SubscriptionControl.SubscriptionContextCallback<C>) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.SubscriptionControl
Unsubscribe another session from topics.
unsubscribe(TopicSelector) - Method in interface com.pushtechnology.diffusion.client.features.Topics
Unsubscribe from topics.
unsubscribe(String) - Method in interface com.pushtechnology.diffusion.client.features.Topics
Unsubscribe from topics.
unsubscribe(TopicSelector, Topics.CompletionCallback) - Method in interface com.pushtechnology.diffusion.client.features.Topics
Unsubscribe from topics.
unsubscribe(String, Topics.CompletionCallback) - Method in interface com.pushtechnology.diffusion.client.features.Topics
Unsubscribe from topics.
unsubscribe(TopicSelector, C, Topics.CompletionContextCallback<C>) - Method in interface com.pushtechnology.diffusion.client.features.Topics
Unsubscribe from topics.
unsubscribe(String, C, Topics.CompletionContextCallback<C>) - Method in interface com.pushtechnology.diffusion.client.features.Topics
Unsubscribe from topics.
unsubscribeByFilter(String, String) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.SubscriptionControl
Unsubscribe sessions that satisfy a given session filter from topics.
unsubscribeByFilter(String, TopicSelector) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.SubscriptionControl
Unsubscribe sessions that satisfy a given session filter from topics.
unsubscribeByFilter(String, String, SubscriptionControl.SubscriptionByFilterCallback) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.SubscriptionControl
Unsubscribe sessions that satisfy a given session filter from topics.
unsubscribeByFilter(String, TopicSelector, SubscriptionControl.SubscriptionByFilterCallback) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.SubscriptionControl
Unsubscribe sessions that satisfy a given session filter from topics.
unsubscribeByFilter(String, String, C, SubscriptionControl.SubscriptionByFilterContextCallback<C>) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.SubscriptionControl
Unsubscribe sessions that satisfy a given session filter from topics.
unsubscribeByFilter(String, TopicSelector, C, SubscriptionControl.SubscriptionByFilterContextCallback<C>) - Method in interface com.pushtechnology.diffusion.client.features.control.topics.SubscriptionControl
Unsubscribe sessions that satisfy a given session filter from topics.
UNSUPPORTED - Static variable in class com.pushtechnology.diffusion.client.callbacks.ErrorReason
The request was rejected because the requested service is unsupported for this caller.
untilLast(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 a number of events before the end of the time series.
untilLast(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 end at a relative time from the timestamp of the last event in the time series.
untilLastMillis(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 a relative time from the timestamp of the last event in the time series.
UpdateConstraint - Interface in com.pushtechnology.diffusion.client.features
A constraint to be applied to an update operation or the creation of an update stream.
UpdateConstraint.Factory - Interface in com.pushtechnology.diffusion.client.features
Factory for the constraint types.
UpdateConstraint.PartialJSON - Interface in com.pushtechnology.diffusion.client.features
A constraint requiring the current value of a JSON topic to match the partially described value.
updateConstraints() - Method in interface com.pushtechnology.diffusion.client.Diffusion.Implementation
 
updateConstraints() - Static method in enum com.pushtechnology.diffusion.client.Diffusion
Returns an update constraint factory.
UpdateFailedException - Exception in com.pushtechnology.diffusion.client.features
Exception used to report a topic update failed.
UpdateFailedException(String) - Constructor for exception com.pushtechnology.diffusion.client.features.UpdateFailedException
Constructor.
updateStore(String) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.SecurityStoreFeature
Send a command script to the server to update the security store.
updateStore(String, SecurityStoreFeature.UpdateStoreCallback) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.SecurityStoreFeature
Send a command script to the server to update the security store.
updateStore(String, C, SecurityStoreFeature.UpdateStoreContextCallback<C>) - Method in interface com.pushtechnology.diffusion.client.features.control.clients.SecurityStoreFeature
Send a command script to the server to update the security store, with a contextual callback.
UpdateStream<T> - Interface in com.pushtechnology.diffusion.client.features
An update stream provides a method for updating a specific topic.

V

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
Creates a new RecordV2Builder.
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
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
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.

W

with(String, Class<V>, V) - Method in interface com.pushtechnology.diffusion.client.features.UpdateConstraint.PartialJSON
Require a value at a specific position in the JSON object.
without(String) - Method in interface com.pushtechnology.diffusion.client.features.UpdateConstraint.PartialJSON
Require a specific position in the JSON object to be absent.
withoutProperties(String...) - Method in interface com.pushtechnology.diffusion.client.topics.details.TopicSpecification
Returns a new specification that does not have the specified properties.
withProperties() - Method in interface com.pushtechnology.diffusion.client.features.Topics.FetchRequest
Specifies that all properties associated with each topic's specification should be returned.
withProperties(Map<String, String>) - Method in interface com.pushtechnology.diffusion.client.topics.details.TopicSpecification
Creates a new specification with the specified properties.
withProperty(String, String) - Method in interface com.pushtechnology.diffusion.client.topics.details.TopicSpecification
Creates a new specification with the specified property value set.
withSchema(Schema) - Method in interface com.pushtechnology.diffusion.datatype.recordv2.RecordV2DataType
Bind a specific schema to a RecordV2DataType instance.
withUnpublishedDelayedTopics() - Method in interface com.pushtechnology.diffusion.client.features.Topics.FetchRequest
Include the details of reference topics that are not yet published.
withValue(T) - Method in interface com.pushtechnology.diffusion.client.features.TimeSeries.Event
Clone this event with a different value.
withValues(Class<? extends T>) - Method in interface com.pushtechnology.diffusion.client.features.Topics.FetchRequest
Specifies that values should be returned for selected topics, constraining the selection to only those topics with a data type compatible with the specified value class.
writeDelta(D, OutputStream) - Method in interface com.pushtechnology.diffusion.datatype.DeltaType
Serialize a delta to binary.
writeTimeout(int) - Method in interface com.pushtechnology.diffusion.client.session.SessionFactory
Sets the write timeout value for blocking writes.
writeValue(V, OutputStream) - Method in interface com.pushtechnology.diffusion.datatype.DataType
Serialize a value to binary.
A B C D E F G H I J K L M N O P R S T U V W 
Skip navigation links
DiffusionTM Android API 6.6.0-preview.1

Copyright © 2020 Push Technology Ltd. All Rights Reserved.