Class KeyValueEndPoint
java.lang.Object
io.fluxzero.testserver.websocket.WebsocketEndpoint
io.fluxzero.testserver.websocket.KeyValueEndPoint
-
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, webSocketSendTimeout -
Constructor Summary
ConstructorsConstructorDescriptionKeyValueEndPoint(KeyValueClient keyValueStore, CommandIdempotencyStore commandIdempotencyStore) -
Method Summary
Methods inherited from class WebsocketEndpoint
abort, createTasks, createTasks, deserializeRequest, dispatchRequest, dispatchRequest, doSendResult, findAlternativeBacklog, getClientId, getClientName, getClientSdkVersion, getCompressionAlgorithm, getNamespace, getNegotiatedSessionId, getRequestHeaders, getRuntimeVersion, getTransportFormat, handleMessage, handleMessage, newRequestStripeExecutors, onClose, onError, onMessage, onOpen, onPong, registerMetrics, schedulePing, sendPing, sendResultBatch, sendResultBatchAsync, sessionMetadata, shouldHandleIdempotently, shutDown, submitRequestTask, transportCodec
-
Constructor Details
-
KeyValueEndPoint
public KeyValueEndPoint(KeyValueClient keyValueStore, CommandIdempotencyStore commandIdempotencyStore)
-
-
Method Details
-
handle
-