Uses of Class
io.fluxzero.sdk.common.serialization.DeserializingMessage

Packages that use DeserializingMessage

Package	Description
io.fluxzero.sdk.common.serialization
io.fluxzero.sdk.configuration
io.fluxzero.sdk.modeling
io.fluxzero.sdk.persisting.eventsourcing
io.fluxzero.sdk.publishing.correlation
io.fluxzero.sdk.publishing.dataprotection
io.fluxzero.sdk.scheduling
io.fluxzero.sdk.tracking
io.fluxzero.sdk.tracking.handling
io.fluxzero.sdk.tracking.handling.authentication
io.fluxzero.sdk.tracking.handling.contentfiltering
io.fluxzero.sdk.tracking.handling.errorreporting
io.fluxzero.sdk.tracking.handling.validation
io.fluxzero.sdk.tracking.metrics
io.fluxzero.sdk.web

Uses of DeserializingMessage in io.fluxzero.sdk.common.serialization

Subclasses with type arguments of type DeserializingMessage in io.fluxzero.sdk.common.serialization

Modifier and Type	Class	Description
protected static class	DeserializingMessage.MessageSpliterator

Subinterfaces with type arguments of type DeserializingMessage in io.fluxzero.sdk.common.serialization

Modifier and Type	Interface	Description
interface	MessageFormatter	A functional interface for formatting DeserializingMessage instances into human-readable strings.

Methods in io.fluxzero.sdk.common.serialization that return DeserializingMessage

Modifier and Type	Method	Description
default DeserializingMessage	Serializer.deserializeMessage(SerializedMessage message, MessageType messageType)	Deserializes a single SerializedMessage into a DeserializingMessage.
static DeserializingMessage	DeserializingMessage.getCurrent()	Returns the current DeserializingMessage being processed in this thread, or null if none is set.
DeserializingMessage	DeserializingMessage.withData(Data<byte[]> data)
DeserializingMessage	DeserializingMessage.withMetadata(Metadata metadata)
DeserializingMessage	DeserializingMessage.withPayload(Object payload)

Methods in io.fluxzero.sdk.common.serialization that return types with arguments of type DeserializingMessage

Modifier and Type	Method	Description
default Stream<DeserializingMessage>	Serializer.deserializeMessages(Stream<SerializedMessage> dataStream, MessageType messageType)	Deserializes a stream of SerializedMessage into DeserializingMessage instances with the specified MessageType.
default Stream<DeserializingMessage>	Serializer.deserializeMessages(Stream<SerializedMessage> dataStream, MessageType messageType, UnknownTypeStrategy unknownTypeStrategy)	Deserializes a stream of SerializedMessage into DeserializingMessage instances with the specified MessageType.
default Stream<DeserializingMessage>	Serializer.deserializeMessages(Stream<SerializedMessage> dataStream, MessageType messageType, String topic)	Deserializes a stream of SerializedMessage into DeserializingMessage instances with the specified MessageType.
default Stream<DeserializingMessage>	Serializer.deserializeMessages(Stream<SerializedMessage> dataStream, MessageType messageType, String topic, UnknownTypeStrategy unknownTypeStrategy)	Deserializes a stream of SerializedMessage into DeserializingMessage instances with the specified MessageType.
static Optional<DeserializingMessage>	DeserializingMessage.getOptionally()	Returns the current DeserializingMessage being processed in this thread, if available.
static Stream<DeserializingMessage>	DeserializingMessage.handleBatch(Stream<DeserializingMessage> batch)

Method parameters in io.fluxzero.sdk.common.serialization with type arguments of type DeserializingMessage

Modifier and Type	Method	Description
<T> T	DeserializingMessage.apply(Function<DeserializingMessage, T> action)
<T> T	DeserializingMessage.computeContextIfAbsent(Class<T> contextKey, Function<DeserializingMessage, ? extends T> provider)
static Stream<DeserializingMessage>	DeserializingMessage.handleBatch(Stream<DeserializingMessage> batch)
void	DeserializingMessage.run(Consumer<DeserializingMessage> task)
boolean	DeserializingMessage.MessageSpliterator.tryAdvance(Consumer<? super DeserializingMessage> action)

