Class SocketEndpointHandler

java.lang.Object

io.fluxzero.sdk.web.SocketEndpointHandler

All Implemented Interfaces:

Handler<DeserializingMessage>

public class SocketEndpointHandler
extends Object
implements Handler<DeserializingMessage>

A specialized Handler that manages lifecycle events and message dispatching for WebSocket endpoints annotated with SocketEndpoint.

This handler supports:

• Instantiating and caching per-session WebSocket handler instances
• Delegating to the correct handler method (e.g., @HandleSocketOpen, @HandleSocketMessage, @HandleSocketPong, @HandleSocketClose)
• Managing handler lifecycle via SocketEndpointHandler.SocketEndpointWrapper, including automatic cleanup and ping-based connection health checks

When a DeserializingMessage is received, the handler checks whether it represents a WebSocket request. If so, it resolves or initializes a SocketEndpointHandler.SocketEndpointWrapper associated with the given session ID and delegates message handling to the appropriate method. For non-WebSocket messages, the handler behaves like a typical Handler by invoking any matching method on the target class or on cached wrappers.

This class is primarily intended for internal use by the Fluxzero dispatcher infrastructure.

See Also:

• SocketEndpoint
• SocketSession
• Handler
• HandlerInvoker

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	SocketEndpointHandler.SocketEndpointWrapper	A stateful wrapper around a WebSocket endpoint instance, managing per-session behavior and message handling.

Nested classes/interfaces inherited from interface Handler

Handler.DelegatingHandler<M>

Constructor Summary

Constructors

Constructor	Description
SocketEndpointHandler(Class<?> targetClass, HandlerMatcher<Object, DeserializingMessage> targetMatcher, HandlerMatcher<Object, DeserializingMessage> wrapperMatcher, RepositoryProvider repositoryProvider)

Method Summary

Modifier and Type	Method	Description
Optional<HandlerInvoker>	getInvoker(DeserializingMessage message)	Returns a HandlerInvoker capable of processing the given message, if available.
String	toString()

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface Handler

getTargetClass, or

Constructor Details

SocketEndpointHandler

public SocketEndpointHandler(Class<?> targetClass,
 HandlerMatcher<Object, DeserializingMessage> targetMatcher,
 HandlerMatcher<Object, DeserializingMessage> wrapperMatcher,
 RepositoryProvider repositoryProvider)

Method Details

getInvoker

public Optional<HandlerInvoker> getInvoker(DeserializingMessage message)

Description copied from interface: Handler

Returns a HandlerInvoker capable of processing the given message, if available.

Specified by:

getInvoker in interface Handler<DeserializingMessage>

Parameters:

message - the message to be handled

Returns:

an optional HandlerInvoker if this handler can handle the message; otherwise Optional.empty()

toString

public String toString()

Overrides:

toString in class Object