All Classes and Interfaces
Class
Description
Helper to track active processes and close them on shutdown.
Configuration wrapper for application configuration
Base implementation for PersistentSubscriber that helps set up useful event filters.
ByteBuffer backed inputstream that supports mark/reset/skip.
Stream exception indicating that the client did something wrong, typically with configuration or authentication problems.
Stream exception indicating that the client is shutting down.
Stream exception indicating that the client did something wrong, typically with configuration or authentication problems.
Will interrupt waiting threads on close.
Configuration builder for the most common cases.
Configuration builder messages to be logged later by Xorcery
This processor checks configuration for the following for each service:
servicename.enabled = true/false (whether to load this service)
servicename.metadata = object with name/value pairs (additional service metadata, potentially overriding annotations)
Used to annotate commands that create entities
Default no-op Disruptor EventHandler
Configuration wrapper for standard defaults.
Used to annotate commands that delete entities
Lookup API to convert a URI with names (hostnames, SRV names, etc.) into a list of URIs with IPs, schemes and other information.
Use the Xorcery DNS lookup service to resolve names.
Function that takes two functions.
Processor that tracks the state of the stream with a CompletableFuture.
Configuration wrapper for instance configuration
Overrides destroy so that Jetty shutdown doesn't perform the servlet lifecycle call.
JMX RMI Connector manager
Marker interface with helper methods to denote a model that is backed by JSON.
Given a JSON tree, merge in another JSON tree into it and return the new tree.
Resolve variables in JSON values.
This is used by the reactive stream client to get access to local stream factories, i.e.
Marker interface for classes with Procedure and Function methods
Stream exception indicating that the client is not authorized.
Support for Optional values
Long-running process that normally involves I/O to other systems.
Note: this is set to run level 0 primarily so that client streams are the last to close when an application shuts down.
Resource loading helper.
Helper for handling Responses.
Lookup secrets from secret providers.
Returns the name itself as the secret
Stream exception indicating that the server is shutting down.
Stream exception indicating that the server did something wrong.
Stream exception indicating that the server shutdown due to timeout.
Collection of ServiceResourceObjects for this server.
Filter for when you don't want to process old events, and just want to skip everything up until a specified timestamp.
All exceptions reported to subscribers will be wrapped in a subclass of this exception.
This template loader uses the SystemClassLoader to allow loading of templates in a JPMS application, where the templates
may be in separate modules and access is governed by module restrictions.
Processor that converts items from one type to another using specified MessageWriter/MessageReader.
Used to annotate commands that are updates
UUIDs without the dashes.
This builder creates a function that makes it easier to add WHERE clauses to Cypher queries.
Builders can implement this to make it easy to use visitor pattern.
Xorcery run level values:
0: Configuration refresh
2: Certificate request/refresh
4: Server
6: Server publishers/subscribers
8: Client publishers/subscribers
18: Server start/stop
20: DNS registration/deregistration
JUnit Extension to create Xorcery instances.