Constructors in io.fluxzero.sdk.common.serialization with parameters of type DeserializingMessage

Modifier	Constructor	Description
protected	DeserializingMessage(@NonNull DeserializingMessage input)

Constructor parameters in io.fluxzero.sdk.common.serialization with type arguments of type DeserializingMessage

Modifier	Constructor	Description
	MessageSpliterator(Spliterator<DeserializingMessage> upStream)

Uses of DeserializingMessage in io.fluxzero.sdk.configuration

Methods in io.fluxzero.sdk.configuration that return types with arguments of type DeserializingMessage

Modifier and Type	Method	Description
List<ParameterResolver<? super DeserializingMessage>>	FluxzeroConfiguration.customParameterResolvers()	Returns additional resolvers for injecting parameters into message handler methods.

Method parameters in io.fluxzero.sdk.configuration with type arguments of type DeserializingMessage

Modifier and Type	Method	Description
DefaultFluxzero.Builder	DefaultFluxzero.Builder.addParameterResolver(@NonNull ParameterResolver<? super DeserializingMessage> parameterResolver)
FluxzeroBuilder	FluxzeroBuilder.addParameterResolver(ParameterResolver<? super DeserializingMessage> parameterResolver)	Registers a ParameterResolver to support injection of method arguments in handlers.
protected GenericGateway	DefaultFluxzero.Builder.createRequestGateway(Client client, MessageType messageType, String topic, RequestHandler requestHandler, Map<MessageType, DispatchInterceptor> dispatchInterceptors, Map<MessageType, HandlerDecorator> handlerDecorators, List<ParameterResolver<? super DeserializingMessage>> parameterResolvers, Function<Class<?>, HandlerRepository> handlerRepositorySupplier, RepositoryProvider repositoryProvider, ResponseMapper responseMapper)
protected HandlerRegistry	DefaultFluxzero.Builder.localHandlerRegistry(MessageType messageType, Map<MessageType, HandlerDecorator> handlerDecorators, List<ParameterResolver<? super DeserializingMessage>> parameterResolvers, Map<MessageType, DispatchInterceptor> dispatchInterceptors, Function<Class<?>, HandlerRepository> handlerRepositorySupplier, RepositoryProvider repositoryProvider)

Uses of DeserializingMessage in io.fluxzero.sdk.modeling

Subclasses of DeserializingMessage in io.fluxzero.sdk.modeling

Modifier and Type	Class	Description
protected static class	DefaultEntityHelper.DeserializingMessageWithEntity	Decorates a DeserializingMessage with an associated entity.

Methods in io.fluxzero.sdk.modeling with parameters of type DeserializingMessage

Modifier and Type	Method	Description
default Entity<T>	Entity.apply(DeserializingMessage eventMessage)	Applies the given deserializing message to the entity.
Entity<T>	ImmutableAggregateRoot.apply(DeserializingMessage message)
Entity<T>	ImmutableEntity.apply(DeserializingMessage message)
Optional<HandlerInvoker>	DefaultEntityHelper.applyInvoker(DeserializingMessage event, Entity<?> entity, boolean searchChildren)	Finds a handler method annotated with @Apply and wraps it to preserve apply context flags.
default Optional<HandlerInvoker>	EntityHelper.applyInvoker(DeserializingMessage message, Entity<?> entity)	Returns an invoker that can apply the given event to the provided entity.
Optional<HandlerInvoker>	EntityHelper.applyInvoker(DeserializingMessage message, Entity<?> entity, boolean searchChildren)	Returns an invoker for applying the event to the entity, optionally checking nested entities.

Constructors in io.fluxzero.sdk.modeling with parameters of type DeserializingMessage

Modifier	Constructor	Description
	DeserializingMessageWithEntity(DeserializingMessage message, Entity<?> entity)

Constructor parameters in io.fluxzero.sdk.modeling with type arguments of type DeserializingMessage

Modifier	Constructor	Description
	DefaultEntityHelper(List<ParameterResolver<? super DeserializingMessage>> parameterResolvers, boolean disablePayloadValidation)	Creates a new helper using the given parameter resolvers and configuration.

