Package io.mats3.matssocket.impl

Class WebSocketOutgoingEnvelopes

java.lang.Object

io.mats3.matssocket.impl.WebSocketOutgoingEnvelopes

All Implemented Interfaces:

MatsSocketStatics

public class WebSocketOutgoingEnvelopes
extends Object
implements MatsSocketStatics

Handles async sending of not-"information bearing messages", that is, messages that are idempotent. These are ACK and NACKs, ACK2s, PONGs, PUB, and incomingHandler-settled DENY, RESOLVE, REJECT, FORWARD or RETRY. For all of these, if we cannot send it out due to WebSocket closed, we will upon reconnect of the session get the "causes" of them again (for PUB, we will get a SUB specifying which message was the last it saw).

Nested Class Summary

Nested classes/interfaces inherited from interface io.mats3.matssocket.impl.MatsSocketStatics

MatsSocketStatics.DebugStackTrace, MatsSocketStatics.DirectJson, MatsSocketStatics.DirectJsonMessageHandlingDeserializer, MatsSocketStatics.MatsSocketEnvelopeDto_Mixin, MatsSocketStatics.MessageToStringDeserializer, MatsSocketStatics.SocketSendIOException

Field Summary

Fields inherited from interface io.mats3.matssocket.impl.MatsSocketStatics

MAX_FORWARDER_POOL_SIZE, MAX_LENGTH_OF_TOPIC_NAME, MAX_NUMBER_OF_COMPENSATING_TRANSACTIONS_ATTEMPTS, MAX_NUMBER_OF_HELD_ENVELOPES_PER_SESSION, MAX_NUMBER_OF_MESSAGES_PER_FORWARD_LOOP, MAX_NUMBER_OF_OUTBOX_STORE_ATTEMPTS_CSAF, MAX_NUMBER_OF_RECORDED_ENVELOPES_PER_SESSION, MAX_NUMBER_OF_REDELIVERY_ATTEMPTS, MAX_NUMBER_OF_SESSIONS_PER_USER_ID, MAX_NUMBER_OF_TOPICS_PER_SESSION, MAX_SIZE_OF_HELD_ENVELOPE_MSGS, MDC_CLIENT_APP_NAME_AND_VERSION, MDC_CLIENT_LIB_AND_VERSIONS, MDC_CMID, MDC_MESSAGE_TYPE, MDC_PRINCIPAL_NAME, MDC_SESSION_ID, MDC_SMID, MDC_TRACE_ID, MDC_USER_ID, MILLIS_BETWEEN_COMPENSATING_TRANSACTIONS_ATTEMPTS, MILLIS_BETWEEN_LIVELINESS_UPDATE_RUN, MILLIS_BETWEEN_SCAVENGE_SESSION_REMNANTS_RUN, MILLIS_BETWEEN_SESSION_TIMEOUT_RUN, MILLIS_SESSION_TIMEOUT_SUPPLIER, MIN_FORWARDER_POOL_SIZE, NUMBER_OF_OUTGOING_ENVELOPES_SCHEDULER_THREADS, THREAD_PREFIX

Method Summary

Modifier and Type	Method	Description
void	removeAck(String matsSocketSessionId, String cmidAck)

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.mats3.matssocket.impl.MatsSocketStatics

jacksonMapper, ms, msSince

Method Details

removeAck

public void removeAck(String matsSocketSessionId,
 String cmidAck)