Interface StateDelegator
- All Known Implementing Classes:
GrpcStateService
public interface StateDelegator
The
StateDelegator
is able to delegate BeamFnApi.StateRequest
s to a set of registered
handlers. Any request for an unregistered process bundle instruction id is automatically failed.-
Nested Class Summary
Nested ClassesModifier and TypeInterfaceDescriptionstatic interface
Allows callers to deregister from receiving further state requests. -
Method Summary
Modifier and TypeMethodDescriptionregisterForProcessBundleInstructionId
(String processBundleInstructionId, StateRequestHandler handler) Registers the supplied handler for the given process bundle instruction id for allBeamFnApi.StateRequest
s with a matching id.
-
Method Details
-
registerForProcessBundleInstructionId
StateDelegator.Registration registerForProcessBundleInstructionId(String processBundleInstructionId, StateRequestHandler handler) Registers the supplied handler for the given process bundle instruction id for allBeamFnApi.StateRequest
s with a matching id. A handle is returned which allows one to deregister from thisStateDelegator
.
-