Annotation Interface HandleDocument
This is a specialization of HandleMessage for MessageType.DOCUMENT messages. It allows consuming
updates from the document store in near real-time—similar to event tracking. Handlers can either specify a collection
name, a document class, or the materialized graph projection of an independent model.
Document Tracking Semantics
Each time a document is (re)indexed in Fluxzero, it receives a new tracking index. When a handler is subscribed
via @HandleDocument, it will receive the most recent version of the document for each index. If the tracker
is behind (e.g., during a replay), earlier versions of the same document may be skipped—only the latest version is
retained.
Transforming and Updating Documents
A powerful feature of document handlers is that they can return a modified version of the document to update it in-place. This allows document transformations and upcasting to be applied automatically and reliably.
For this behavior to take effect:
- The returned document must have a higher
Revisionthan the one stored - The updated version will be stored in the document collection under the same ID
This mechanism supports fully-automated data migrations: handlers can evolve or patch documents over time, and changes are persisted across application restarts.
- See Also:
-
Optional Element Summary
Optional ElementsModifier and TypeOptional ElementDescriptionbooleanIftrue, disables this handler during discovery.Class<?> Optional class of the documents to handle.Class<?> Optional independent-model root whose materialized graph projection should be handled.Determines how the handler responds when referenced protected data is no longer available.Optional name of the document collection.
-
Element Details
-
onMissingProtectedData
MissingProtectedDataPolicy onMissingProtectedDataDetermines how the handler responds when referenced protected data is no longer available.- Default:
DEFAULT
-
value
String valueOptional name of the document collection. If provided,documentClass()is ignored.If neither documentClass nor value are specified, the first parameter of the method is used to determine the collection:
class OrganisationHandler { @HandleDocument void on(Organisation organisation, Metadata metadata) { ... } }- See Also:
- Default:
""
-
documentClass
Class<?> documentClassOptional class of the documents to handle. If annotated withSearchable, the annotation defines the collection; otherwise the class name is used.If neither documentClass nor value are specified, the first parameter of the method is used to determine the collection:
class OrganisationHandler { @HandleDocument void on(Organisation organisation, Metadata metadata) { ... } }- See Also:
- Default:
java.lang.Void.class
-
modelGraph
Class<?> modelGraphOptional independent-model root whose materialized graph projection should be handled.The model must enable
Model.materializeGraph(). The effective collection is resolved fromModel.graphProjection(), including its derived Graph-collection default and any explicit collection override. A handler may injectGraph<RootModel>; node values are materialized lazily and parent, root, child and descendant navigation stays within the projected state boundary. This is useful when a stateful document handler needs to maintain a local view over complete model graphs rather than over independently stored root documents.When a materialized root graph is deleted, this handler receives a typed empty graph. The graph retains its identity, type and deletion boundary, while
previous()returns the complete last materialized graph. Deletion records are exclusive to handlers usingmodelGraph; ordinary document handlers for the same collection do not receive them.A non-passive handler may return the injected complete
Graph<RootModel>to persist ordinary serializer upcasting of its root and descendants into the materialized projection. Every node retains its own serialized type and revision and uses the ordinary@Upcastchain; there is no Graph-wide upcaster. An upcaster may return aData<T>envelope to evolve a node's type and content together without a separate typecaster. This is a projection-only migration: the graph must retain the handled root, state boundary, nodes and placements, and direct Models, relationships and projection progress are never changed. The Runtime replaces the document only if its original manifest is still current, so a delayed handler cannot overwrite a newer projection. Returning a Graph whose node schemas are already current is a no-op; tombstones remain observational.An explicit
value()takes precedence. Otherwise this attribute takes precedence overdocumentClass()and inference from the first handler parameter.- Default:
java.lang.Void.class
-
disabled
boolean disabledIftrue, disables this handler during discovery.- Default:
false
-