Class WebsocketResponseInterceptor

java.lang.Object

io.fluxzero.sdk.web.WebsocketResponseInterceptor

All Implemented Interfaces:

DispatchInterceptor

public class WebsocketResponseInterceptor
extends Object
implements DispatchInterceptor

A DispatchInterceptor that modifies outgoing WebResponse messages in response to WebSocket-based WebRequests.

This interceptor ensures that appropriate metadata is included in the corresponding WebResponse. It supports both the WebSocket handshake phase and subsequent message exchanges over an established WebSocket session.

Specifically:

• If the incoming message is a WS_HANDSHAKE, it adds the clientId and trackerId to the response metadata to identify the connection.
• If the session is already open, it includes the sessionId and, if absent, sets a function field to either message or ack, depending on whether the outgoing message has a payload.

This ensures that the Fluxzero WebSocket infrastructure can properly route and interpret messages sent back to the client.

Field Summary

Fields inherited from interface DispatchInterceptor

noOp

Constructor Summary

Constructors

Constructor	Description
WebsocketResponseInterceptor()

Method Summary

Modifier and Type	Method	Description
Message	interceptDispatch(Message message, MessageType messageType, String topic)	Intercepts and conditionally modifies an outgoing message in the context of a WebSocket request.

Methods inherited from class Object

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

Methods inherited from interface DispatchInterceptor

andThen, modifySerializedMessage, monitorDispatch

Constructor Details

WebsocketResponseInterceptor

public WebsocketResponseInterceptor()

Method Details

interceptDispatch

public Message interceptDispatch(Message message,
 MessageType messageType,
 String topic)

Intercepts and conditionally modifies an outgoing message in the context of a WebSocket request.

Specified by:

interceptDispatch in interface DispatchInterceptor

Parameters:

message - the original message to be dispatched

messageType - the type of the message (e.g., WEBRESPONSE)

topic - the topic to which the message is being published

Returns:

the possibly modified message