Uses of Interface
io.fluxzero.common.Registration

Packages that use Registration

Package	Description
io.fluxzero.common
io.fluxzero.proxy
io.fluxzero.sdk
io.fluxzero.sdk.common.serialization
io.fluxzero.sdk.common.serialization.casting
io.fluxzero.sdk.common.websocket
io.fluxzero.sdk.configuration
io.fluxzero.sdk.configuration.client
io.fluxzero.sdk.configuration.spring
io.fluxzero.sdk.persisting.caching
io.fluxzero.sdk.persisting.search.client
io.fluxzero.sdk.publishing.client
io.fluxzero.sdk.tracking
io.fluxzero.sdk.tracking.client
io.fluxzero.sdk.tracking.handling

Uses of Registration in io.fluxzero.common

Methods in io.fluxzero.common that return Registration

Modifier and Type	Method	Description
default Registration	Registration.merge(Registration otherRegistration)	Returns a new Registration that cancels both this and the given otherRegistration.
static Registration	Registration.noOp()	Returns a no-op Registration that does nothing on Registration.cancel().
Registration	Backlog.registerMonitor(Consumer<List<T>> monitor)	Adds a monitor to observe flushed batches.
Registration	Monitored.registerMonitor(Consumer<T> monitor)	Registers a monitor that will be notified when an activity of type T occurs.
Registration	InMemoryTaskScheduler.schedule(long deadline, ThrowingRunnable task)
Registration	TaskScheduler.schedule(long deadline, ThrowingRunnable task)	Schedules a task to be executed at the given epoch millisecond timestamp.
default Registration	TaskScheduler.schedule(Duration duration, ThrowingRunnable task)	Schedules a task to be executed after a specified delay.
default Registration	TaskScheduler.schedule(Instant deadline, ThrowingRunnable task)	Schedules a task to be executed at a specific timestamp.

Methods in io.fluxzero.common with parameters of type Registration

Modifier and Type	Method	Description
default Registration	Registration.merge(Registration otherRegistration)	Returns a new Registration that cancels both this and the given otherRegistration.

Uses of Registration in io.fluxzero.proxy

Classes in io.fluxzero.proxy that implement Registration

Modifier and Type	Class	Description
class	ProxyServer

Fields in io.fluxzero.proxy with type parameters of type Registration

Modifier and Type	Field	Description
protected final Map<String, Registration>	ForwardProxyConsumer.runningConsumers

Methods in io.fluxzero.proxy that return Registration

Modifier and Type	Method	Description
Registration	ProxySerializer.registerDowncasters(Object... casterCandidates)
Registration	ProxySerializer.registerTypeCaster(String s, String s1)
Registration	ProxySerializer.registerUpcasters(Object... casterCandidates)
protected Registration	ForwardProxyConsumer.start()
static Registration	ForwardProxyConsumer.start(Client client)

Uses of Registration in io.fluxzero.sdk

Methods in io.fluxzero.sdk that return Registration

Modifier and Type	Method	Description
Registration	Fluxzero.beforeShutdown(Runnable task)	Register a task to run before this Fluxzero instance is closed.
default Registration	Fluxzero.registerHandlers(Object... handlers)	Registers given handlers and initiates message tracking (i.e. listening for messages).
default Registration	Fluxzero.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 Registration

Modifier and Type	Method	Description
default Registration	Serializer.registerCasters(Object... casterCandidates)	Registers upcasters and downcasters in one step.
Registration	AbstractSerializer.registerDowncasters(Object... casterCandidates)	Registers custom downcasters for transforming newer object states to older revisions.
Registration	Serializer.registerDowncasters(Object... casterCandidates)	Registers one or more downcaster candidates.
Registration	AbstractSerializer.registerTypeCaster(String oldType, String newType)	Registers a type mapping for upcasting old type names to new ones.
Registration	Serializer.registerTypeCaster(String oldType, String newType)	Registers a mapping from an old type identifier to a new one.
Registration	AbstractSerializer.registerUpcasters(Object... casterCandidates)	Registers custom upcasters for handling older serialized formats.
Registration	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 Registration

Modifier and Type	Method	Description
Registration	CasterChain.registerCasterCandidates(Object... candidates)	Registers one or more objects that may contain casting logic (e.g. annotated methods or implementations).
Registration	DefaultCasterChain.registerCasterCandidates(Object... candidates)

Uses of Registration in io.fluxzero.sdk.common.websocket

Classes in io.fluxzero.sdk.common.websocket that implement Registration

Modifier and Type	Class	Description
protected static class	AbstractWebsocketClient.PingRegistration

Uses of Registration in io.fluxzero.sdk.configuration

Methods in io.fluxzero.sdk.configuration that return Registration

Modifier and Type	Method	Description
Registration	DefaultFluxzero.beforeShutdown(Runnable task)

