All Classes and Interfaces

Class	Description
ApplicationStateSubscriptionListener	A simple SubscriptionListener implementation.
Codec	Provides support for custom serialization formats.
Codec.Decoder	Decodes custom messages for a given type.
Codec.Encoder	Encodes custom messages for a given type.
Codec.Encoder.Writer	Receives the encoded payload produced by Codec.Encoder.encode(Object, Writer).
Codec.Type	A tuple of schema id and template id, this is used to uniquely identify a type on the platform.
ConcurrencyMode	Defines how the session may be accessed by application code.
Counter	Counter metric created with session.monitoring().createCounter(name).
CustomMessage<T>	A message whose payload is serialized and deserialized by a user-provided Codec.
DtoMessage<T>	DTO message for publication.
EditListener	Requester-side callback for edit requests.
EditProcessor<T>	Responder-side callback for handling edit requests.
EditResult	Decision returned by an EditProcessor.
EditResult.Accepted	Reusable accepted result returned by EditResult.accept().
EditResult.Failed	Reusable failed result returned by EditResult.fail() and EditResult.fail(String).
FlexibleMessage<T>	Flexible message for Object, POJO, Map, etc. payloads.
Histogram	Histogram metric created with session.monitoring().createHistogram(name).
KeyHeader	Header containing platform metadata and topic identity.
KeyMessage<T>	Sequenced message received from the platform.
KeySession	KeySession connects an application to the platform and is used for routing, subscriptions, publication and monitoring.
KeySessionContext	Configuration used when creating a KeySession.
KeySessionEdit	Methods to submit edit requests for published data.
KeySessionEditRouting	Methods to register edit processors for different types of messages.
KeySessionExperimental	Experimental features - these are subject to change.
KeySessionFactory	Factory for creating KeySession instances.
KeySessionListener	Listener for session lifecycle, fallback message handling and session-level errors.
KeySessionMonitoring	Monitoring related methods for the session.
KeySessionRouting	Methods to register message processors for different types of messages.
LoggingSubscriptionListener	A simple SubscriptionListener implementation that logs onSuccess / onFailure notifications.
LoggingUnsubscriptionListener	A simple UnsubscriptionListener implementation that logs onSuccess / onFailure notifications.
MessageProcessor<T>	Callback for handling sequenced messages received from the platform.
Messages	Static factory for creating messages for publication.
MutableKeyHeader<T>
MutableKeyMessage<T,M>	Mutable message parent interface.
NanoClock	A clock that returns time as nanoseconds since the Unix epoch.
NanoClockFactory	Factory for creating NanoClock instances.
PostProcessor	Callback invoked periodically after a batch of messages has been processed.
RawMessage	Raw message for publishing raw bytes.
RawPayload	View over a raw payload buffer.
RecoveryActions	Actions available to a RecoveryPolicy during recovery.
RecoveryContext	Context provided to a RecoveryPolicy when a recovery event occurs.
RecoveryPolicy	Defines the policy for recovering application state after a disruption.
Result	Result returned by session operations.
SbeMessage<E,D>	SBE message for publication.
SimpleMessageProcessor<T>	Simple callback for handling sequenced messages received from the platform where only the payload of the message is needed.
SubscriptionListener	Callback for subscription request completion.
Topic	Immutable topic identity used for subscriptions and topic sets.
Topics	Class that provides factory methods to create Topic instances.
TopicSet	A TopicSet is a collection of topics.
TopicSetSubscriptionListener	Callback for topic set subscription completion.
UnsubscriptionListener	Callback for unsubscription request completion.