Package io.fluxcapacitor.javaclient.web

Class SocketEndpointHandler.SocketEndpointWrapper

java.lang.Object

io.fluxcapacitor.javaclient.web.SocketEndpointHandler.SocketEndpointWrapper

Enclosing class:

SocketEndpointHandler

@Path("*")
public static class SocketEndpointHandler.SocketEndpointWrapper
extends Object

A stateful wrapper around a WebSocket endpoint instance, managing per-session behavior and message handling.

This class is created per WebSocket session and holds:

• A lazily instantiated target handler
• Connection health tracking (ping/pong logic)
• Automatic session cleanup via Registration hooks
• Delegation to matching methods for open, message, pong, and close events

When the first @HandleSocketOpen or @HandleSocketMessage message arrives for a session, the target handler is initialized and stored. Subsequent WebSocket lifecycle messages (e.g. @HandleSocketPong, @HandleSocketClose) are routed to the correct methods on the same instance.

Ping scheduling and timeout behavior is based on the SocketEndpoint.aliveCheck() configuration.

See Also:

• HandleSocketOpen
• HandleSocketMessage
• HandleSocketPong
• HandleSocketClose
• SocketEndpoint

Constructor Summary

Constructors

Constructor	Description
SocketEndpointWrapper()

Method Summary

Modifier and Type	Method	Description
protected void	abort(int closeCode)
protected boolean	isOpen()
protected void	onClose(DeserializingMessage message)
protected Object	onOpenOrMessage(SocketSession session, DeserializingMessage message)
protected void	onPong(DeserializingMessage message)
protected void	sendPing(Duration pingTimeout, TaskScheduler taskScheduler)
protected void	trySchedulePing()
protected Object	unwrap()

Methods inherited from class java.lang.Object

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

Constructor Details

SocketEndpointWrapper

public SocketEndpointWrapper()

Method Details

onOpenOrMessage

@HandleSocketOpen
@HandleSocketMessage
protected Object onOpenOrMessage(SocketSession session,
 DeserializingMessage message)

onPong

@HandleSocketPong
protected void onPong(DeserializingMessage message)

trySchedulePing

protected void trySchedulePing()

sendPing

protected void sendPing(Duration pingTimeout,
 TaskScheduler taskScheduler)

onClose

@HandleSocketClose
protected void onClose(DeserializingMessage message)

abort

protected void abort(int closeCode)

isOpen

protected boolean isOpen()

unwrap

protected Object unwrap()