NoSQLPublisher |
Object represents a NoSQLPublisher which publishes changes to the NoSQL
store on order, an implementation of Reactive Streams Publisher interface.
|
NoSQLPublisherConfig |
Configuration used to create an instance of NoSQLPublisher.
|
NoSQLPublisherConfig.Builder |
Builder to help construct a NoSQLPublisherConfig instance
|
NoSQLStreamMode |
Subscription stream mode used to configure the starting point for a NoSQL
subscription.
|
NoSQLSubscriberId |
Object to represent a subscriber id in a subscription group.
|
NoSQLSubscriptionConfig |
Configuration used by the NoSQL Publisher to create a subscription.
|
NoSQLSubscriptionConfig.Builder |
Builder to construct a NoSQLSubscriptionConfig instance
|
PublisherFailureException |
Exception that will be raised when NoSQL Publisher cannot be created due
to errors, or experiences irrecoverable errors and must be closed.
|
StreamOperation |
The operation (Put, Delete) that was delivered over the NoSQL stream.
|
StreamOperation.DeleteEvent |
Used to signal a Delete operation
|
StreamOperation.PutEvent |
Used to signal a Put operation
|
StreamOperation.SequenceId |
A SequenceId uniquely identifies a stream operation associated with a
Publisher.
|
StreamOperation.Type |
The type of the operation.
|
StreamPosition |
A StreamPosition represents a position in a subscription stream.
|
SubscriptionChangeNotAppliedException.Reason |
Describes the reason that a change was not applied.
|
SubscriptionFailureException |
Exception raised when a subscription fails.
|