Class WebsocketEndpoint

java.lang.Object

io.fluxzero.testserver.websocket.WebsocketEndpoint

Direct Known Subclasses:

ConsumerEndpoint, EventSourcingEndpoint, KeyValueEndPoint, ProducerEndpoint, SchedulingEndpoint, SearchEndpoint

public abstract class WebsocketEndpoint
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static class	WebsocketEndpoint.ClientMessage
protected static class	WebsocketEndpoint.PingRegistration
protected static class	WebsocketEndpoint.SessionBacklog

Field Summary

Fields

Modifier and Type	Field	Description
protected static Duration	pingDelay
protected static Duration	pingTimeout
protected boolean	shutDown
protected final AtomicBoolean	shuttingDown

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	WebsocketEndpoint()
protected	WebsocketEndpoint(CommandIdempotencyStore commandIdempotencyStore)
protected	WebsocketEndpoint(Executor requestExecutor)
protected	WebsocketEndpoint(Executor requestExecutor, CommandIdempotencyStore commandIdempotencyStore)

Method Summary

Modifier and Type	Method	Description
protected void	abort(ServerWebsocketSession session, String reason)
protected Stream<Runnable>	createTasks(io.fluxzero.common.api.RequestBatch<?> batch, ServerWebsocketSession session)
protected io.fluxzero.common.api.JsonType	deserializeRequest(ServerWebsocketSession session, byte[] bytes)
protected void	dispatchRequest(ServerWebsocketSession session, io.fluxzero.common.api.JsonType request)
protected void	doSendResult(ServerWebsocketSession session, io.fluxzero.common.api.RequestResult result)
protected Optional<WebsocketEndpoint.SessionBacklog>	findAlternativeBacklog(ServerWebsocketSession closedSession)
protected String	getClientId(ServerWebsocketSession session)
protected String	getClientName(ServerWebsocketSession session)
protected String	getClientSdkVersion(ServerWebsocketSession session)
protected io.fluxzero.common.serialization.compression.CompressionAlgorithm	getCompressionAlgorithm(ServerWebsocketSession session)
protected String	getNamespace(ServerWebsocketSession session)
protected String	getNegotiatedSessionId(ServerWebsocketSession session)
protected Map<String, List<String>>	getRequestHeaders(ServerWebsocketSession session)
protected String	getRuntimeVersion()
protected void	handleMessage(ServerWebsocketSession session, io.fluxzero.common.api.JsonType message)
void	onClose(ServerWebsocketSession session, io.fluxzero.sdk.common.websocket.WebsocketCloseReason closeReason)
void	onError(ServerWebsocketSession session, Throwable e)
void	onMessage(byte[] bytes, ServerWebsocketSession session)
void	onOpen(ServerWebsocketSession session)
void	onPong(ByteBuffer message, ServerWebsocketSession session)
protected void	registerMetrics(io.fluxzero.common.api.JsonType event, ServerWebsocketSession session)
protected WebsocketEndpoint.PingRegistration	schedulePing(ServerWebsocketSession session)
protected void	sendPing(ServerWebsocketSession session)
protected void	sendResultBatch(ServerWebsocketSession session, List<io.fluxzero.common.api.RequestResult> results)
protected io.fluxzero.common.api.Metadata	sessionMetadata(ServerWebsocketSession session)
protected boolean	shouldHandleIdempotently(io.fluxzero.common.api.Command command)
protected void	shutDown()	Close all sessions on the websocket after an optional delay.
protected boolean	submitRequestTask(ServerWebsocketSession session, io.fluxzero.common.api.JsonType request, Runnable task)

Methods inherited from class Object

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

Field Details

pingTimeout

protected static Duration pingTimeout

pingDelay

protected static Duration pingDelay

shuttingDown

protected final AtomicBoolean shuttingDown

shutDown

protected volatile boolean shutDown

Constructor Details

WebsocketEndpoint

protected WebsocketEndpoint()

WebsocketEndpoint

protected WebsocketEndpoint(CommandIdempotencyStore commandIdempotencyStore)

WebsocketEndpoint

protected WebsocketEndpoint(Executor requestExecutor)

WebsocketEndpoint

protected WebsocketEndpoint(Executor requestExecutor,
 CommandIdempotencyStore commandIdempotencyStore)

Method Details

onOpen

public void onOpen(ServerWebsocketSession session)

deserializeRequest

protected io.fluxzero.common.api.JsonType deserializeRequest(ServerWebsocketSession session,
 byte[] bytes)

onMessage

public void onMessage(byte[] bytes,
 ServerWebsocketSession session)

dispatchRequest

protected void dispatchRequest(ServerWebsocketSession session,
 io.fluxzero.common.api.JsonType request)

shouldHandleIdempotently

protected boolean shouldHandleIdempotently(io.fluxzero.common.api.Command command)

submitRequestTask

protected boolean submitRequestTask(ServerWebsocketSession session,
 io.fluxzero.common.api.JsonType request,
 Runnable task)

handleMessage

protected void handleMessage(ServerWebsocketSession session,
 io.fluxzero.common.api.JsonType message)

doSendResult

protected void doSendResult(ServerWebsocketSession session,
 io.fluxzero.common.api.RequestResult result)

createTasks

protected Stream<Runnable> createTasks(io.fluxzero.common.api.RequestBatch<?> batch,
 ServerWebsocketSession session)

sendResultBatch

protected void sendResultBatch(ServerWebsocketSession session,
 List<io.fluxzero.common.api.RequestResult> results)

findAlternativeBacklog

protected Optional<WebsocketEndpoint.SessionBacklog> findAlternativeBacklog(ServerWebsocketSession closedSession)

schedulePing

protected WebsocketEndpoint.PingRegistration schedulePing(ServerWebsocketSession session)

sendPing

protected void sendPing(ServerWebsocketSession session)

onPong

public void onPong(ByteBuffer message,
 ServerWebsocketSession session)

abort

protected void abort(ServerWebsocketSession session,
 String reason)

onClose

public void onClose(ServerWebsocketSession session,
 io.fluxzero.sdk.common.websocket.WebsocketCloseReason closeReason)

onError

public void onError(ServerWebsocketSession session,
 Throwable e)

shutDown

protected void shutDown()

Close all sessions on the websocket after an optional delay. During the delay we don't handle new requests but will be able to send back results.

getCompressionAlgorithm

protected io.fluxzero.common.serialization.compression.CompressionAlgorithm getCompressionAlgorithm(ServerWebsocketSession session)

getRequestHeaders

protected Map<String, List<String>> getRequestHeaders(ServerWebsocketSession session)

getNamespace

protected String getNamespace(ServerWebsocketSession session)

getClientId

protected String getClientId(ServerWebsocketSession session)

getClientName

protected String getClientName(ServerWebsocketSession session)

getClientSdkVersion

protected String getClientSdkVersion(ServerWebsocketSession session)

getRuntimeVersion

protected String getRuntimeVersion()

getNegotiatedSessionId

protected String getNegotiatedSessionId(ServerWebsocketSession session)

registerMetrics

protected void registerMetrics(io.fluxzero.common.api.JsonType event,
 ServerWebsocketSession session)

sessionMetadata

protected io.fluxzero.common.api.Metadata sessionMetadata(ServerWebsocketSession session)