Uses of Interface
io.fluxzero.common.Registration
Packages that use Registration
Package
Description
-
Uses of Registration in io.fluxzero.common
Methods in io.fluxzero.common that return RegistrationModifier and TypeMethodDescriptiondefault RegistrationRegistration.merge(Registration otherRegistration) Returns a newRegistrationthat cancels both this and the givenotherRegistration.static RegistrationRegistration.noOp()Returns a no-opRegistrationthat does nothing onRegistration.cancel().Backlog.registerMonitor(Consumer<List<T>> monitor) Adds a monitor to observe flushed batches.Monitored.registerMonitor(Consumer<T> monitor) Registers a monitor that will be notified when an activity of typeToccurs.InMemoryTaskScheduler.schedule(long deadline, ThrowingRunnable task) TaskScheduler.schedule(long deadline, ThrowingRunnable task) Schedules a task to be executed at the given epoch millisecond timestamp.default RegistrationTaskScheduler.schedule(Duration duration, ThrowingRunnable task) Schedules a task to be executed after a specified delay.default RegistrationTaskScheduler.schedule(Instant deadline, ThrowingRunnable task) Schedules a task to be executed at a specific timestamp.Methods in io.fluxzero.common with parameters of type RegistrationModifier and TypeMethodDescriptiondefault RegistrationRegistration.merge(Registration otherRegistration) Returns a newRegistrationthat cancels both this and the givenotherRegistration. -
Uses of Registration in io.fluxzero.proxy
Classes in io.fluxzero.proxy that implement RegistrationFields in io.fluxzero.proxy with type parameters of type RegistrationModifier and TypeFieldDescriptionprotected final Map<String, Registration> ForwardProxyConsumer.runningConsumersMethods in io.fluxzero.proxy that return RegistrationModifier and TypeMethodDescriptionProxySerializer.registerDowncasters(Object... casterCandidates) ProxySerializer.registerTypeCaster(String s, String s1) ProxySerializer.registerUpcasters(Object... casterCandidates) protected RegistrationForwardProxyConsumer.start()static Registration -
Uses of Registration in io.fluxzero.sdk
Methods in io.fluxzero.sdk that return RegistrationModifier and TypeMethodDescriptionFluxzero.beforeShutdown(Runnable task) Register a task to run before this Fluxzero instance is closed.default RegistrationFluxzero.registerHandlers(Object... handlers) Registers given handlers and initiates message tracking (i.e. listening for messages).default RegistrationFluxzero.registerHandlers(List<?> handlers) Registers given handlers and initiates message tracking. -
Uses of Registration in io.fluxzero.sdk.common.serialization
Methods in io.fluxzero.sdk.common.serialization that return RegistrationModifier and TypeMethodDescriptiondefault RegistrationSerializer.registerCasters(Object... casterCandidates) Registers upcasters and downcasters in one step.AbstractSerializer.registerDowncasters(Object... casterCandidates) Registers custom downcasters for transforming newer object states to older revisions.Serializer.registerDowncasters(Object... casterCandidates) Registers one or more downcaster candidates.AbstractSerializer.registerTypeCaster(String oldType, String newType) Registers a type mapping for upcasting old type names to new ones.Serializer.registerTypeCaster(String oldType, String newType) Registers a mapping from an old type identifier to a new one.AbstractSerializer.registerUpcasters(Object... casterCandidates) Registers custom upcasters for handling older serialized formats.Serializer.registerUpcasters(Object... casterCandidates) Registers one or more upcaster candidates. -
Uses of Registration in io.fluxzero.sdk.common.serialization.casting
Methods in io.fluxzero.sdk.common.serialization.casting that return RegistrationModifier and TypeMethodDescriptionCasterChain.registerCasterCandidates(Object... candidates) Registers one or more objects that may contain casting logic (e.g. annotated methods or implementations).DefaultCasterChain.registerCasterCandidates(Object... candidates) -
Uses of Registration in io.fluxzero.sdk.common.websocket
Classes in io.fluxzero.sdk.common.websocket that implement Registration -
Uses of Registration in io.fluxzero.sdk.configuration
Methods in io.fluxzero.sdk.configuration that return Registration -
Uses of Registration in io.fluxzero.sdk.configuration.client
Methods in io.fluxzero.sdk.configuration.client that return RegistrationModifier and TypeMethodDescriptionAbstractClient.beforeShutdown(Runnable task) Client.beforeShutdown(Runnable task) Registers a shutdown hook that will be called before this client shuts down.AbstractClient.monitorDispatch(ClientDispatchMonitor monitor, MessageType... messageTypes) Client.monitorDispatch(ClientDispatchMonitor monitor, MessageType... messageTypes) Registers aClientDispatchMonitorto receive hooks and diagnostics when messages of the givenMessageTypes are dispatched from this client. -
Uses of Registration in io.fluxzero.sdk.configuration.spring
Methods in io.fluxzero.sdk.configuration.spring that return RegistrationModifier and TypeMethodDescriptionSpringHandlerRegistry.registerHandlers(List<?> handlers) Registers the given list of handlers with the registry. -
Uses of Registration in io.fluxzero.sdk.persisting.caching
Methods in io.fluxzero.sdk.persisting.caching that return RegistrationModifier and TypeMethodDescriptionRegisters this logger as an eviction listener for the givenCache.Cache.registerEvictionListener(Consumer<CacheEviction> listener) Registers a listener to be notified whenever a cache entry is evicted or removed.DefaultCache.registerEvictionListener(Consumer<CacheEviction> listener) NamedCache.registerEvictionListener(Consumer<CacheEviction> listener) NoOpCache.registerEvictionListener(Consumer<CacheEviction> listener) SelectiveCache.registerEvictionListener(Consumer<CacheEviction> listener) -
Uses of Registration in io.fluxzero.sdk.persisting.search.client
Methods in io.fluxzero.sdk.persisting.search.client that return RegistrationModifier and TypeMethodDescriptionLocalDocumentHandlerRegistry.registerHandler(Object target, HandlerFilter handlerFilter) CollectionMessageStore.registerMonitor(Consumer<List<SerializedMessage>> monitor) InMemorySearchStore.registerMonitor(String collection, Consumer<List<SerializedMessage>> monitor) InMemorySearchStore.registerMonitor(BiConsumer<String, List<SerializedMessage>> monitor) -
Uses of Registration in io.fluxzero.sdk.publishing.client
Methods in io.fluxzero.sdk.publishing.client that return RegistrationModifier and TypeMethodDescriptionWebsocketGatewayClient.registerMonitor(Consumer<List<SerializedMessage>> monitor) -
Uses of Registration in io.fluxzero.sdk.tracking
Methods in io.fluxzero.sdk.tracking that return RegistrationModifier and TypeMethodDescriptionStarts tracking by assigning the given handlers to configured consumers and creating topic-specific or shared trackers.default RegistrationStarts the tracking process using the specified Fluxzero instance and the provided handlers.Starts tracking messages using the provided Fluxzero and a list of handlers.protected RegistrationDefaultTracking.startTracking(ConsumerConfiguration configuration, List<Handler<DeserializingMessage>> handlers, Fluxzero fluxzero) -
Uses of Registration in io.fluxzero.sdk.tracking.client
Classes in io.fluxzero.sdk.tracking.client that implement RegistrationModifier and TypeClassDescriptionclassA tracker keeps reading messages until it is stopped (generally only when the application is shut down).Methods in io.fluxzero.sdk.tracking.client that return RegistrationModifier and TypeMethodDescriptionInMemoryMessageStore.registerMonitor(Consumer<List<SerializedMessage>> monitor) LocalTrackingClient.registerMonitor(Consumer<List<SerializedMessage>> monitor) static RegistrationDefaultTracker.start(Consumer<List<SerializedMessage>> consumer, MessageType messageType, ConsumerConfiguration config, Client client) Starts one or more trackers.static RegistrationDefaultTracker.start(Consumer<List<SerializedMessage>> consumer, MessageType messageType, ConsumerConfiguration config, Fluxzero fluxzero) Starts one or more trackers.static RegistrationDefaultTracker.start(Consumer<List<SerializedMessage>> consumer, MessageType messageType, String topic, ConsumerConfiguration config, Client client) Starts one or more trackers.static RegistrationDefaultTracker.start(Consumer<List<SerializedMessage>> consumer, MessageType messageType, String topic, ConsumerConfiguration config, Fluxzero fluxzero) Starts one or more trackers.static RegistrationDefaultTracker.start(Consumer<List<SerializedMessage>> consumer, ConsumerConfiguration config, TrackingClient trackingClient) Starts one or more trackers that consume messages using the provided trackingClient and process them using the provided consumer. -
Uses of Registration in io.fluxzero.sdk.tracking.handling
Methods in io.fluxzero.sdk.tracking.handling that return RegistrationModifier and TypeMethodDescriptionHandlerRegistry.MergedHandlerRegistry.registerHandler(Object target) HandlerRegistry.MergedHandlerRegistry.registerHandler(Object target, HandlerFilter handlerFilter) HandlerRegistry.NoOpHandlerRegistry.registerHandler(Object target, HandlerFilter handlerFilter) default RegistrationHasLocalHandlers.registerHandler(Object target) Registers the given handler object and includes only the methods that are annotated with a recognized handler annotation (e.g.,@HandleCommand,@HandleQuery, etc.).HasLocalHandlers.registerHandler(Object target, HandlerFilter handlerFilter) Registers a handler object, including only those methods that match the providedHandlerFilter.LocalHandlerRegistry.registerHandler(Object target, HandlerFilter handlerFilter) static RegistrationInvocation.whenHandlerCompletes(BiConsumer<Object, Throwable> callback) Registers a callback to be executed when the current handler invocation completes.