Uses of DeserializingMessage in io.fluxzero.sdk.persisting.eventsourcing

Methods in io.fluxzero.sdk.persisting.eventsourcing that return types with arguments of type DeserializingMessage

Modifier and Type	Method	Description
AggregateEventStream<DeserializingMessage>	DefaultEventStore.getEvents(Object aggregateId, long lastSequenceNumber, int maxSize, boolean ignoreUnknownType)
default AggregateEventStream<DeserializingMessage>	EventStore.getEvents(Object aggregateId)	Retrieves the full event stream for an aggregate starting from the beginning.
default AggregateEventStream<DeserializingMessage>	EventStore.getEvents(Object aggregateId, long lastSequenceNumber)	Retrieves the event stream for an aggregate starting after the specified sequence number.
default AggregateEventStream<DeserializingMessage>	EventStore.getEvents(Object aggregateId, long lastSequenceNumber, int maxSize)	Retrieves the event stream for an aggregate starting after a given sequence number, with a maximum limit.
AggregateEventStream<DeserializingMessage>	EventStore.getEvents(Object aggregateId, long lastSequenceNumber, int maxSize, boolean ignoreUnknownType)	Retrieves the event stream for an aggregate with full control over behavior.

Uses of DeserializingMessage in io.fluxzero.sdk.publishing.correlation

Methods in io.fluxzero.sdk.publishing.correlation with parameters of type DeserializingMessage

Modifier and Type	Method	Description
default Map<String,String>	CorrelationDataProvider.getCorrelationData(DeserializingMessage currentMessage)	Returns correlation metadata derived from the current deserializing message.

Uses of DeserializingMessage in io.fluxzero.sdk.publishing.dataprotection

Methods in io.fluxzero.sdk.publishing.dataprotection that return types with arguments of type DeserializingMessage

Modifier and Type	Method	Description
Function<DeserializingMessage, Object>	DataProtectionInterceptor.interceptHandling(Function<DeserializingMessage, Object> function, HandlerInvoker invoker)

Method parameters in io.fluxzero.sdk.publishing.dataprotection with type arguments of type DeserializingMessage

Modifier and Type	Method	Description
Function<DeserializingMessage, Object>	DataProtectionInterceptor.interceptHandling(Function<DeserializingMessage, Object> function, HandlerInvoker invoker)

Uses of DeserializingMessage in io.fluxzero.sdk.scheduling

Methods in io.fluxzero.sdk.scheduling that return types with arguments of type DeserializingMessage

Modifier and Type	Method	Description
Function<DeserializingMessage, Object>	SchedulingInterceptor.interceptHandling(Function<DeserializingMessage, Object> function, HandlerInvoker invoker)
Handler<DeserializingMessage>	SchedulingInterceptor.wrap(Handler<DeserializingMessage> handler)

Methods in io.fluxzero.sdk.scheduling with parameters of type DeserializingMessage

Modifier and Type	Method	Description
protected Object	SchedulingInterceptor.handleExceptionalResult(Throwable result, DeserializingMessage schedule, Instant now, Periodic periodic)
protected Object	SchedulingInterceptor.handleResult(Object result, DeserializingMessage schedule, Instant now, Periodic periodic)

Method parameters in io.fluxzero.sdk.scheduling with type arguments of type DeserializingMessage

Modifier and Type	Method	Description
Function<DeserializingMessage, Object>	SchedulingInterceptor.interceptHandling(Function<DeserializingMessage, Object> function, HandlerInvoker invoker)
Handler<DeserializingMessage>	SchedulingInterceptor.wrap(Handler<DeserializingMessage> handler)

Uses of DeserializingMessage in io.fluxzero.sdk.tracking

Methods in io.fluxzero.sdk.tracking with parameters of type DeserializingMessage

