Class ConsumerEndpoint

java.lang.Object

io.fluxzero.testserver.websocket.WebsocketEndpoint

io.fluxzero.testserver.websocket.ConsumerEndpoint

public class ConsumerEndpoint
extends WebsocketEndpoint

Nested Class Summary

Nested classes/interfaces inherited from class WebsocketEndpoint

WebsocketEndpoint.ClientMessage, WebsocketEndpoint.SessionBacklog

Field Summary

Fields inherited from class WebsocketEndpoint

shutDown, shuttingDown

Constructor Summary

Constructors

Constructor	Description
ConsumerEndpoint(io.fluxzero.common.tracking.MessageStore messageStore, io.fluxzero.common.MessageType messageType)

Method Summary

Modifier and Type	Method	Description
void	onClose(ServerWebsocketSession session, io.fluxzero.sdk.common.websocket.WebsocketCloseReason closeReason)
protected void	shutDown()	Close all sessions on the websocket after an optional delay.
String	toString()

Methods inherited from class WebsocketEndpoint

createTasks, deserializeRequest, doSendResult, findAlternativeBacklog, getClientId, getClientName, getClientSdkVersion, getCompressionAlgorithm, getNamespace, getNegotiatedSessionId, getRequestHeaders, getRuntimeVersion, handleMessage, onError, onMessage, onOpen, registerMetrics, sendResultBatch, sessionMetadata

Methods inherited from class Object

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

Constructor Details

ConsumerEndpoint

public ConsumerEndpoint(io.fluxzero.common.tracking.MessageStore messageStore,
 io.fluxzero.common.MessageType messageType)

Method Details

onClose

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

Overrides:

onClose in class WebsocketEndpoint

shutDown

protected void shutDown()

Description copied from class: WebsocketEndpoint

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.

Overrides:

shutDown in class WebsocketEndpoint

toString

public String toString()

Overrides:

toString in class Object