Uses of Registration in io.fluxzero.sdk.configuration.client

Methods in io.fluxzero.sdk.configuration.client that return Registration

Modifier and Type	Method	Description
Registration	AbstractClient.beforeShutdown(Runnable task)
Registration	Client.beforeShutdown(Runnable task)	Registers a shutdown hook that will be called before this client shuts down.
Registration	AbstractClient.monitorDispatch(ClientDispatchMonitor monitor, MessageType... messageTypes)
Registration	Client.monitorDispatch(ClientDispatchMonitor monitor, MessageType... messageTypes)	Registers a ClientDispatchMonitor to receive hooks and diagnostics when messages of the given MessageTypes are dispatched from this client.

Uses of Registration in io.fluxzero.sdk.configuration.spring

Methods in io.fluxzero.sdk.configuration.spring that return Registration

Modifier and Type	Method	Description
Registration	SpringHandlerRegistry.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 Registration

Modifier and Type	Method	Description
Registration	CacheEvictionsLogger.register(Cache cache)	Registers this logger as an eviction listener for the given Cache.
Registration	Cache.registerEvictionListener(Consumer<CacheEviction> listener)	Registers a listener to be notified whenever a cache entry is evicted or removed.
Registration	DefaultCache.registerEvictionListener(Consumer<CacheEviction> listener)
Registration	NamedCache.registerEvictionListener(Consumer<CacheEviction> listener)
Registration	NoOpCache.registerEvictionListener(Consumer<CacheEviction> listener)
Registration	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 Registration

Modifier and Type	Method	Description
Registration	LocalDocumentHandlerRegistry.registerHandler(Object target, HandlerFilter handlerFilter)
Registration	CollectionMessageStore.registerMonitor(Consumer<List<SerializedMessage>> monitor)
Registration	InMemorySearchStore.registerMonitor(String collection, Consumer<List<SerializedMessage>> monitor)
Registration	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 Registration

Modifier and Type	Method	Description
Registration	WebsocketGatewayClient.registerMonitor(Consumer<List<SerializedMessage>> monitor)

Uses of Registration in io.fluxzero.sdk.tracking

Methods in io.fluxzero.sdk.tracking that return Registration

Modifier and Type	Method	Description
Registration	DefaultTracking.start(Fluxzero fluxzero, List<?> handlers)	Starts tracking by assigning the given handlers to configured consumers and creating topic-specific or shared trackers.
default Registration	Tracking.start(Fluxzero fluxzero, Object... handlers)	Starts the tracking process using the specified Fluxzero instance and the provided handlers.
Registration	Tracking.start(Fluxzero fluxzero, List<?> handlers)	Starts tracking messages using the provided Fluxzero and a list of handlers.
protected Registration	DefaultTracking.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 Registration

Modifier and Type	Class	Description
class	DefaultTracker	A 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 Registration

Modifier and Type	Method	Description
Registration	InMemoryMessageStore.registerMonitor(Consumer<List<SerializedMessage>> monitor)
Registration	LocalTrackingClient.registerMonitor(Consumer<List<SerializedMessage>> monitor)
static Registration	DefaultTracker.start(Consumer<List<SerializedMessage>> consumer, MessageType messageType, ConsumerConfiguration config, Client client)	Starts one or more trackers.
static Registration	DefaultTracker.start(Consumer<List<SerializedMessage>> consumer, MessageType messageType, ConsumerConfiguration config, Fluxzero fluxzero)	Starts one or more trackers.
static Registration	DefaultTracker.start(Consumer<List<SerializedMessage>> consumer, MessageType messageType, String topic, ConsumerConfiguration config, Client client)	Starts one or more trackers.
static Registration	DefaultTracker.start(Consumer<List<SerializedMessage>> consumer, MessageType messageType, String topic, ConsumerConfiguration config, Fluxzero fluxzero)	Starts one or more trackers.
static Registration	DefaultTracker.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 Registration

Modifier and Type	Method	Description
Registration	MutableHandler.onDelete(Runnable callback)
Registration	HandlerRegistry.MergedHandlerRegistry.registerHandler(Object target)
Registration	HandlerRegistry.MergedHandlerRegistry.registerHandler(Object target, HandlerFilter handlerFilter)
Registration	HandlerRegistry.NoOpHandlerRegistry.registerHandler(Object target, HandlerFilter handlerFilter)
default Registration	HasLocalHandlers.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.).
Registration	HasLocalHandlers.registerHandler(Object target, HandlerFilter handlerFilter)	Registers a handler object, including only those methods that match the provided HandlerFilter.
Registration	LocalHandlerRegistry.registerHandler(Object target, HandlerFilter handlerFilter)
static Registration	Invocation.whenHandlerCompletes(BiConsumer<Object, Throwable> callback)	Registers a callback to be executed when the current handler invocation completes.