Modifier and Type	Method	Description
boolean	Tracker.canHandle(DeserializingMessage message, String routingKey)	When the consumer is configured with ignoreSegment=true, segment filtering is performed client-side.
protected Optional<HandlerInvoker>	DefaultTracking.getInvoker(DeserializingMessage message, Handler<DeserializingMessage> handler, ConsumerConfiguration config)
protected Object	DefaultTracking.handle(DeserializingMessage message, HandlerInvoker h, Handler<DeserializingMessage> handler, ConsumerConfiguration config)
protected Object	DefaultTracking.processError(Throwable e, DeserializingMessage message, HandlerInvoker h, Handler<DeserializingMessage> handler, ConsumerConfiguration config)
protected void	DefaultTracking.reportResult(Object result, HandlerInvoker h, DeserializingMessage message, ConsumerConfiguration config)
protected boolean	DefaultTracking.shouldSendResponse(HandlerInvoker invoker, DeserializingMessage request, Object result, ConsumerConfiguration config)
protected void	DefaultTracking.stopTracker(DeserializingMessage message, Handler<DeserializingMessage> handler, Throwable e)
protected void	DefaultTracking.tryHandle(DeserializingMessage message, Handler<DeserializingMessage> handler, ConsumerConfiguration config, boolean reportResult)

Method parameters in io.fluxzero.sdk.tracking with type arguments of type DeserializingMessage

Modifier and Type	Method	Description
protected Consumer<List<SerializedMessage>>	DefaultTracking.createConsumer(ConsumerConfiguration config, List<Handler<DeserializingMessage>> handlers)
protected Optional<HandlerInvoker>	DefaultTracking.getInvoker(DeserializingMessage message, Handler<DeserializingMessage> handler, ConsumerConfiguration config)
protected Object	DefaultTracking.handle(DeserializingMessage message, HandlerInvoker h, Handler<DeserializingMessage> handler, ConsumerConfiguration config)
protected Object	DefaultTracking.processError(Throwable e, DeserializingMessage message, HandlerInvoker h, Handler<DeserializingMessage> handler, ConsumerConfiguration config)
protected Registration	DefaultTracking.startTracking(ConsumerConfiguration configuration, List<Handler<DeserializingMessage>> handlers, Fluxzero fluxzero)
protected void	DefaultTracking.stopTracker(DeserializingMessage message, Handler<DeserializingMessage> handler, Throwable e)
protected void	DefaultTracking.tryHandle(DeserializingMessage message, Handler<DeserializingMessage> handler, ConsumerConfiguration config, boolean reportResult)

Uses of DeserializingMessage in io.fluxzero.sdk.tracking.handling

Classes in io.fluxzero.sdk.tracking.handling that implement interfaces with type arguments of type DeserializingMessage

Modifier and Type	Class	Description
protected class	DocumentHandlerDecorator.DocumentHandler
class	HandleCustomFilter	A MessageFilter implementation that filters DeserializingMessage instances based on a custom topic defined in the HandleCustom annotation on handler methods.
class	HandleDocumentFilter	A MessageFilter that routes DeserializingMessage instances to methods annotated with HandleDocument, based on the message's topic.
static class	HandlerInterceptor.InterceptedHandler	Implementation of Handler that delegates to another handler and applies a HandlerInterceptor.
class	JsonPayloadParameterResolver	A ParameterResolver that converts the message payload to the parameter's declared type if that type is assignable to JsonNode.
class	StatefulHandler	A Handler implementation for classes annotated with Stateful, responsible for resolving and invoking stateful handler instances based on Association metadata.

Methods in io.fluxzero.sdk.tracking.handling that return types with arguments of type DeserializingMessage

