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.PingRegistration, WebsocketEndpoint.SessionBacklog

Field Summary

Fields inherited from class WebsocketEndpoint

pingDelay, pingTimeout, shutDown, shuttingDown

Constructor Summary

Constructors

Constructor	Description
ConsumerEndpoint(io.fluxzero.common.tracking.MessageStore messageStore, io.fluxzero.common.MessageType messageType)
ConsumerEndpoint(io.fluxzero.common.tracking.MessageStore messageStore, io.fluxzero.common.MessageType messageType, CommandIdempotencyStore commandIdempotencyStore)
ConsumerEndpoint(io.fluxzero.common.tracking.TrackingStrategy trackingStrategy, io.fluxzero.common.tracking.MessageStore messageStore, io.fluxzero.common.tracking.PositionStore positionStore, io.fluxzero.common.MessageType messageType)
ConsumerEndpoint(io.fluxzero.common.tracking.TrackingStrategy trackingStrategy, io.fluxzero.common.tracking.MessageStore messageStore, io.fluxzero.common.tracking.PositionStore positionStore, io.fluxzero.common.MessageType messageType, CommandIdempotencyStore commandIdempotencyStore)

Method Summary

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

Methods inherited from class WebsocketEndpoint

abort, createTasks, deserializeRequest, dispatchRequest, doSendResult, findAlternativeBacklog, getClientId, getClientName, getClientSdkVersion, getCompressionAlgorithm, getNamespace, getNegotiatedSessionId, getRequestHeaders, getRuntimeVersion, handleMessage, onError, onMessage, onOpen, onPong, registerMetrics, schedulePing, sendPing, sendResultBatch, sessionMetadata, submitRequestTask

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)

ConsumerEndpoint

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

ConsumerEndpoint

public ConsumerEndpoint(io.fluxzero.common.tracking.TrackingStrategy trackingStrategy,
 io.fluxzero.common.tracking.MessageStore messageStore,
 io.fluxzero.common.tracking.PositionStore positionStore,
 io.fluxzero.common.MessageType messageType)

ConsumerEndpoint

public ConsumerEndpoint(io.fluxzero.common.tracking.TrackingStrategy trackingStrategy,
 io.fluxzero.common.tracking.MessageStore messageStore,
 io.fluxzero.common.tracking.PositionStore positionStore,
 io.fluxzero.common.MessageType messageType,
 CommandIdempotencyStore commandIdempotencyStore)

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

shouldHandleIdempotently

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

Overrides:

shouldHandleIdempotently in class WebsocketEndpoint

toString

public String toString()

Overrides:

toString in class Object