Package net.carcdr.yhocuspocus.websocket

Class WebSocketTransport

java.lang.Object

net.carcdr.yhocuspocus.websocket.WebSocketTransport

All Implemented Interfaces:

AutoCloseable, net.carcdr.yhocuspocus.transport.Transport

public class WebSocketTransport
extends Object
implements net.carcdr.yhocuspocus.transport.Transport

WebSocket transport implementation using Jetty WebSocket.

This class adapts a Jetty WebSocket Session to the Transport interface, allowing YHocuspocus to work with WebSocket connections.

Thread-safe implementation that handles:

• Binary message transmission
• Connection state tracking
• Graceful closure with WebSocket close codes
• Remote address extraction

Since:

1.0.0

Constructor Summary

Constructors

Constructor	Description
WebSocketTransport(org.eclipse.jetty.websocket.api.Session session)	Creates a new WebSocket transport from a Jetty session.

Method Summary

Modifier and Type	Method	Description
void	close(int code, String reason)
String	getConnectionId()
String	getRemoteAddress()
org.eclipse.jetty.websocket.api.Session	getSession()	Gets the underlying Jetty WebSocket session.
boolean	isOpen()
CompletableFuture<Void>	send(byte[] message)
void	setReceiveListener(net.carcdr.yhocuspocus.transport.ReceiveListener listener)

Methods inherited from class java.lang.Object

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

Methods inherited from interface net.carcdr.yhocuspocus.transport.Transport

close

Constructor Details

WebSocketTransport

public WebSocketTransport(org.eclipse.jetty.websocket.api.Session session)

Creates a new WebSocket transport from a Jetty session.

Parameters:

session - the WebSocket session (must not be null)

Throws:

IllegalArgumentException - if session is null

Method Details

send

public CompletableFuture<Void> send(byte[] message)

Specified by:

send in interface net.carcdr.yhocuspocus.transport.Transport

getConnectionId

public String getConnectionId()

Specified by:

getConnectionId in interface net.carcdr.yhocuspocus.transport.Transport

close

public void close(int code,
 String reason)

Specified by:

close in interface net.carcdr.yhocuspocus.transport.Transport

isOpen

public boolean isOpen()

Specified by:

isOpen in interface net.carcdr.yhocuspocus.transport.Transport

getRemoteAddress

public String getRemoteAddress()

Specified by:

getRemoteAddress in interface net.carcdr.yhocuspocus.transport.Transport

setReceiveListener

public void setReceiveListener(net.carcdr.yhocuspocus.transport.ReceiveListener listener)

Specified by:

setReceiveListener in interface net.carcdr.yhocuspocus.transport.Transport

getSession

public org.eclipse.jetty.websocket.api.Session getSession()

Gets the underlying Jetty WebSocket session.

Returns:

the WebSocket session