Modifier and Type	Method	Description
protected Handler<DeserializingMessage>	DefaultHandlerFactory.buildHandler(@NonNull Object target, HandlerConfiguration<DeserializingMessage> config)
protected MessageFilter<? super DeserializingMessage>	DefaultHandlerFactory.computeMessageFilter()
protected Handler<DeserializingMessage>	DefaultHandlerFactory.createDefaultHandler(Object target, Function<DeserializingMessage, ?> targetSupplier, HandlerConfiguration<DeserializingMessage> config)
Optional<Handler<DeserializingMessage>>	DefaultHandlerFactory.createHandler(Object target, HandlerFilter handlerFilter, List<HandlerInterceptor> extraInterceptors)
Optional<Handler<DeserializingMessage>>	HandlerFactory.createHandler(Object target, HandlerFilter handlerFilter, List<HandlerInterceptor> extraInterceptors)	Attempts to create a message handler for the given target object.
protected HandlerMatcher<Object, DeserializingMessage>	DefaultHandlerFactory.createHandlerMatcher(Object target, HandlerConfiguration<DeserializingMessage> config)
protected List<Handler<DeserializingMessage>>	LocalHandlerRegistry.getLocalHandlers(DeserializingMessage message)	Returns the full list of handlers that should be used to process the given message.
protected Optional<DeserializingMessage>	TriggerParameterResolver.getTriggerMessage(long index, Class<?> type, MessageType messageType)
Function<DeserializingMessage, Object>	HandlerInterceptor.interceptHandling(Function<DeserializingMessage, Object> function, HandlerInvoker invoker)	Intercepts the message handling logic.
Function<DeserializingMessage, Object>	JsonPayloadParameterResolver.resolve(Parameter parameter, Annotation methodAnnotation)	Returns a function that converts the message payload to the expected parameter type using HasMessage.getPayloadAs(java.lang.reflect.Type).
Handler<DeserializingMessage>	DocumentHandlerDecorator.wrap(Handler<DeserializingMessage> handler)
Handler<DeserializingMessage>	HandlerDecorator.MergedDecorator.wrap(Handler<DeserializingMessage> handler)
Handler<DeserializingMessage>	HandlerDecorator.wrap(Handler<DeserializingMessage> handler)	Wraps the given handler with additional behavior.
default Handler<DeserializingMessage>	HandlerInterceptor.wrap(Handler<DeserializingMessage> handler)	Wraps a Handler with this interceptor, producing an intercepted handler.

Methods in io.fluxzero.sdk.tracking.handling with parameters of type DeserializingMessage

Modifier and Type	Method	Description
protected Map<Object,String>	StatefulHandler.associations(DeserializingMessage message)
protected Boolean	StatefulHandler.canTrackerHandle(DeserializingMessage message, String routingKey)
Optional<HandlerInvoker>	DocumentHandlerDecorator.DocumentHandler.getInvoker(DeserializingMessage message)
Optional<HandlerInvoker>	HandlerInterceptor.InterceptedHandler.getInvoker(DeserializingMessage message)
Optional<HandlerInvoker>	StatefulHandler.getInvoker(DeserializingMessage message)
protected List<Handler<DeserializingMessage>>	LocalHandlerRegistry.getLocalHandlers(DeserializingMessage message)	Returns the full list of handlers that should be used to process the given message.
Optional<CompletableFuture<Object>>	HandlerRegistry.handle(DeserializingMessage message)	Attempts to handle the given message using local handlers.
Optional<CompletableFuture<Object>>	HandlerRegistry.MergedHandlerRegistry.handle(DeserializingMessage message)
Optional<CompletableFuture<Object>>	HandlerRegistry.NoOpHandlerRegistry.handle(DeserializingMessage message)
Optional<CompletableFuture<Object>>	LocalHandlerRegistry.handle(DeserializingMessage message)
boolean	JsonPayloadParameterResolver.matches(Parameter parameter, Annotation methodAnnotation, DeserializingMessage value)	Determines whether this resolver matches the given parameter.
boolean	HandleCustomFilter.test(DeserializingMessage message, Executable executable, Class<? extends Annotation> handlerAnnotation)
boolean	HandleDocumentFilter.test(DeserializingMessage message, Executable executable, Class<? extends Annotation> handlerAnnotation)

Method parameters in io.fluxzero.sdk.tracking.handling with type arguments of type DeserializingMessage

Modifier and Type	Method	Description
protected Handler<DeserializingMessage>	DefaultHandlerFactory.buildHandler(@NonNull Object target, HandlerConfiguration<DeserializingMessage> config)
protected Handler<DeserializingMessage>	DefaultHandlerFactory.createDefaultHandler(Object target, Function<DeserializingMessage, ?> targetSupplier, HandlerConfiguration<DeserializingMessage> config)
protected Handler<DeserializingMessage>	DefaultHandlerFactory.createDefaultHandler(Object target, Function<DeserializingMessage, ?> targetSupplier, HandlerConfiguration<DeserializingMessage> config)
protected HandlerMatcher<Object, DeserializingMessage>	DefaultHandlerFactory.createHandlerMatcher(Object target, HandlerConfiguration<DeserializingMessage> config)
Function<DeserializingMessage, Object>	HandlerInterceptor.interceptHandling(Function<DeserializingMessage, Object> function, HandlerInvoker invoker)	Intercepts the message handling logic.
Handler<DeserializingMessage>	DocumentHandlerDecorator.wrap(Handler<DeserializingMessage> handler)
Handler<DeserializingMessage>	HandlerDecorator.MergedDecorator.wrap(Handler<DeserializingMessage> handler)
Handler<DeserializingMessage>	HandlerDecorator.wrap(Handler<DeserializingMessage> handler)	Wraps the given handler with additional behavior.
default Handler<DeserializingMessage>	HandlerInterceptor.wrap(Handler<DeserializingMessage> handler)	Wraps a Handler with this interceptor, producing an intercepted handler.

Constructors in io.fluxzero.sdk.tracking.handling with parameters of type DeserializingMessage

Modifier	Constructor	Description
	DocumentHandlerInvoker(HandlerInvoker delegate, String collection, DeserializingMessage message)
	StatefulHandlerInvoker(HandlerInvoker delegate, Entry<?> currentEntry, DeserializingMessage message)

Constructor parameters in io.fluxzero.sdk.tracking.handling with type arguments of type DeserializingMessage

Modifier	Constructor	Description
	DefaultHandlerFactory(MessageType messageType, HandlerDecorator defaultDecorator, List<ParameterResolver<? super DeserializingMessage>> parameterResolvers, Function<Class<?>, HandlerRepository> handlerRepositorySupplier, RepositoryProvider repositoryProvider)

Uses of DeserializingMessage in io.fluxzero.sdk.tracking.handling.authentication

Methods in io.fluxzero.sdk.tracking.handling.authentication that return types with arguments of type DeserializingMessage

Modifier and Type	Method	Description
Function<DeserializingMessage, Object>	AuthenticatingInterceptor.interceptHandling(Function<DeserializingMessage, Object> function, HandlerInvoker invoker)
Handler<DeserializingMessage>	AuthenticatingInterceptor.wrap(Handler<DeserializingMessage> handler)

Method parameters in io.fluxzero.sdk.tracking.handling.authentication with type arguments of type DeserializingMessage

Modifier and Type	Method	Description
Function<DeserializingMessage, Object>	AuthenticatingInterceptor.interceptHandling(Function<DeserializingMessage, Object> function, HandlerInvoker invoker)
Handler<DeserializingMessage>	AuthenticatingInterceptor.wrap(Handler<DeserializingMessage> handler)

Uses of DeserializingMessage in io.fluxzero.sdk.tracking.handling.contentfiltering

Methods in io.fluxzero.sdk.tracking.handling.contentfiltering that return types with arguments of type DeserializingMessage

Modifier and Type	Method	Description
Function<DeserializingMessage, Object>	ContentFilterInterceptor.interceptHandling(Function<DeserializingMessage, Object> function, HandlerInvoker invoker)

Method parameters in io.fluxzero.sdk.tracking.handling.contentfiltering with type arguments of type DeserializingMessage

Modifier and Type	Method	Description
Function<DeserializingMessage, Object>	ContentFilterInterceptor.interceptHandling(Function<DeserializingMessage, Object> function, HandlerInvoker invoker)

Uses of DeserializingMessage in io.fluxzero.sdk.tracking.handling.errorreporting

Methods in io.fluxzero.sdk.tracking.handling.errorreporting that return types with arguments of type DeserializingMessage

Modifier and Type	Method	Description
Function<DeserializingMessage, Object>	ErrorReportingInterceptor.interceptHandling(Function<DeserializingMessage, Object> function, HandlerInvoker invoker)

Methods in io.fluxzero.sdk.tracking.handling.errorreporting with parameters of type DeserializingMessage

Modifier and Type	Method	Description
protected void	ErrorReportingInterceptor.reportError(Throwable e, HandlerInvoker invoker, DeserializingMessage cause)

Method parameters in io.fluxzero.sdk.tracking.handling.errorreporting with type arguments of type DeserializingMessage

Modifier and Type	Method	Description
Function<DeserializingMessage, Object>	ErrorReportingInterceptor.interceptHandling(Function<DeserializingMessage, Object> function, HandlerInvoker invoker)

Uses of DeserializingMessage in io.fluxzero.sdk.tracking.handling.validation

Methods in io.fluxzero.sdk.tracking.handling.validation that return types with arguments of type DeserializingMessage

Modifier and Type	Method	Description
Function<DeserializingMessage, Object>	ValidatingInterceptor.interceptHandling(Function<DeserializingMessage, Object> function, HandlerInvoker invoker)

Method parameters in io.fluxzero.sdk.tracking.handling.validation with type arguments of type DeserializingMessage

Modifier and Type	Method	Description
Function<DeserializingMessage, Object>	ValidatingInterceptor.interceptHandling(Function<DeserializingMessage, Object> function, HandlerInvoker invoker)

Uses of DeserializingMessage in io.fluxzero.sdk.tracking.metrics

Methods in io.fluxzero.sdk.tracking.metrics that return types with arguments of type DeserializingMessage

Modifier and Type	Method	Description
Function<DeserializingMessage, Object>	DisableMetrics.interceptHandling(Function<DeserializingMessage, Object> function, HandlerInvoker invoker)
Function<DeserializingMessage, Object>	HandlerMonitor.interceptHandling(Function<DeserializingMessage, Object> function, HandlerInvoker invoker)

Methods in io.fluxzero.sdk.tracking.metrics with parameters of type DeserializingMessage

Modifier and Type	Method	Description
protected String	HandlerMonitor.formatType(DeserializingMessage message, HandlerInvoker invoker)
protected void	HandlerMonitor.publishMetrics(HandlerInvoker invoker, DeserializingMessage message, boolean exceptionalResult, Instant start, Object result)

Method parameters in io.fluxzero.sdk.tracking.metrics with type arguments of type DeserializingMessage

Modifier and Type	Method	Description
Function<DeserializingMessage, Object>	DisableMetrics.interceptHandling(Function<DeserializingMessage, Object> function, HandlerInvoker invoker)
Function<DeserializingMessage, Object>	HandlerMonitor.interceptHandling(Function<DeserializingMessage, Object> function, HandlerInvoker invoker)

Uses of DeserializingMessage in io.fluxzero.sdk.web

Classes in io.fluxzero.sdk.web that implement interfaces with type arguments of type DeserializingMessage

Modifier and Type	Class	Description
class	SocketEndpointHandler	A specialized Handler that manages lifecycle events and message dispatching for WebSocket endpoints annotated with SocketEndpoint.
class	WebHandlerMatcher	Specialized HandlerMatcher that routes DeserializingMessages of type MessageType.WEBREQUEST to matching handler methods based on annotated URI patterns, HTTP methods, and optional origins.

Methods in io.fluxzero.sdk.web that return types with arguments of type DeserializingMessage

Modifier and Type	Method	Description
protected Handler<DeserializingMessage>	WebsocketHandlerDecorator.cleanUpOnClose(Handler<DeserializingMessage> handler)
protected Handler<DeserializingMessage>	WebsocketHandlerDecorator.closeOnError(Handler<DeserializingMessage> handler)
protected Handler<DeserializingMessage>	WebsocketHandlerDecorator.enableHandshake(Handler<DeserializingMessage> handler, List<WebPattern> socketPatterns)
protected Handler<DeserializingMessage>	WebsocketHandlerDecorator.handleRequest(Handler<DeserializingMessage> handler)
protected Optional<HandlerInspector.MethodHandlerMatcher<DeserializingMessage>>	WebHandlerMatcher.methodMatcher(DeserializingMessage message)
Handler<DeserializingMessage>	WebsocketHandlerDecorator.wrap(Handler<DeserializingMessage> handler)	Wraps a websocket-compatible handler with websocket-specific functionality.

Methods in io.fluxzero.sdk.web with parameters of type DeserializingMessage

Modifier and Type	Method	Description
boolean	WebHandlerMatcher.canHandle(DeserializingMessage message)
Optional<HandlerInvoker>	SocketEndpointHandler.getInvoker(DeserializingMessage message)
Optional<HandlerInvoker>	WebHandlerMatcher.getInvoker(Object target, DeserializingMessage message)
static DefaultWebRequestContext	DefaultWebRequestContext.getWebRequestContext(DeserializingMessage message)	Creates or retrieves a DefaultWebRequestContext from the given DeserializingMessage.
Stream<Executable>	WebHandlerMatcher.matchingMethods(DeserializingMessage message)
protected Optional<HandlerInspector.MethodHandlerMatcher<DeserializingMessage>>	WebHandlerMatcher.methodMatcher(DeserializingMessage message)
protected void	SocketEndpointHandler.SocketEndpointWrapper.onClose(DeserializingMessage message)
protected Object	SocketEndpointHandler.SocketEndpointWrapper.onOpenOrMessage(SocketSession session, DeserializingMessage message)
protected void	SocketEndpointHandler.SocketEndpointWrapper.onPong(DeserializingMessage message)
Optional<HandlerInvoker>	DefaultSocketSession.tryCompleteRequest(DeserializingMessage message)
Optional<HandlerInvoker>	DefaultSocketSession.tryHandleRequest(DeserializingMessage message, Handler<DeserializingMessage> handler)

Method parameters in io.fluxzero.sdk.web with type arguments of type DeserializingMessage

Modifier and Type	Method	Description
protected Handler<DeserializingMessage>	WebsocketHandlerDecorator.cleanUpOnClose(Handler<DeserializingMessage> handler)
protected Handler<DeserializingMessage>	WebsocketHandlerDecorator.closeOnError(Handler<DeserializingMessage> handler)
protected static WebHandlerMatcher	WebHandlerMatcher.create(Object handler, Class<?> type, List<ParameterResolver<? super DeserializingMessage>> parameterResolvers, HandlerConfiguration<DeserializingMessage> config)
protected static WebHandlerMatcher	WebHandlerMatcher.create(Object handler, Class<?> type, List<ParameterResolver<? super DeserializingMessage>> parameterResolvers, HandlerConfiguration<DeserializingMessage> config)
static WebHandlerMatcher	WebHandlerMatcher.create(Object handler, List<ParameterResolver<? super DeserializingMessage>> parameterResolvers, HandlerConfiguration<DeserializingMessage> config)
static WebHandlerMatcher	WebHandlerMatcher.create(Object handler, List<ParameterResolver<? super DeserializingMessage>> parameterResolvers, HandlerConfiguration<DeserializingMessage> config)
protected Handler<DeserializingMessage>	WebsocketHandlerDecorator.enableHandshake(Handler<DeserializingMessage> handler, List<WebPattern> socketPatterns)
protected Handler<DeserializingMessage>	WebsocketHandlerDecorator.handleRequest(Handler<DeserializingMessage> handler)
Optional<HandlerInvoker>	DefaultSocketSession.tryHandleRequest(DeserializingMessage message, Handler<DeserializingMessage> handler)
Handler<DeserializingMessage>	WebsocketHandlerDecorator.wrap(Handler<DeserializingMessage> handler)	Wraps a websocket-compatible handler with websocket-specific functionality.

Constructor parameters in io.fluxzero.sdk.web with type arguments of type DeserializingMessage

Modifier	Constructor	Description
	SocketEndpointHandler(Class<?> targetClass, HandlerMatcher<Object, DeserializingMessage> targetMatcher, HandlerMatcher<Object, DeserializingMessage> wrapperMatcher, RepositoryProvider repositoryProvider)
protected	WebHandlerMatcher(Object handler, List<HandlerInspector.MethodHandlerMatcher<DeserializingMessage>> methodHandlerMatchers)