Index (matssocket 0.19.0-2022-11-11 API)

A B C D E F G H I J L M N O P R S T U V W X _
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form

A

ACK - Enum constant in enum class io.mats3.matssocket.MatsSocketServer.MessageType: The specified message was Received, and acknowledged positively - i.e.
ACK2 - Enum constant in enum class io.mats3.matssocket.MatsSocketServer.MessageType: An "Acknowledge ^ 2", i.e.
ActiveMatsSocketSessionDto() - Constructor for class io.mats3.matssocket.MatsSocketServer.ActiveMatsSocketSessionDto
adaptReply(MatsSocketServer.MatsSocketEndpointReplyContext<I, MR, R>, MR) - Method in interface io.mats3.matssocket.MatsSocketServer.ReplyAdapter
addMessageEventListener(MatsSocketServer.MessageEventListener) - Method in class io.mats3.matssocket.impl.DefaultMatsSocketServer
addMessageEventListener(MatsSocketServer.MessageEventListener) - Method in interface io.mats3.matssocket.MatsSocketServer: MessageEventListeners will be invoked for every processed incoming and outgoing message for any session.
addSessionEstablishedEventListener(MatsSocketServer.SessionEstablishedEventListener) - Method in class io.mats3.matssocket.impl.DefaultMatsSocketServer
addSessionEstablishedEventListener(MatsSocketServer.SessionEstablishedEventListener) - Method in interface io.mats3.matssocket.MatsSocketServer: SessionEstablishedEvent listeners will be invoked when an LiveMatsSocketSession is established on this node of the MatsSocketServer instance cluster, i.e.
addSessionRemovedEventListener(MatsSocketServer.SessionRemovedEventListener) - Method in class io.mats3.matssocket.impl.DefaultMatsSocketServer
addSessionRemovedEventListener(MatsSocketServer.SessionRemovedEventListener) - Method in interface io.mats3.matssocket.MatsSocketServer: MatsSocketServer.SessionRemovedEvent listeners will be invoked when an MatsSocketServer.LiveMatsSocketSession is removed from this node of the MatsSocketServer instance cluster - this is both when a MatsSocketSession is DEREGISTERed, in which case the Client can still RECONNECT to the same MatsSocketSessionId, and when a MatsSocketSession is CLOSEd or TIMEOUTed.
ALPHABET - Static variable in class io.mats3.matssocket.impl.DefaultMatsSocketServer: A-Z, a-z, 0-9, which is 62 chars.
ALPHABET_JSON_ID - Static variable in class io.mats3.matssocket.impl.DefaultMatsSocketServer: All chars from 20-7f, except: Space (32, 0x20) - since spaces are always annoying to use in Ids " (34, 0x22) - since this is the start and end symbol of a String \ (92 0x5c) - since this is the escape char DEL (127, 0x7f) - since this is a control char This is 92 chars.
an - Variable in class io.mats3.matssocket.MatsSocketServer.MatsSocketEnvelopeDto
an - Variable in class io.mats3.matssocket.MatsSocketServer.MatsSocketEnvelopeDto.LogLineDto
an - Variable in class io.mats3.matssocket.MatsSocketServer.MatsSocketSessionDto
attemptGetRemoteAddress(Session) - Static method in class io.mats3.matssocket.impl.RemoteAddressContainerHacks
auth - Variable in class io.mats3.matssocket.MatsSocketServer.ActiveMatsSocketSessionDto
auth - Variable in class io.mats3.matssocket.MatsSocketServer.MatsSocketEnvelopeDto
AUTH - Enum constant in enum class io.mats3.matssocket.MatsSocketServer.MessageType: From Client: The client can use a separate AUTH message to send over the requested MatsSocketServer.MessageType.REAUTH (it could just as well put the 'auth' in a PING or any other message it had pending).
authenticated(Principal, String) - Method in interface io.mats3.matssocket.AuthenticationPlugin.AuthenticationContext: Good Authentication! Return the result from this method from SessionAuthenticator.initialAuthentication(..) to denote good authentication, supplying a Principal representing the accessing user, and the UserId of this user.
authenticated(Principal, String, EnumSet<AuthenticationPlugin.DebugOption>) - Method in interface io.mats3.matssocket.AuthenticationPlugin.AuthenticationContext: Good Authentication! Variant of AuthenticationPlugin.AuthenticationContext.authenticated(Principal, String) that grants the authenticated user special abilities to ask for debug info of the performed call.
AuthenticationPlugin - Interface in io.mats3.matssocket: Plugin that must evaluate whether a WebSocket connection shall be allowed, and then authenticate the resulting MatsSocketSession.
AuthenticationPlugin.AuthenticationContext - Interface in io.mats3.matssocket
AuthenticationPlugin.AuthenticationResult - Interface in io.mats3.matssocket: You are NOT supposed to implement this interface! Instances of this interface are created by methods on the AuthenticationPlugin.AuthenticationContext, which you are supposed to return from the AuthenticationPlugin.SessionAuthenticator to inform the MatsSocketServer about your verdict of the authentication attempt.
AuthenticationPlugin.DebugOption - Enum Class in io.mats3.matssocket: These bit-field enums (bit-field) is used by the Client to request different types of debug/meta information from Server-side, and used by the AuthenticationPlugin to tell the MatsSocketServer which types of information the specific user is allowed to request - the resulting debug/meta information provided is the intersection of the requested + allowed.
AuthenticationPlugin.SessionAuthenticator - Interface in io.mats3.matssocket: An instance of this interface shall be returned upon invocation of AuthenticationPlugin.newSessionAuthenticator().
authorizeUserForTopic(AuthenticationPlugin.AuthenticationContext, String) - Method in interface io.mats3.matssocket.AuthenticationPlugin.SessionAuthenticator: Decide whether the specified Principal/User should be allowed to subscribe to the specified Topic.
av - Variable in class io.mats3.matssocket.MatsSocketServer.MatsSocketEnvelopeDto
av - Variable in class io.mats3.matssocket.MatsSocketServer.MatsSocketEnvelopeDto.LogLineDto
av - Variable in class io.mats3.matssocket.MatsSocketServer.MatsSocketSessionDto

B

boot() - Method in interface io.mats3.matssocket.ClusterStoreAndForward: Start the ClusterStoreAndForward, perform DB preparations and migrations.
boot() - Method in class io.mats3.matssocket.impl.ClusterStoreAndForward_SQL

C

C2S - Enum constant in enum class io.mats3.matssocket.MatsSocketServer.MatsSocketEnvelopeWithMetaDto.Direction: Client-to-Server.
checkHandshake(ServerEndpointConfig, HandshakeRequest, HandshakeResponse) - Method in interface io.mats3.matssocket.AuthenticationPlugin.SessionAuthenticator: Implement this if you want to do a check on any other header values, e.g.
checkOrigin(String) - Method in interface io.mats3.matssocket.AuthenticationPlugin.SessionAuthenticator: Implement this if you want to do a check on the Origin header value while the initial WebSocket Upgrade/Handshake request is still being processed.
clone() - Method in class io.mats3.matssocket.MatsSocketServer.MatsSocketEnvelopeDto
CLOSE - Enum constant in enum class io.mats3.matssocket.MatsSocketServer.SessionRemovedEvent.SessionRemovedEventType: The MatsSocketSession was explicitly closed.
CLOSE_SESSION - Enum constant in enum class io.mats3.matssocket.MatsSocketServer.MatsSocketCloseCodes: 4000: Both from Server side and Client/Browser side, client should REJECT all outstanding: From Client/Browser: Used when the client closes WebSocket "on purpose", wanting to close the session - typically when the user explicitly logs out, or navigates away from web page.
CLOSED - Enum constant in enum class io.mats3.matssocket.MatsSocketServer.ActiveMatsSocketSession.MatsSocketSessionState: This MatsSocketServer.ActiveMatsSocketSession instance is dead - and the MatsSocketSession that this MatsSocketServer.ActiveMatsSocketSession represented was CLOSED - i.e.
closeSession(String) - Method in interface io.mats3.matssocket.ClusterStoreAndForward: Invoked when the client explicitly tells us that he closed this session, CLOSE_SESSION.
closeSession(String) - Method in class io.mats3.matssocket.impl.ClusterStoreAndForward_SQL
closeSession(String, String) - Method in class io.mats3.matssocket.impl.DefaultMatsSocketServer
closeSession(String, String) - Method in interface io.mats3.matssocket.MatsSocketServer: Closes the specified MatsSocketSession - can be used to forcibly close an active MatsSocketSession (i.e.
ClusterStoreAndForward - Interface in io.mats3.matssocket: MatsSockets forwards requests from WebSocket-connected clients to a Mats Endpoint, and must get the reply back to the client.
ClusterStoreAndForward_SQL - Class in io.mats3.matssocket.impl: An implementation of CSAF relying on a shared SQL database to store the necessary information in a cluster setting.
ClusterStoreAndForward_SQL(DataSource, String, Clock) - Constructor for class io.mats3.matssocket.impl.ClusterStoreAndForward_SQL
ClusterStoreAndForward_SQL_DbMigrations - Class in io.mats3.matssocket.impl: Perform the DB-setup/migrations that ClusterStoreAndForward_SQL needs, using Flyway.
ClusterStoreAndForward_SQL_DbMigrations() - Constructor for class io.mats3.matssocket.impl.ClusterStoreAndForward_SQL_DbMigrations
ClusterStoreAndForward_SQL_DbMigrations.Database - Enum Class in io.mats3.matssocket.impl: Defines the String and Binary datatypes for some databases.
ClusterStoreAndForward.CurrentNode - Interface in io.mats3.matssocket
ClusterStoreAndForward.DataAccessException - Exception in io.mats3.matssocket: If having problems accessing the underlying common data store.
ClusterStoreAndForward.MessageIdAlreadyExistsException - Exception in io.mats3.matssocket: Thrown if the operation resulted in a Unique Constraint situation.
ClusterStoreAndForward.RequestCorrelation - Interface in io.mats3.matssocket
ClusterStoreAndForward.SimpleCurrentNode - Class in io.mats3.matssocket
ClusterStoreAndForward.SimpleRequestCorrelation - Class in io.mats3.matssocket
ClusterStoreAndForward.SimpleStoredInMessage - Class in io.mats3.matssocket
ClusterStoreAndForward.SimpleStoredOutMessage - Class in io.mats3.matssocket
ClusterStoreAndForward.StoredInMessage - Interface in io.mats3.matssocket
ClusterStoreAndForward.StoredOutMessage - Interface in io.mats3.matssocket
ClusterStoreAndForward.WrongUserException - Exception in io.mats3.matssocket: Thrown from ClusterStoreAndForward.registerSessionAtThisNode(String, String, String, String, String, String) if the userId does not match the original userId that created this session.
clv - Variable in class io.mats3.matssocket.MatsSocketServer.MatsSocketEnvelopeDto
clv - Variable in class io.mats3.matssocket.MatsSocketServer.MatsSocketSessionDto
cmid - Variable in class io.mats3.matssocket.MatsSocketServer.MatsSocketEnvelopeDto
cmrnn - Variable in class io.mats3.matssocket.MatsSocketServer.MatsSocketEnvelopeDto.DebugDto
cmrts - Variable in class io.mats3.matssocket.MatsSocketServer.MatsSocketEnvelopeDto.DebugDto
create(ClusterStoreAndForward_SQL_DbMigrations.Database) - Static method in class io.mats3.matssocket.impl.ClusterStoreAndForward_SQL_DbMigrations
create(String, String) - Static method in class io.mats3.matssocket.impl.ClusterStoreAndForward_SQL_DbMigrations
create(DataSource, String) - Static method in class io.mats3.matssocket.impl.ClusterStoreAndForward_SQL
createMatsSocketServer(ServerContainer, MatsFactory, ClusterStoreAndForward, AuthenticationPlugin, String) - Static method in class io.mats3.matssocket.impl.DefaultMatsSocketServer: Variant of the full method that uses the appName that the MatsFactory is configured with as the 'instanceName' parameter.
createMatsSocketServer(ServerContainer, MatsFactory, ClusterStoreAndForward, AuthenticationPlugin, String, String) - Static method in class io.mats3.matssocket.impl.DefaultMatsSocketServer: Create a MatsSocketServer, piecing together necessary bits.
CUSTOM_A - Enum constant in enum class io.mats3.matssocket.AuthenticationPlugin.DebugOption: AuthenticationPlugin-specific "Option A" - this is not used by MatsSocket itself, but can be employed and given a meaning by the AuthenticationPlugin.
CUSTOM_B - Enum constant in enum class io.mats3.matssocket.AuthenticationPlugin.DebugOption: AuthenticationPlugin-specific "Option B" - this is not used by MatsSocket itself, but can be employed and given a meaning by the AuthenticationPlugin.

D

DataAccessException(String) - Constructor for exception io.mats3.matssocket.ClusterStoreAndForward.DataAccessException
DataAccessException(String, Throwable) - Constructor for exception io.mats3.matssocket.ClusterStoreAndForward.DataAccessException
DataStoreException(String) - Constructor for exception io.mats3.matssocket.MatsSocketServer.DataStoreException
DataStoreException(String, Throwable) - Constructor for exception io.mats3.matssocket.MatsSocketServer.DataStoreException
debug - Variable in class io.mats3.matssocket.MatsSocketServer.MatsSocketEnvelopeDto
DebugDto() - Constructor for class io.mats3.matssocket.MatsSocketServer.MatsSocketEnvelopeDto.DebugDto
DebugStackTrace(String) - Constructor for exception io.mats3.matssocket.impl.MatsSocketStatics.DebugStackTrace
DefaultMatsSocketServer - Class in io.mats3.matssocket.impl
deleteMessageIdsFromInbox(String, Collection<String>) - Method in interface io.mats3.matssocket.ClusterStoreAndForward: Deletes the incoming message Ids, as we've established that the client will never try to send this particular message again.
deleteMessageIdsFromInbox(String, Collection<String>) - Method in class io.mats3.matssocket.impl.ClusterStoreAndForward_SQL
deny() - Method in interface io.mats3.matssocket.MatsSocketServer.MatsSocketEndpointIncomingContext: Invoke if you want to deny this message from being processed, e.g.
DENY - Enum constant in enum class io.mats3.matssocket.MatsSocketServer.MatsSocketEnvelopeWithMetaDto.IncomingResolution: The IncomingHandler sent NACK ("Negative Acknowledgement"), signifying that it did not want to process the message, typically because the authenticated user was not allowed to perform the requested action (i.e.
DEREGISTER - Enum constant in enum class io.mats3.matssocket.MatsSocketServer.SessionRemovedEvent.SessionRemovedEventType: The WebSocket connection was severed without an explicit MatsSocketSession closing, e.g.
DEREGISTERED - Enum constant in enum class io.mats3.matssocket.MatsSocketServer.ActiveMatsSocketSession.MatsSocketSessionState: This MatsSocketServer.ActiveMatsSocketSession instance is dead - but the MatsSocketSession that this MatsSocketServer.ActiveMatsSocketSession represented is still "live" in the data store, i.e.
deregisterSessionFromThisNode(String, String) - Method in interface io.mats3.matssocket.ClusterStoreAndForward: Deregisters a Session home when a WebSocket is closed.
deregisterSessionFromThisNode(String, String) - Method in class io.mats3.matssocket.impl.ClusterStoreAndForward_SQL
desc - Variable in class io.mats3.matssocket.MatsSocketServer.MatsSocketEnvelopeDto
deserialize(JsonParser, DeserializationContext) - Method in class io.mats3.matssocket.impl.MatsSocketStatics.MessageToStringDeserializer
dir - Variable in class io.mats3.matssocket.MatsSocketServer.MatsSocketEnvelopeWithMetaDto
DirectJsonMessageHandlingDeserializer() - Constructor for class io.mats3.matssocket.impl.MatsSocketStatics.DirectJsonMessageHandlingDeserializer
DISCONNECT - Enum constant in enum class io.mats3.matssocket.MatsSocketServer.MatsSocketCloseCodes: 4003: From Server side: Currently used in the specific situation where a MatsSocket client connects with the same MatsSocketSessionId as an existing open WebSocket connection.

E

eid - Variable in class io.mats3.matssocket.MatsSocketServer.MatsSocketEnvelopeDto

enumSetOf(int) - Static method in enum class io.mats3.matssocket.AuthenticationPlugin.DebugOption

enumSetOf(Integer) - Static method in enum class io.mats3.matssocket.AuthenticationPlugin.DebugOption

EXCEPTION - Enum constant in enum class io.mats3.matssocket.MatsSocketServer.MatsSocketEnvelopeWithMetaDto.IncomingResolution

The IncomingHandler raised an Exception.

execute(Runnable) - Method in class io.mats3.matssocket.impl.SaneThreadPoolExecutor

F

flags(EnumSet<AuthenticationPlugin.DebugOption>) - Static method in enum class io.mats3.matssocket.AuthenticationPlugin.DebugOption

fmeid - Variable in class io.mats3.matssocket.MatsSocketServer.MatsSocketEnvelopeWithMetaDto

forward(String, Object, MatsInitiator.InitiateLambda) - Method in interface io.mats3.matssocket.MatsSocketServer.MatsSocketEndpointIncomingContext

Generic forward method.

FORWARD - Enum constant in enum class io.mats3.matssocket.MatsSocketServer.MatsSocketEnvelopeWithMetaDto.IncomingResolution

The IncomingHandler forwarded the SEND or REQUEST to a Mats Endpoint.

forwardEssential(String, Object) - Method in interface io.mats3.matssocket.MatsSocketServer.MatsSocketEndpointIncomingContext

Employ this for Requests or Sends whose call flow can potentially change state in the system.

forwardNonessential(String, Object) - Method in interface io.mats3.matssocket.MatsSocketServer.MatsSocketEndpointIncomingContext

Employ this for pure, non-state changing "GET-style" Requests, or Sends for e.g.

G

getActiveMatsSocketSessions() - Method in class io.mats3.matssocket.impl.DefaultMatsSocketServer

getActiveMatsSocketSessions() - Method in interface io.mats3.matssocket.MatsSocketServer

This returns static, frozen-in-time, "copied-out" DTO-variants of the LiveMatsSocketSessions.

getAllowedDebugOptions() - Method in interface io.mats3.matssocket.MatsSocketServer.LiveMatsSocketSession

getAllowedDebugOptions() - Method in interface io.mats3.matssocket.MatsSocketServer.MatsSocketEndpointIncomingContext

getAndDeleteRequestCorrelation(String, String) - Method in interface io.mats3.matssocket.ClusterStoreAndForward

getAndDeleteRequestCorrelation(String, String) - Method in class io.mats3.matssocket.impl.ClusterStoreAndForward_SQL

getAppName() - Method in interface io.mats3.matssocket.MatsSocketServer.MatsSocketSession

Note: Do realize that it is the Client that specifies this value, there is no restriction and you cannot trust that this String falls within your expected values.

getAppName() - Method in class io.mats3.matssocket.MatsSocketServer.MatsSocketSessionDto

getAppVersion() - Method in interface io.mats3.matssocket.MatsSocketServer.MatsSocketSession

Note: Do realize that it is the Client that specifies this value, there is no restriction and you cannot trust that this String falls within your expected values.

getAppVersion() - Method in class io.mats3.matssocket.MatsSocketServer.MatsSocketSessionDto

getAttemptTimestamp() - Method in class io.mats3.matssocket.ClusterStoreAndForward.SimpleStoredOutMessage

getAttemptTimestamp() - Method in interface io.mats3.matssocket.ClusterStoreAndForward.StoredOutMessage

getAuthorization() - Method in interface io.mats3.matssocket.MatsSocketServer.ActiveMatsSocketSession

getAuthorization() - Method in class io.mats3.matssocket.MatsSocketServer.ActiveMatsSocketSessionDto

getAuthorizationValue() - Method in interface io.mats3.matssocket.MatsSocketServer.MatsSocketEndpointIncomingContext

getBinaryType() - Method in enum class io.mats3.matssocket.impl.ClusterStoreAndForward_SQL_DbMigrations.Database

getClientLibAndVersions() - Method in interface io.mats3.matssocket.MatsSocketServer.MatsSocketSession

Note: Do realize that it is the Client that specifies this value, there is no restriction and you cannot trust that this String falls within your expected values.

getClientLibAndVersions() - Method in class io.mats3.matssocket.MatsSocketServer.MatsSocketSessionDto

getClientMessageId() - Method in class io.mats3.matssocket.ClusterStoreAndForward.SimpleStoredInMessage

getClientMessageId() - Method in class io.mats3.matssocket.ClusterStoreAndForward.SimpleStoredOutMessage

getClientMessageId() - Method in interface io.mats3.matssocket.ClusterStoreAndForward.StoredInMessage

getClientMessageId() - Method in interface io.mats3.matssocket.ClusterStoreAndForward.StoredOutMessage

getCloseCode() - Method in interface io.mats3.matssocket.MatsSocketServer.SessionRemovedEvent

getCloseCode(int) - Static method in enum class io.mats3.matssocket.MatsSocketServer.MatsSocketCloseCodes

getCode() - Method in enum class io.mats3.matssocket.MatsSocketServer.MatsSocketCloseCodes

getConnectionId() - Method in interface io.mats3.matssocket.ClusterStoreAndForward.CurrentNode

getConnectionId() - Method in class io.mats3.matssocket.ClusterStoreAndForward.SimpleCurrentNode

getCorrelationBinary() - Method in interface io.mats3.matssocket.ClusterStoreAndForward.RequestCorrelation

getCorrelationBinary() - Method in class io.mats3.matssocket.ClusterStoreAndForward.SimpleRequestCorrelation

getCorrelationBinary() - Method in interface io.mats3.matssocket.MatsSocketServer.MatsSocketEndpointIncomingContext

If this is a Client Reply from a Server-to-Client request, this method returns the 'correlationBinary' that was provided in the request.

getCorrelationString() - Method in interface io.mats3.matssocket.ClusterStoreAndForward.RequestCorrelation

getCorrelationString() - Method in class io.mats3.matssocket.ClusterStoreAndForward.SimpleRequestCorrelation

getCorrelationString() - Method in interface io.mats3.matssocket.MatsSocketServer.MatsSocketEndpointIncomingContext

If this is a Client Reply from a Server-to-Client request, this method returns the 'correlationString' that was provided in the request.

getCurrentRegisteredNodeForSession(String) - Method in interface io.mats3.matssocket.ClusterStoreAndForward

getCurrentRegisteredNodeForSession(String) - Method in class io.mats3.matssocket.impl.ClusterStoreAndForward_SQL

getDeliveryCount() - Method in class io.mats3.matssocket.ClusterStoreAndForward.SimpleStoredOutMessage

getDeliveryCount() - Method in interface io.mats3.matssocket.ClusterStoreAndForward.StoredOutMessage

getEnvelope() - Method in class io.mats3.matssocket.ClusterStoreAndForward.SimpleStoredOutMessage

getEnvelope() - Method in interface io.mats3.matssocket.ClusterStoreAndForward.StoredOutMessage

getEnvelopes() - Method in interface io.mats3.matssocket.MatsSocketServer.MessageEvent

getFullEnvelope() - Method in class io.mats3.matssocket.ClusterStoreAndForward.SimpleStoredInMessage

getFullEnvelope() - Method in interface io.mats3.matssocket.ClusterStoreAndForward.StoredInMessage

getHandshakeRequest() - Method in interface io.mats3.matssocket.AuthenticationPlugin.AuthenticationContext

getIncomingClass() - Method in interface io.mats3.matssocket.MatsSocketServer.MatsSocketEndpoint

getIncomingSrrMsgHandler() - Method in class io.mats3.matssocket.impl.DefaultMatsSocketServer

getJson() - Method in class io.mats3.matssocket.impl.MatsSocketStatics.DirectJson

getLastActivityTimestamp() - Method in interface io.mats3.matssocket.MatsSocketServer.ActiveMatsSocketSession

getLastActivityTimestamp() - Method in class io.mats3.matssocket.MatsSocketServer.ActiveMatsSocketSessionDto

getLastAuthenticatedTimestamp() - Method in interface io.mats3.matssocket.MatsSocketServer.ActiveMatsSocketSession

getLastAuthenticatedTimestamp() - Method in class io.mats3.matssocket.MatsSocketServer.ActiveMatsSocketSessionDto

getLastClientPingTimestamp() - Method in interface io.mats3.matssocket.MatsSocketServer.ActiveMatsSocketSession

getLastClientPingTimestamp() - Method in class io.mats3.matssocket.MatsSocketServer.ActiveMatsSocketSessionDto

getLastEnvelopes() - Method in interface io.mats3.matssocket.MatsSocketServer.ActiveMatsSocketSession

getLastEnvelopes() - Method in class io.mats3.matssocket.MatsSocketServer.ActiveMatsSocketSessionDto

getLiveMatsSocketSessions() - Method in class io.mats3.matssocket.impl.DefaultMatsSocketServer

getLiveMatsSocketSessions() - Method in interface io.mats3.matssocket.MatsSocketServer

Imagine that the MatsSocketServer uses a ConcurrentMap to keep its set of local, live, currently connected MatsSocketSessions.

getMatsContext() - Method in interface io.mats3.matssocket.MatsSocketServer.MatsSocketEndpointReplyContext

getMatsInitiate() - Method in interface io.mats3.matssocket.MatsSocketServer.MatsSocketEndpointIncomingContext

Using the returned MatsInitiate instance, which is the same as the forwardXX(..) methods utilize, you can initiate one or several Mats flows, in addition to your actual handling of the incoming message - within the same Mats transactional demarcation as the handling of the incoming message ("actual handling" referring to forward, resolve, reject or even deny or ignore - the latter two being a bit hard to understand why you'd want).

getMatsReplyClass() - Method in interface io.mats3.matssocket.MatsSocketServer.MatsSocketEndpoint

getMatsReplyMessage() - Method in interface io.mats3.matssocket.MatsSocketServer.MatsSocketEndpointReplyContext

getMatsSocketEndpoint() - Method in interface io.mats3.matssocket.MatsSocketServer.MatsSocketEndpointContext

getMatsSocketEndpointId() - Method in interface io.mats3.matssocket.MatsSocketServer.MatsSocketEndpoint

getMatsSocketEndpointId() - Method in interface io.mats3.matssocket.MatsSocketServer.MatsSocketEndpointContext

Convenience method, default implementation is this.getMatsSocketEndpoint().getMatsSocketEndpointId().

getMatsSocketEndpoints() - Method in class io.mats3.matssocket.impl.DefaultMatsSocketServer

getMatsSocketEndpoints() - Method in interface io.mats3.matssocket.MatsSocketServer

getMatsSocketIncomingMessage() - Method in interface io.mats3.matssocket.MatsSocketServer.MatsSocketEndpointIncomingContext

getMatsSocketSession() - Method in interface io.mats3.matssocket.AuthenticationPlugin.AuthenticationContext

getMatsSocketSession() - Method in interface io.mats3.matssocket.MatsSocketServer.MessageEvent

getMatsSocketSession() - Method in interface io.mats3.matssocket.MatsSocketServer.SessionEstablishedEvent

getMatsSocketSessionId() - Method in interface io.mats3.matssocket.ClusterStoreAndForward.RequestCorrelation

getMatsSocketSessionId() - Method in class io.mats3.matssocket.ClusterStoreAndForward.SimpleRequestCorrelation

getMatsSocketSessionId() - Method in class io.mats3.matssocket.ClusterStoreAndForward.SimpleStoredInMessage

getMatsSocketSessionId() - Method in class io.mats3.matssocket.ClusterStoreAndForward.SimpleStoredOutMessage

getMatsSocketSessionId() - Method in interface io.mats3.matssocket.ClusterStoreAndForward.StoredInMessage

getMatsSocketSessionId() - Method in interface io.mats3.matssocket.ClusterStoreAndForward.StoredOutMessage

getMatsSocketSessionId() - Method in interface io.mats3.matssocket.MatsSocketServer.MatsSocketEndpointIncomingContext

getMatsSocketSessionId() - Method in interface io.mats3.matssocket.MatsSocketServer.MatsSocketSession

getMatsSocketSessionId() - Method in class io.mats3.matssocket.MatsSocketServer.MatsSocketSessionDto

getMatsSocketSessionId() - Method in interface io.mats3.matssocket.MatsSocketServer.SessionEstablishedEvent

getMatsSocketSessionId() - Method in interface io.mats3.matssocket.MatsSocketServer.SessionRemovedEvent

getMatsSocketSessions(boolean, String, String, String) - Method in class io.mats3.matssocket.impl.DefaultMatsSocketServer

getMatsSocketSessions(boolean, String, String, String) - Method in interface io.mats3.matssocket.MatsSocketServer

Unless restricted by the "constraint parameters", this method returns all MatsSocketSessions on this MatsSocketServer instance, regardless of whether the session currently is connected, and if connected, which node it is connected to.

getMatsSocketSessionsCount(boolean, String, String, String) - Method in class io.mats3.matssocket.impl.DefaultMatsSocketServer

getMatsSocketSessionsCount(boolean, String, String, String) - Method in interface io.mats3.matssocket.MatsSocketServer

Like MatsSocketServer.getMatsSocketSessions(boolean, String, String, String), only returning the count - this might be interesting if there are very many sessions, and you do not need the full DTOs of every Session, just the count for a metric to graph or similar.

getMessageBinary() - Method in class io.mats3.matssocket.ClusterStoreAndForward.SimpleStoredInMessage

getMessageBinary() - Method in class io.mats3.matssocket.ClusterStoreAndForward.SimpleStoredOutMessage

getMessageBinary() - Method in interface io.mats3.matssocket.ClusterStoreAndForward.StoredInMessage

getMessageBinary() - Method in interface io.mats3.matssocket.ClusterStoreAndForward.StoredOutMessage

getMessageFromInbox(String, String) - Method in interface io.mats3.matssocket.ClusterStoreAndForward

getMessageFromInbox(String, String) - Method in class io.mats3.matssocket.impl.ClusterStoreAndForward_SQL

getMessagesFromOutbox(String, int) - Method in interface io.mats3.matssocket.ClusterStoreAndForward

Fetch a set of messages, up to 'maxNumberOfMessages' - but do not include messages that have been attempted delivered already (marked with ClusterStoreAndForward.outboxMessagesAttemptedDelivery(String, Collection)).

getMessagesFromOutbox(String, int) - Method in class io.mats3.matssocket.impl.ClusterStoreAndForward_SQL

getMessageText() - Method in class io.mats3.matssocket.ClusterStoreAndForward.SimpleStoredOutMessage

getMessageText() - Method in interface io.mats3.matssocket.ClusterStoreAndForward.StoredOutMessage

getMessageType() - Method in interface io.mats3.matssocket.MatsSocketServer.MatsSocketEndpointIncomingContext

getMigrationsLocation() - Method in class io.mats3.matssocket.impl.ClusterStoreAndForward_SQL_DbMigrations

getNodename() - Method in interface io.mats3.matssocket.ClusterStoreAndForward.CurrentNode

getNodename() - Method in class io.mats3.matssocket.ClusterStoreAndForward.SimpleCurrentNode

getNodeName() - Method in interface io.mats3.matssocket.MatsSocketServer.MatsSocketSession

getNodeName() - Method in class io.mats3.matssocket.MatsSocketServer.MatsSocketSessionDto

getOriginatingRemoteAddr() - Method in interface io.mats3.matssocket.MatsSocketServer.ActiveMatsSocketSession

The AuthenticationPlugin can set the originating remote IP address - which must be derived by headers like X-Forwarded-For (Wikipedia).

getOriginatingRemoteAddr() - Method in class io.mats3.matssocket.MatsSocketServer.ActiveMatsSocketSessionDto

getPlaceHolders() - Method in class io.mats3.matssocket.impl.ClusterStoreAndForward_SQL_DbMigrations

getPrincipal() - Method in interface io.mats3.matssocket.MatsSocketServer.LiveMatsSocketSession

getPrincipal() - Method in interface io.mats3.matssocket.MatsSocketServer.MatsSocketEndpointIncomingContext

getPrincipalName() - Method in interface io.mats3.matssocket.MatsSocketServer.ActiveMatsSocketSession

getPrincipalName() - Method in class io.mats3.matssocket.MatsSocketServer.ActiveMatsSocketSessionDto

getReason() - Method in interface io.mats3.matssocket.MatsSocketServer.SessionRemovedEvent

getRemoteAddr() - Method in interface io.mats3.matssocket.MatsSocketServer.ActiveMatsSocketSession

If we have a way to find the connected (remote) address, it will be exposed here.

getRemoteAddr() - Method in class io.mats3.matssocket.MatsSocketServer.ActiveMatsSocketSessionDto

getReplyClass() - Method in interface io.mats3.matssocket.MatsSocketServer.MatsSocketEndpoint

getReplyTerminatorId() - Method in interface io.mats3.matssocket.ClusterStoreAndForward.RequestCorrelation

getReplyTerminatorId() - Method in class io.mats3.matssocket.ClusterStoreAndForward.SimpleRequestCorrelation

getRequestTimestamp() - Method in interface io.mats3.matssocket.ClusterStoreAndForward.RequestCorrelation

getRequestTimestamp() - Method in class io.mats3.matssocket.ClusterStoreAndForward.SimpleRequestCorrelation

getRequestTimestamp() - Method in class io.mats3.matssocket.ClusterStoreAndForward.SimpleStoredOutMessage

getRequestTimestamp() - Method in interface io.mats3.matssocket.ClusterStoreAndForward.StoredOutMessage

getResolvedDebugOptions() - Method in interface io.mats3.matssocket.MatsSocketServer.MatsSocketEndpointIncomingContext

getServerMessageId() - Method in interface io.mats3.matssocket.ClusterStoreAndForward.RequestCorrelation

getServerMessageId() - Method in class io.mats3.matssocket.ClusterStoreAndForward.SimpleRequestCorrelation

getServerMessageId() - Method in class io.mats3.matssocket.ClusterStoreAndForward.SimpleStoredOutMessage

getServerMessageId() - Method in interface io.mats3.matssocket.ClusterStoreAndForward.StoredOutMessage

getSession() - Method in interface io.mats3.matssocket.MatsSocketServer.MatsSocketEndpointIncomingContext

getSessionCreatedTimestamp() - Method in interface io.mats3.matssocket.MatsSocketServer.MatsSocketSession

getSessionCreatedTimestamp() - Method in class io.mats3.matssocket.MatsSocketServer.MatsSocketSessionDto

getSessionEstablishedTimestamp() - Method in interface io.mats3.matssocket.MatsSocketServer.ActiveMatsSocketSession

getSessionEstablishedTimestamp() - Method in class io.mats3.matssocket.MatsSocketServer.ActiveMatsSocketSessionDto

getSessionLivelinessTimestamp() - Method in interface io.mats3.matssocket.MatsSocketServer.MatsSocketSession

getSessionLivelinessTimestamp() - Method in class io.mats3.matssocket.MatsSocketServer.MatsSocketSessionDto

getSessions(boolean, String, String, String) - Method in interface io.mats3.matssocket.ClusterStoreAndForward

Direct implementation of MatsSocketServer.getMatsSocketSessions(boolean, String, String, String) - go read there for semantics.

getSessions(boolean, String, String, String) - Method in class io.mats3.matssocket.impl.ClusterStoreAndForward_SQL

getSessionsCount(boolean, String, String, String) - Method in interface io.mats3.matssocket.ClusterStoreAndForward

Direct implementation of MatsSocketServer.getMatsSocketSessionsCount(boolean, String, String, String) - go read there for semantics.

getSessionsCount(boolean, String, String, String) - Method in class io.mats3.matssocket.impl.ClusterStoreAndForward_SQL

getState() - Method in interface io.mats3.matssocket.MatsSocketServer.LiveMatsSocketSession

getStoredTimestamp() - Method in class io.mats3.matssocket.ClusterStoreAndForward.SimpleStoredInMessage

getStoredTimestamp() - Method in class io.mats3.matssocket.ClusterStoreAndForward.SimpleStoredOutMessage

getStoredTimestamp() - Method in interface io.mats3.matssocket.ClusterStoreAndForward.StoredInMessage

getStoredTimestamp() - Method in interface io.mats3.matssocket.ClusterStoreAndForward.StoredOutMessage

getTextType() - Method in enum class io.mats3.matssocket.impl.ClusterStoreAndForward_SQL_DbMigrations.Database

getTopicSubscriptions() - Method in interface io.mats3.matssocket.MatsSocketServer.ActiveMatsSocketSession

getTopicSubscriptions() - Method in class io.mats3.matssocket.MatsSocketServer.ActiveMatsSocketSessionDto

getTraceId() - Method in class io.mats3.matssocket.ClusterStoreAndForward.SimpleStoredOutMessage

getTraceId() - Method in interface io.mats3.matssocket.ClusterStoreAndForward.StoredOutMessage

getTraceId() - Method in interface io.mats3.matssocket.MatsSocketServer.MatsSocketEndpointIncomingContext

getType() - Method in class io.mats3.matssocket.ClusterStoreAndForward.SimpleStoredOutMessage

getType() - Method in interface io.mats3.matssocket.ClusterStoreAndForward.StoredOutMessage

getType() - Method in interface io.mats3.matssocket.MatsSocketServer.SessionEstablishedEvent

getType() - Method in interface io.mats3.matssocket.MatsSocketServer.SessionRemovedEvent

getUserId() - Method in interface io.mats3.matssocket.MatsSocketServer.MatsSocketEndpointIncomingContext

getUserId() - Method in interface io.mats3.matssocket.MatsSocketServer.MatsSocketSession

getUserId() - Method in class io.mats3.matssocket.MatsSocketServer.MatsSocketSessionDto

getWebSocketOutgoingEnvelopes() - Method in class io.mats3.matssocket.impl.DefaultMatsSocketServer

getWebSocketSession() - Method in interface io.mats3.matssocket.MatsSocketServer.LiveMatsSocketSession

GOING_AWAY - Enum constant in enum class io.mats3.matssocket.MatsSocketServer.MatsSocketCloseCodes

Standard code 1001 - From Client/Browser side, client should have REJECTed all outstanding: Synonym for MatsSocketServer.MatsSocketCloseCodes.CLOSE_SESSION, as the WebSocket documentation states "indicates that an endpoint is "going away", such as a server going down or a browser having navigated away from a page.", the latter point being pretty much exactly correct wrt.

H

H2 - Enum constant in enum class io.mats3.matssocket.impl.ClusterStoreAndForward_SQL_DbMigrations.Database

H2: VARCHAR, VARBINARY (NOTE: H2 also handles ClusterStoreAndForward_SQL_DbMigrations.Database.MS_SQL and ClusterStoreAndForward_SQL_DbMigrations.Database.MS_SQL_2019_UTF8).

handleIncoming(MatsSocketServer.MatsSocketEndpointIncomingContext<I, MR, R>, Principal, I) - Method in interface io.mats3.matssocket.MatsSocketServer.IncomingAuthorizationAndAdapter

HELLO - Enum constant in enum class io.mats3.matssocket.MatsSocketServer.MessageType

A HELLO message must be part of the first Pipeline of messages, preferably alone.

hos - Variable in class io.mats3.matssocket.MatsSocketServer.MatsSocketEnvelopeDto.LogLineDto

I

icnanos - Variable in class io.mats3.matssocket.MatsSocketServer.MatsSocketEnvelopeWithMetaDto

icts - Variable in class io.mats3.matssocket.MatsSocketServer.MatsSocketEnvelopeWithMetaDto

id - Variable in class io.mats3.matssocket.MatsSocketServer.MatsSocketSessionDto

ids - Variable in class io.mats3.matssocket.MatsSocketServer.MatsSocketEnvelopeDto

IncomingSrrMsgHandler - Class in io.mats3.matssocket.impl

Incoming (Client-to-Server) Send, Request and Replies (Resolve and Reject) handler.

IncomingSrrMsgHandler(DefaultMatsSocketServer, int, int) - Constructor for class io.mats3.matssocket.impl.IncomingSrrMsgHandler

initialAuthentication(AuthenticationPlugin.AuthenticationContext, String) - Method in interface io.mats3.matssocket.AuthenticationPlugin.SessionAuthenticator

Invoked when the MatsSocket initially connects (or reconnects) over WebSocket, and needs to be authenticated by the Authorization string supplied via the initial set ("pipeline") of message from the client, typically in the HELLO message (which needs to present in the initial pipeline).

innn - Variable in class io.mats3.matssocket.MatsSocketServer.MatsSocketEnvelopeWithMetaDto

ints - Variable in class io.mats3.matssocket.MatsSocketServer.MatsSocketEnvelopeWithMetaDto

invalidAuthentication(String) - Method in interface io.mats3.matssocket.AuthenticationPlugin.AuthenticationContext

Bad Authentication! Return the result from this method from SessionAuthenticator.initialAuthentication(..) or AuthenticationPlugin.SessionAuthenticator.reevaluateAuthentication(AuthenticationContext, String, Principal) SessionAuthenticator.reevaluateAuthentication(..)} to denote BAD authentication, supplying a reason string which will be sent all the way to the client (so do not include sensitive information).

io.mats3.matssocket - package io.mats3.matssocket

io.mats3.matssocket.impl - package io.mats3.matssocket.impl

ir - Variable in class io.mats3.matssocket.MatsSocketServer.MatsSocketEnvelopeWithMetaDto

isHandlesMessages() - Method in enum class io.mats3.matssocket.MatsSocketServer.ActiveMatsSocketSession.MatsSocketSessionState

isSessionClosed() - Method in enum class io.mats3.matssocket.MatsSocketServer.SessionRemovedEvent.SessionRemovedEventType

isSessionExists(String) - Method in interface io.mats3.matssocket.ClusterStoreAndForward

isSessionExists(String) - Method in class io.mats3.matssocket.impl.ClusterStoreAndForward_SQL

J

jacksonMapper() - Method in interface io.mats3.matssocket.impl.MatsSocketStatics

L

l - Variable in class io.mats3.matssocket.MatsSocketServer.MatsSocketEnvelopeDto.DebugDto

lactts - Variable in class io.mats3.matssocket.MatsSocketServer.ActiveMatsSocketSessionDto

lauthts - Variable in class io.mats3.matssocket.MatsSocketServer.ActiveMatsSocketSessionDto

lcpts - Variable in class io.mats3.matssocket.MatsSocketServer.ActiveMatsSocketSessionDto

level - Variable in class io.mats3.matssocket.MatsSocketServer.MatsSocketEnvelopeDto.LogLineDto

LogLineDto() - Constructor for class io.mats3.matssocket.MatsSocketServer.MatsSocketEnvelopeDto.LogLineDto

M

m - Variable in class io.mats3.matssocket.MatsSocketServer.MatsSocketEnvelopeDto.LogLineDto

MATS_SOCKET_PROTOCOL_ERROR - Enum constant in enum class io.mats3.matssocket.MatsSocketServer.MatsSocketCloseCodes

4004: From Server side: Client should REJECT all outstanding and "crash"/reboot application: Used when the client does not speak the MatsSocket protocol correctly.

matsSocketDirectReplyEndpoint(String, Class, Class<R>, MatsSocketServer.IncomingAuthorizationAndAdapter<I, Void, R>) - Method in interface io.mats3.matssocket.MatsSocketServer

(Convenience-variant of the base method) Registers a MatsSocket Endpoint meant for situations where you intend to reply directly in the MatsSocketServer.IncomingAuthorizationAndAdapter without forwarding to Mats.

matsSocketEndpoint(String, Class, Class<MR>, Class<R>, MatsSocketServer.IncomingAuthorizationAndAdapter<I, MR, R>, MatsSocketServer.ReplyAdapter<I, MR, R>) - Method in class io.mats3.matssocket.impl.DefaultMatsSocketServer

matsSocketEndpoint(String, Class, Class<MR>, Class<R>, MatsSocketServer.IncomingAuthorizationAndAdapter<I, MR, R>, MatsSocketServer.ReplyAdapter<I, MR, R>) - Method in interface io.mats3.matssocket.MatsSocketServer

Registers a MatsSocket Endpoint, including a MatsSocketServer.ReplyAdapter which can adapt the reply from the Mats endpoint before being fed back to the MatsSocket - and also decide whether to resolve or reject the waiting Client Promise.

matsSocketEndpoint(String, Class, Class<R>, MatsSocketServer.IncomingAuthorizationAndAdapter<I, R, R>) - Method in interface io.mats3.matssocket.MatsSocketServer

(Convenience-variant of the base method) Registers a MatsSocket Endpoint where there is no replyAdapter - the reply from the Mats endpoint is directly fed back (as "resolved") to the MatsSocket.

MatsSocketEnvelopeDto() - Constructor for class io.mats3.matssocket.MatsSocketServer.MatsSocketEnvelopeDto

MatsSocketEnvelopeDto_Mixin() - Constructor for class io.mats3.matssocket.impl.MatsSocketStatics.MatsSocketEnvelopeDto_Mixin

MatsSocketEnvelopeWithMetaDto() - Constructor for class io.mats3.matssocket.MatsSocketServer.MatsSocketEnvelopeWithMetaDto

MatsSocketServer - Interface in io.mats3.matssocket

The MatsSocket Java library, along with its several clients libraries, is a WebSocket-"extension" of the Mats library (there are currently clients for JavaScript (web and Node.js) and Dart (Dart and Flutter)).

MatsSocketServer.ActiveMatsSocketSession - Interface in io.mats3.matssocket

Represents an active node-local MatsSocketSession - i.e.

MatsSocketServer.ActiveMatsSocketSession.MatsSocketSessionState - Enum Class in io.mats3.matssocket

The state of ActiveMatsSocketSession.

MatsSocketServer.ActiveMatsSocketSessionDto - Class in io.mats3.matssocket

Implementation of MatsSocketServer.ActiveMatsSocketSession, which is serializable both for MatsSocket and Mats, i.e.

MatsSocketServer.DataStoreException - Exception in io.mats3.matssocket

RuntimeException raised from methods which directly interfaces with the ClusterStoreAndForward and which cannot "hide" the situation if the data store doesn't work.

MatsSocketServer.IncomingAuthorizationAndAdapter<I,MR,R> - Interface in io.mats3.matssocket

Should handle Authorization evaluation on the supplied Principal and decide whether this message should be forwarded to the Mats fabric (or directly resolved, rejected or denied).

MatsSocketServer.LiveMatsSocketSession - Interface in io.mats3.matssocket

A live representation of a MatsSocketSession.

MatsSocketServer.MatsSocketCloseCodes - Enum Class in io.mats3.matssocket

WebSocket CloseCodes used in MatsSocket, and for what.

MatsSocketServer.MatsSocketEndpoint<I,MR,R> - Interface in io.mats3.matssocket

Representation of a MatsSocketEndpoint.

MatsSocketServer.MatsSocketEndpointContext<I,MR,R> - Interface in io.mats3.matssocket

Root for both MatsSocketServer.MatsSocketEndpointIncomingContext and MatsSocketServer.MatsSocketEndpointReplyContext.

MatsSocketServer.MatsSocketEndpointIncomingContext<I,MR,R> - Interface in io.mats3.matssocket

The context which the MatsSocketServer.IncomingAuthorizationAndAdapter gets to work with when handling an incoming MatsSocket message.

MatsSocketServer.MatsSocketEndpointReplyContext<I,MR,R> - Interface in io.mats3.matssocket

MatsSocketServer.MatsSocketEnvelopeDto - Class in io.mats3.matssocket

This is the entire "Wire transport" DTO of MatsSocket.

MatsSocketServer.MatsSocketEnvelopeDto.DebugDto - Class in io.mats3.matssocket

MatsSocketServer.MatsSocketEnvelopeDto.LogLineDto - Class in io.mats3.matssocket

MatsSocketServer.MatsSocketEnvelopeWithMetaDto - Class in io.mats3.matssocket

Extension of MatsSocketServer.MatsSocketEnvelopeDto which carries some metadata about the processing of the Envelope.

MatsSocketServer.MatsSocketEnvelopeWithMetaDto.Direction - Enum Class in io.mats3.matssocket

Only used for when the MatsSocketEnvelopeDto is exposed via the MatsSocket API - contains "meta-meta" about the processing of the envelope

MatsSocketServer.MatsSocketEnvelopeWithMetaDto.IncomingResolution - Enum Class in io.mats3.matssocket

Only used for when the MatsSocketEnvelopeDto is exposed via the MatsSocket API - contains "meta-meta" about the processing of the envelope

MatsSocketServer.MatsSocketSession - Interface in io.mats3.matssocket

A MatsSocketSession, either as represented in the data store when gotten via MatsSocketServer.getMatsSocketSessions(boolean, String, String, String) (returning MatsSocketSessionDto), or an ActiveMatsSocketSession representing an active MatsSocketSession connected to this node of the MatsSocketServer instance when gotten via MatsSocketServer.getActiveMatsSocketSessions() (returning ActiveMatsSocketSessionDto), or a LiveMatsSocketSession which is an interface view over the actual live session in the MatsSocketServer when gotten via MatsSocketServer.getLiveMatsSocketSessions().

MatsSocketServer.MatsSocketSessionDto - Class in io.mats3.matssocket

Implementation of MatsSocketServer.MatsSocketSession, which is serializable both for MatsSocket and Mats, i.e.

MatsSocketServer.MessageEvent - Interface in io.mats3.matssocket

MatsSocketServer.MessageEventListener - Interface in io.mats3.matssocket

MatsSocketServer.MessageType - Enum Class in io.mats3.matssocket

All Message Types (aka MatsSocket Envelope Types) used in the wire-protocol of MatsSocket.

MatsSocketServer.ReplyAdapter<I,MR,R> - Interface in io.mats3.matssocket

Used to transform the reply message from the Mats endpoint to the reply for the MatsSocket endpoint, and decide whether to resolve or reject the waiting Client-side Promise (i.e.

MatsSocketServer.SessionEstablishedEvent - Interface in io.mats3.matssocket

MatsSocketServer.SessionEstablishedEvent.SessionEstablishedEventType - Enum Class in io.mats3.matssocket

MatsSocketServer.SessionEstablishedEventListener - Interface in io.mats3.matssocket

MatsSocketServer.SessionRemovedEvent - Interface in io.mats3.matssocket

MatsSocketServer.SessionRemovedEvent.SessionRemovedEventType - Enum Class in io.mats3.matssocket

Type of "remove": Either DEREGISTER, CLOSE or TIMEOUT.

MatsSocketServer.SessionRemovedEventListener - Interface in io.mats3.matssocket

MatsSocketSessionDto() - Constructor for class io.mats3.matssocket.MatsSocketServer.MatsSocketSessionDto

MatsSocketStatics - Interface in io.mats3.matssocket.impl

MatsSocketStatics.DebugStackTrace - Exception in io.mats3.matssocket.impl

MatsSocketStatics.DirectJson - Class in io.mats3.matssocket.impl

If the MatsSocketServer.MatsSocketEnvelopeDto.msg-field is of this magic type, the String it contains - which then needs to be proper JSON - will be output directly.

MatsSocketStatics.DirectJsonMessageHandlingDeserializer - Class in io.mats3.matssocket.impl

A MatsSocketServer.MatsSocketEnvelopeWithMetaDto will be Serialized (made into object) with the "msg" field handled specially: If it is any other class than MatsSocketStatics.DirectJson, default handling ensues (JSON object serialization) - but if it this particular class, it will output the (JSON) String it contains directly.

MatsSocketStatics.MatsSocketEnvelopeDto_Mixin - Class in io.mats3.matssocket.impl

MatsSocketStatics.MessageToStringDeserializer - Class in io.mats3.matssocket.impl

A MatsSocketServer.MatsSocketEnvelopeWithMetaDto will be Deserialized (made into object) with the "msg" field directly to the JSON that is present there (i.e.

MatsSocketStatics.SocketSendIOException - Exception in io.mats3.matssocket.impl

When trying to send messages over WebSocket and get an IOException, we do not have many options of handling - the socket has probably closed.

matsSocketTerminator(String, Class, MatsSocketServer.IncomingAuthorizationAndAdapter<I, Void, Void>) - Method in interface io.mats3.matssocket.MatsSocketServer

(Convenience-variant of the base method) Registers a MatsSocket Terminator (no reply), specifically for Client-to-Server "SEND", and to accept a "REPLY" from a Server-to-Client "REQUEST".

MAX_FORWARDER_POOL_SIZE - Static variable in interface io.mats3.matssocket.impl.MatsSocketStatics

MAX_LENGTH_OF_TOPIC_NAME - Static variable in interface io.mats3.matssocket.impl.MatsSocketStatics

MAX_NUMBER_OF_COMPENSATING_TRANSACTIONS_ATTEMPTS - Static variable in interface io.mats3.matssocket.impl.MatsSocketStatics

MAX_NUMBER_OF_HELD_ENVELOPES_PER_SESSION - Static variable in interface io.mats3.matssocket.impl.MatsSocketStatics

MAX_NUMBER_OF_MESSAGES_PER_FORWARD_LOOP - Static variable in interface io.mats3.matssocket.impl.MatsSocketStatics

MAX_NUMBER_OF_OUTBOX_STORE_ATTEMPTS_CSAF - Static variable in interface io.mats3.matssocket.impl.MatsSocketStatics

MAX_NUMBER_OF_RECORDED_ENVELOPES_PER_SESSION - Static variable in interface io.mats3.matssocket.impl.MatsSocketStatics

MAX_NUMBER_OF_REDELIVERY_ATTEMPTS - Static variable in interface io.mats3.matssocket.impl.MatsSocketStatics

MAX_NUMBER_OF_SESSIONS_PER_USER_ID - Static variable in interface io.mats3.matssocket.impl.MatsSocketStatics

MAX_NUMBER_OF_TOPICS_PER_SESSION - Static variable in interface io.mats3.matssocket.impl.MatsSocketStatics

MAX_SIZE_OF_HELD_ENVELOPE_MSGS - Static variable in interface io.mats3.matssocket.impl.MatsSocketStatics

mdc - Variable in class io.mats3.matssocket.MatsSocketServer.MatsSocketEnvelopeDto.LogLineDto

MDC_CLIENT_APP_NAME_AND_VERSION - Static variable in interface io.mats3.matssocket.impl.MatsSocketStatics

MDC_CLIENT_LIB_AND_VERSIONS - Static variable in interface io.mats3.matssocket.impl.MatsSocketStatics

MDC_CMID - Static variable in interface io.mats3.matssocket.impl.MatsSocketStatics

MDC_MESSAGE_TYPE - Static variable in interface io.mats3.matssocket.impl.MatsSocketStatics

MDC_PRINCIPAL_NAME - Static variable in interface io.mats3.matssocket.impl.MatsSocketStatics

MDC_SESSION_ID - Static variable in interface io.mats3.matssocket.impl.MatsSocketStatics

MDC_SMID - Static variable in interface io.mats3.matssocket.impl.MatsSocketStatics

MDC_TRACE_ID - Static variable in interface io.mats3.matssocket.impl.MatsSocketStatics

MDC_USER_ID - Static variable in interface io.mats3.matssocket.impl.MatsSocketStatics

MessageIdAlreadyExistsException(String, Throwable) - Constructor for exception io.mats3.matssocket.ClusterStoreAndForward.MessageIdAlreadyExistsException

messagesProcessed(MatsSocketServer.MessageEvent) - Method in interface io.mats3.matssocket.MatsSocketServer.MessageEventListener

MessageToStringDeserializer() - Constructor for class io.mats3.matssocket.impl.MatsSocketStatics.MessageToStringDeserializer

migrateUsingFlyway(DataSource) - Method in class io.mats3.matssocket.impl.ClusterStoreAndForward_SQL_DbMigrations

Perform migrations using Flyway, getting the placeholder (interpolated values for "texttype" and "binarytype") from ClusterStoreAndForward_SQL_DbMigrations.getPlaceHolders(), and the migration scrips from ClusterStoreAndForward_SQL_DbMigrations.getMigrationsLocation().

MILLIS_BETWEEN_COMPENSATING_TRANSACTIONS_ATTEMPTS - Static variable in interface io.mats3.matssocket.impl.MatsSocketStatics

MILLIS_BETWEEN_LIVELINESS_UPDATE_RUN - Static variable in interface io.mats3.matssocket.impl.MatsSocketStatics

MILLIS_BETWEEN_SCAVENGE_SESSION_REMNANTS_RUN - Static variable in interface io.mats3.matssocket.impl.MatsSocketStatics

MILLIS_BETWEEN_SESSION_TIMEOUT_RUN - Static variable in interface io.mats3.matssocket.impl.MatsSocketStatics

MILLIS_SESSION_TIMEOUT_SUPPLIER - Static variable in interface io.mats3.matssocket.impl.MatsSocketStatics

MIN_FORWARDER_POOL_SIZE - Static variable in interface io.mats3.matssocket.impl.MatsSocketStatics

mmrrnn - Variable in class io.mats3.matssocket.MatsSocketServer.MatsSocketEnvelopeDto.DebugDto

mmrrts - Variable in class io.mats3.matssocket.MatsSocketServer.MatsSocketEnvelopeDto.DebugDto

mmsts - Variable in class io.mats3.matssocket.MatsSocketServer.MatsSocketEnvelopeDto.DebugDto

ms(long) - Method in interface io.mats3.matssocket.impl.MatsSocketStatics

MS_SQL - Enum constant in enum class io.mats3.matssocket.impl.ClusterStoreAndForward_SQL_DbMigrations.Database

Default: MS SQL: NVARCHAR(MAX), VARBINARY(MAX) (NOTE: H2 also handles these).

MS_SQL_2019_UTF8 - Enum constant in enum class io.mats3.matssocket.impl.ClusterStoreAndForward_SQL_DbMigrations.Database

MS SQL 2019 and above: (assumes UTF-8 collation type) VARCHAR(MAX), VARBINARY(MAX) (NOTE: H2 also handles these).

mscnn - Variable in class io.mats3.matssocket.MatsSocketServer.MatsSocketEnvelopeDto.DebugDto

mscts - Variable in class io.mats3.matssocket.MatsSocketServer.MatsSocketEnvelopeDto.DebugDto

msg - Variable in class io.mats3.matssocket.impl.MatsSocketStatics.MatsSocketEnvelopeDto_Mixin

msg - Variable in class io.mats3.matssocket.MatsSocketServer.MatsSocketEnvelopeDto

msgs - Variable in class io.mats3.matssocket.MatsSocketServer.ActiveMatsSocketSessionDto

msSince(long) - Method in interface io.mats3.matssocket.impl.MatsSocketStatics

MYSQL - Enum constant in enum class io.mats3.matssocket.impl.ClusterStoreAndForward_SQL_DbMigrations.Database

MySQL / MariaDB: LONGTEXT, LONGBLOB (both 32 bits)

N

NACK - Enum constant in enum class io.mats3.matssocket.MatsSocketServer.MessageType

The specified message was Received, but it did not acknowledge it - i.e.

NEW - Enum constant in enum class io.mats3.matssocket.MatsSocketServer.SessionEstablishedEvent.SessionEstablishedEventType

newSessionAuthenticator() - Method in interface io.mats3.matssocket.AuthenticationPlugin

Invoked by the MatsSocketServer upon each WebSocket connection that wants to establish a MatsSocket - that is, you may provide a connections-specific instance per connection.

nn - Variable in class io.mats3.matssocket.MatsSocketServer.MatsSocketEnvelopeWithMetaDto

nn - Variable in class io.mats3.matssocket.MatsSocketServer.MatsSocketSessionDto

NO_ACTION - Enum constant in enum class io.mats3.matssocket.MatsSocketServer.MatsSocketEnvelopeWithMetaDto.IncomingResolution

IncomingHandler did no action wrt.

NO_SESSION - Enum constant in enum class io.mats3.matssocket.MatsSocketServer.ActiveMatsSocketSession.MatsSocketSessionState

HELLO not yet processed - only accepts messages up to HELLO.

NODES - Enum constant in enum class io.mats3.matssocket.AuthenticationPlugin.DebugOption

Node-name of the handling nodes of the separate phases.

notifySessionLiveliness(Collection<String>) - Method in interface io.mats3.matssocket.ClusterStoreAndForward

Shall be invoked on some kind of schedule (e.g.

notifySessionLiveliness(Collection<String>) - Method in class io.mats3.matssocket.impl.ClusterStoreAndForward_SQL

NUMBER_OF_OUTGOING_ENVELOPES_SCHEDULER_THREADS - Static variable in interface io.mats3.matssocket.impl.MatsSocketStatics

O

ocrip - Variable in class io.mats3.matssocket.MatsSocketServer.ActiveMatsSocketSessionDto

of(String) - Static method in class io.mats3.matssocket.impl.MatsSocketStatics.DirectJson

onOpen(Session, ServerEndpointConfig) - Method in interface io.mats3.matssocket.AuthenticationPlugin.SessionAuthenticator

Invoked straight after the HTTP WebSocket handshake request/response is performed, in the Endpoint.onOpen(Session, EndpointConfig) invocation from the WebSocket ServerContainer.

ORACLE - Enum constant in enum class io.mats3.matssocket.impl.ClusterStoreAndForward_SQL_DbMigrations.Database

Oracle: NCLOB, BLOB

outboxMessagesAttemptedDelivery(String, Collection<String>) - Method in interface io.mats3.matssocket.ClusterStoreAndForward

Marks the specified messages as attempted delivered and notches the ClusterStoreAndForward.StoredOutMessage.getDeliveryCount() one up.

outboxMessagesAttemptedDelivery(String, Collection<String>) - Method in class io.mats3.matssocket.impl.ClusterStoreAndForward_SQL

outboxMessagesComplete(String, Collection<String>) - Method in interface io.mats3.matssocket.ClusterStoreAndForward

States that the messages are delivered.

outboxMessagesComplete(String, Collection<String>) - Method in class io.mats3.matssocket.impl.ClusterStoreAndForward_SQL

outboxMessagesDeadLetterQueue(String, Collection<String>) - Method in interface io.mats3.matssocket.ClusterStoreAndForward

States that the messages overran the accepted number of delivery attempts.

outboxMessagesDeadLetterQueue(String, Collection<String>) - Method in class io.mats3.matssocket.impl.ClusterStoreAndForward_SQL

outboxMessagesUnmarkAttemptedDelivery(String) - Method in interface io.mats3.matssocket.ClusterStoreAndForward

When this method is invoked, ClusterStoreAndForward.getMessagesFromOutbox(String, int) will again return messages that has previously been marked as attempted delivered with ClusterStoreAndForward.outboxMessagesAttemptedDelivery(String, Collection).

outboxMessagesUnmarkAttemptedDelivery(String) - Method in class io.mats3.matssocket.impl.ClusterStoreAndForward_SQL

P

PING - Enum constant in enum class io.mats3.matssocket.MatsSocketServer.MessageType

A PING, to which a MatsSocketServer.MessageType.PONG is expected.

pn - Variable in class io.mats3.matssocket.MatsSocketServer.ActiveMatsSocketSessionDto

PONG - Enum constant in enum class io.mats3.matssocket.MatsSocketServer.MessageType

A Reply to a MatsSocketServer.MessageType.PING.

POSTGRESQL - Enum constant in enum class io.mats3.matssocket.impl.ClusterStoreAndForward_SQL_DbMigrations.Database

PostgreSQL: TEXT, BYTEA

PUB - Enum constant in enum class io.mats3.matssocket.MatsSocketServer.MessageType

Topic message from Server: A message is issued on Topic, the TopicId is specified in 'eid', while the message is in 'msg'.

publish(String, String, Object) - Method in class io.mats3.matssocket.impl.DefaultMatsSocketServer

publish(String, String, Object) - Method in interface io.mats3.matssocket.MatsSocketServer

Publish a Message to the specified Topic, with the specified TraceId.

R

rd - Variable in class io.mats3.matssocket.MatsSocketServer.MatsSocketEnvelopeDto

REAUTH - Enum constant in enum class io.mats3.matssocket.MatsSocketServer.MessageType

The server requests that the Client re-authenticates, where the Client should immediately get a fresh authentication and send it back using either any message it has pending, or in a separate MatsSocketServer.MessageType.AUTH message.

RECONNECT - Enum constant in enum class io.mats3.matssocket.MatsSocketServer.MatsSocketCloseCodes

4002: Both from Server side and from Client/Browser side: REISSUE all outstanding upon reconnect: From Client: The client just fancied a little break (just as if lost connection in a tunnel), used from integration tests. From Server: We ask that the client reconnects.

RECONNECT - Enum constant in enum class io.mats3.matssocket.MatsSocketServer.SessionEstablishedEvent.SessionEstablishedEventType

reevaluateAuthentication(AuthenticationPlugin.AuthenticationContext, String, Principal) - Method in interface io.mats3.matssocket.AuthenticationPlugin.SessionAuthenticator

Invoked on every subsequent "pipeline" of incoming messages (including every time the Client supplies a new Authorization string).

reevaluateAuthenticationForOutgoingMessage(AuthenticationPlugin.AuthenticationContext, String, Principal, long) - Method in interface io.mats3.matssocket.AuthenticationPlugin.SessionAuthenticator

This method is invoked each time the server wants to send a message to the client - either a REPLY to a request from the Client, or a Server-to-Client SEND or MatsSocketServer.request(String, String, String, Object, String, String, byte[]) REQUEST}.

registerSessionAtThisNode(String, String, String, String, String, String) - Method in interface io.mats3.matssocket.ClusterStoreAndForward

Registers a Session home to this node - only one node can ever be home, so any old is deleted.

registerSessionAtThisNode(String, String, String, String, String, String) - Method in class io.mats3.matssocket.impl.ClusterStoreAndForward_SQL

reject(R) - Method in interface io.mats3.matssocket.MatsSocketServer.MatsSocketEndpointIncomingContext

Only for REQUESTs: Send "Reject" reply (rejects the client side Promise) to the MatsSocket directly, i.e.

reject(R) - Method in interface io.mats3.matssocket.MatsSocketServer.MatsSocketEndpointReplyContext

Send "Reject" reply (rejects the client side Promise) to the MatsSocket directly, i.e.

REJECT - Enum constant in enum class io.mats3.matssocket.MatsSocketServer.MatsSocketEnvelopeWithMetaDto.IncomingResolution

For a REQUEST: The IncomingHandler "insta-settled" the request with a Reject.

REJECT - Enum constant in enum class io.mats3.matssocket.MatsSocketServer.MessageType

A REJECT-reply to a previous MatsSocketServer.MessageType.REQUEST - if the Client did the REQUEST, the Server will answer with either a REJECT or MatsSocketServer.MessageType.RESOLVE.

RemoteAddressContainerHacks - Class in io.mats3.matssocket.impl

Provides several hacks to get the Remote Address for different Servlet Containers implementing JSR 356 Java API for WebSockets, as that standard does not specify a method for it.

RemoteAddressContainerHacks() - Constructor for class io.mats3.matssocket.impl.RemoteAddressContainerHacks

removeAck(String, String) - Method in class io.mats3.matssocket.impl.WebSocketOutgoingEnvelopes

request(String, String, String, Object, String, String, byte[]) - Method in class io.mats3.matssocket.impl.DefaultMatsSocketServer

request(String, String, String, Object, String, String, byte[]) - Method in interface io.mats3.matssocket.MatsSocketServer

Initiates a request to the specified MatsSocketSession, to the specified Client EndpointId, with a replyTo specified to (typically) a MatsSocket terminator - which includes a String "correlationString" and byte array "correlationBinary" which can be used to correlate the reply to the request (available here and here for the reply processing).

REQUEST - Enum constant in enum class io.mats3.matssocket.MatsSocketServer.MessageType

The sender initiates a request, to which a MatsSocketServer.MessageType.RESOLVE or MatsSocketServer.MessageType.REJECT message is expected.

resd - Variable in class io.mats3.matssocket.MatsSocketServer.MatsSocketEnvelopeDto.DebugDto

resolve(R) - Method in interface io.mats3.matssocket.MatsSocketServer.MatsSocketEndpointIncomingContext

Only for REQUESTs: Send "Resolve" reply (resolves the client side Promise) to the MatsSocket directly, i.e.

resolve(R) - Method in interface io.mats3.matssocket.MatsSocketServer.MatsSocketEndpointReplyContext

Send "Resolve" reply (resolves the client side Promise) to the MatsSocket directly, i.e.

RESOLVE - Enum constant in enum class io.mats3.matssocket.MatsSocketServer.MatsSocketEnvelopeWithMetaDto.IncomingResolution

For a REQUEST: The IncomingHandler "insta-settled" the request with a Resolve.

RESOLVE - Enum constant in enum class io.mats3.matssocket.MatsSocketServer.MessageType

A RESOLVE-reply to a previous MatsSocketServer.MessageType.REQUEST - if the Client did the REQUEST, the Server will answer with either a RESOLVE or MatsSocketServer.MessageType.REJECT.

RETRY - Enum constant in enum class io.mats3.matssocket.MatsSocketServer.MessageType

The sender should retry the message (the receiver could not handle it right now, but a Retry might fix it).

rip - Variable in class io.mats3.matssocket.MatsSocketServer.ActiveMatsSocketSessionDto

rm - Variable in class io.mats3.matssocket.MatsSocketServer.MatsSocketEnvelopeWithMetaDto

rttm - Variable in class io.mats3.matssocket.MatsSocketServer.MatsSocketEnvelopeWithMetaDto

S

s - Variable in class io.mats3.matssocket.MatsSocketServer.MatsSocketEnvelopeDto.LogLineDto

S2C - Enum constant in enum class io.mats3.matssocket.MatsSocketServer.MatsSocketEnvelopeWithMetaDto.Direction

Server-to-Client.

SaneThreadPoolExecutor - Class in io.mats3.matssocket.impl

Trick to make ThreadPoolExecutor work as anyone in the world would expect: Have a constant pool of "corePoolSize", and then as more tasks are concurrently running than threads available, you increase the number of threads until "maxPoolSize", at which point the rest go on queue.

scavengeSessionRemnants() - Method in interface io.mats3.matssocket.ClusterStoreAndForward

Shall be invoked on some kind of schedule (e.g.

scavengeSessionRemnants() - Method in class io.mats3.matssocket.impl.ClusterStoreAndForward_SQL

scts - Variable in class io.mats3.matssocket.MatsSocketServer.MatsSocketSessionDto

send(String, String, String, Object) - Method in class io.mats3.matssocket.impl.DefaultMatsSocketServer

send(String, String, String, Object) - Method in interface io.mats3.matssocket.MatsSocketServer

Sends a message to the specified MatsSocketSession, to the specified Client TerminatorId.

SEND - Enum constant in enum class io.mats3.matssocket.MatsSocketServer.MessageType

The sender sends a "fire and forget" style message.

serialize(Object, JsonGenerator, SerializerProvider) - Method in class io.mats3.matssocket.impl.MatsSocketStatics.DirectJsonMessageHandlingDeserializer

SERVICE_RESTART - Enum constant in enum class io.mats3.matssocket.MatsSocketServer.MatsSocketCloseCodes

Standard code 1012 - From Server side, Client should REISSUE all outstanding upon reconnect: used when MatsSocketServer.stop(int) is invoked.

SESSION_ESTABLISHED - Enum constant in enum class io.mats3.matssocket.MatsSocketServer.ActiveMatsSocketSession.MatsSocketSessionState

HELLO is processed and auth verified, and we are processing all kinds of messages.

SESSION_LOST - Enum constant in enum class io.mats3.matssocket.MatsSocketServer.MatsSocketCloseCodes

4001: From Server side, Client should REJECT all outstanding and "crash"/reboot application: A HELLO:RECONNECT was attempted, but the session was gone.

sessionEstablished(MatsSocketServer.SessionEstablishedEvent) - Method in interface io.mats3.matssocket.MatsSocketServer.SessionEstablishedEventListener

sessionRemoved(MatsSocketServer.SessionRemovedEvent) - Method in interface io.mats3.matssocket.MatsSocketServer.SessionRemovedEventListener

setOriginatingRemoteAddr(String) - Method in interface io.mats3.matssocket.AuthenticationPlugin.AuthenticationContext

Sets the Originating Remote Address, as exposed via MatsSocketServer.ActiveMatsSocketSession.getOriginatingRemoteAddr() - read that JavaDoc.

setRemoteAddr(String) - Method in interface io.mats3.matssocket.AuthenticationPlugin.AuthenticationContext

Sets (or overrides) the Remote Address, as exposed via MatsSocketServer.ActiveMatsSocketSession.getRemoteAddr() - read that JavaDoc, in particular that if this server is behind a proxy, this will be the proxy's address.

sets - Variable in class io.mats3.matssocket.MatsSocketServer.ActiveMatsSocketSessionDto

setTextAndBinaryTypes(ClusterStoreAndForward_SQL_DbMigrations.Database) - Method in class io.mats3.matssocket.impl.ClusterStoreAndForward_SQL_DbMigrations

setTextAndBinaryTypes(String, String) - Method in class io.mats3.matssocket.impl.ClusterStoreAndForward_SQL_DbMigrations

shutdownNice(int) - Method in class io.mats3.matssocket.impl.SaneThreadPoolExecutor

sid - Variable in class io.mats3.matssocket.MatsSocketServer.MatsSocketEnvelopeDto

SimpleCurrentNode(String, String) - Constructor for class io.mats3.matssocket.ClusterStoreAndForward.SimpleCurrentNode

SimpleRequestCorrelation(String, String, long, String, String, byte[]) - Constructor for class io.mats3.matssocket.ClusterStoreAndForward.SimpleRequestCorrelation

SimpleStoredInMessage(String, String, long, String, byte[]) - Constructor for class io.mats3.matssocket.ClusterStoreAndForward.SimpleStoredInMessage

SimpleStoredOutMessage(String, String, String, MatsSocketServer.MessageType, String, Long, long, Long, int, String, String, byte[]) - Constructor for class io.mats3.matssocket.ClusterStoreAndForward.SimpleStoredOutMessage

slts - Variable in class io.mats3.matssocket.MatsSocketServer.MatsSocketSessionDto

smcnn - Variable in class io.mats3.matssocket.MatsSocketServer.MatsSocketEnvelopeDto.DebugDto

smcts - Variable in class io.mats3.matssocket.MatsSocketServer.MatsSocketEnvelopeDto.DebugDto

smid - Variable in class io.mats3.matssocket.MatsSocketServer.MatsSocketEnvelopeDto

SocketSendIOException(IOException) - Constructor for exception io.mats3.matssocket.impl.MatsSocketStatics.SocketSendIOException

stillValid() - Method in interface io.mats3.matssocket.AuthenticationPlugin.AuthenticationContext

Existing Authentication is still good! Return the result from this method from AuthenticationPlugin.SessionAuthenticator.reevaluateAuthentication(AuthenticationContext, String, Principal) if the 'existingPrincipal' (and implicitly the userId) is still good to go.

stop(int) - Method in class io.mats3.matssocket.impl.DefaultMatsSocketServer

stop(int) - Method in interface io.mats3.matssocket.MatsSocketServer

Closes all MatsSocketServer.ActiveMatsSocketSession on this node, closing the WebSocket with CloseReason.CloseCodes.SERVICE_RESTART (assuming that a MatsSocket service will never truly go down, thus effectively asking the client to reconnect, hopefully to another instance).

storeMessageIdInInbox(String, String) - Method in interface io.mats3.matssocket.ClusterStoreAndForward

Stores the incoming message Id, to avoid double delivery.

storeMessageIdInInbox(String, String) - Method in class io.mats3.matssocket.impl.ClusterStoreAndForward_SQL

storeMessageInOutbox(String, String, String, String, MatsSocketServer.MessageType, Long, String, String, byte[]) - Method in interface io.mats3.matssocket.ClusterStoreAndForward

Stores the message for the Session, returning the nodename for the node holding the session, if any.

storeMessageInOutbox(String, String, String, String, MatsSocketServer.MessageType, Long, String, String, byte[]) - Method in class io.mats3.matssocket.impl.ClusterStoreAndForward_SQL

storeRequestCorrelation(String, String, long, String, String, byte[]) - Method in interface io.mats3.matssocket.ClusterStoreAndForward

storeRequestCorrelation(String, String, long, String, String, byte[]) - Method in class io.mats3.matssocket.impl.ClusterStoreAndForward_SQL

SUB - Enum constant in enum class io.mats3.matssocket.MatsSocketServer.MessageType

Request from Client: The Client want to subscribe to a Topic, the TopicId is specified in 'eid'.

SUB_LOST - Enum constant in enum class io.mats3.matssocket.MatsSocketServer.MessageType

Reply from Server: Subscription went OK, but you've lost messages: The messageId that was referenced in the MatsSocketServer.MessageType.SUB was not known to the server, implying that there are at least one message that has expired, but we don't know whether it was 1 or 1 million - so you won't get any of them "replayed".

SUB_NO_AUTH - Enum constant in enum class io.mats3.matssocket.MatsSocketServer.MessageType

Reply from Server: Subscription was not authorized - no messages for this Topic will be delivered.

SUB_OK - Enum constant in enum class io.mats3.matssocket.MatsSocketServer.MessageType

Reply from Server: Subscription was OK.

subs - Variable in class io.mats3.matssocket.MatsSocketServer.ActiveMatsSocketSessionDto

T

t - Variable in class io.mats3.matssocket.MatsSocketServer.MatsSocketEnvelopeDto.LogLineDto

t - Variable in class io.mats3.matssocket.MatsSocketServer.MatsSocketEnvelopeDto

THREAD_PREFIX - Static variable in interface io.mats3.matssocket.impl.MatsSocketStatics

tid - Variable in class io.mats3.matssocket.MatsSocketServer.MatsSocketEnvelopeDto

TIMEOUT - Enum constant in enum class io.mats3.matssocket.MatsSocketServer.SessionRemovedEvent.SessionRemovedEventType

The MatsSocketSession was previously MatsSocketServer.SessionRemovedEvent.SessionRemovedEventType.DEREGISTER, but was now "cleaned out" by the timeouter.

timeoutSessions(long) - Method in interface io.mats3.matssocket.ClusterStoreAndForward

Shall be invoked on some kind of schedule (e.g.

timeoutSessions(long) - Method in class io.mats3.matssocket.impl.ClusterStoreAndForward_SQL

TIMESTAMPS - Enum constant in enum class io.mats3.matssocket.AuthenticationPlugin.DebugOption

Timestamp info for the separate phases.

to - Variable in class io.mats3.matssocket.MatsSocketServer.MatsSocketEnvelopeDto

toActiveMatsSocketSession() - Method in interface io.mats3.matssocket.MatsSocketServer.LiveMatsSocketSession

toString() - Method in class io.mats3.matssocket.MatsSocketServer.MatsSocketEnvelopeDto

ts - Variable in class io.mats3.matssocket.MatsSocketServer.MatsSocketEnvelopeDto.LogLineDto

ts - Variable in class io.mats3.matssocket.MatsSocketServer.MatsSocketEnvelopeWithMetaDto

U

uid - Variable in class io.mats3.matssocket.MatsSocketServer.MatsSocketSessionDto

UNEXPECTED_CONDITION - Enum constant in enum class io.mats3.matssocket.MatsSocketServer.MatsSocketCloseCodes

Standard code 1011 - From Server side, Client should REJECT all outstanding and "crash"/reboot application.

UNSUB - Enum constant in enum class io.mats3.matssocket.MatsSocketServer.MessageType

Request from Client: The Client want to unsubscribe from a Topic, the TopicId is specified in 'eid'.

updateMessageInInbox(String, String, String, byte[]) - Method in interface io.mats3.matssocket.ClusterStoreAndForward

Stores the resulting message (envelope and binary), so that if the incoming messages comes again (based on ClusterStoreAndForward.storeMessageIdInInbox(String, String) throwing ClusterStoreAndForward.MessageIdAlreadyExistsException), the result from the previous processing can be returned right away.

updateMessageInInbox(String, String, String, byte[]) - Method in class io.mats3.matssocket.impl.ClusterStoreAndForward_SQL

V

valueOf(String) - Static method in enum class io.mats3.matssocket.AuthenticationPlugin.DebugOption

Returns the enum constant of this class with the specified name.

valueOf(String) - Static method in enum class io.mats3.matssocket.impl.ClusterStoreAndForward_SQL_DbMigrations.Database

Returns the enum constant of this class with the specified name.

valueOf(String) - Static method in enum class io.mats3.matssocket.MatsSocketServer.ActiveMatsSocketSession.MatsSocketSessionState

Returns the enum constant of this class with the specified name.

valueOf(String) - Static method in enum class io.mats3.matssocket.MatsSocketServer.MatsSocketCloseCodes

Returns the enum constant of this class with the specified name.

valueOf(String) - Static method in enum class io.mats3.matssocket.MatsSocketServer.MatsSocketEnvelopeWithMetaDto.Direction

Returns the enum constant of this class with the specified name.

valueOf(String) - Static method in enum class io.mats3.matssocket.MatsSocketServer.MatsSocketEnvelopeWithMetaDto.IncomingResolution

Returns the enum constant of this class with the specified name.

valueOf(String) - Static method in enum class io.mats3.matssocket.MatsSocketServer.MessageType

Returns the enum constant of this class with the specified name.

valueOf(String) - Static method in enum class io.mats3.matssocket.MatsSocketServer.SessionEstablishedEvent.SessionEstablishedEventType

Returns the enum constant of this class with the specified name.

valueOf(String) - Static method in enum class io.mats3.matssocket.MatsSocketServer.SessionRemovedEvent.SessionRemovedEventType

Returns the enum constant of this class with the specified name.

values() - Static method in enum class io.mats3.matssocket.AuthenticationPlugin.DebugOption

Returns an array containing the constants of this enum class, in the order they are declared.

values() - Static method in enum class io.mats3.matssocket.impl.ClusterStoreAndForward_SQL_DbMigrations.Database

Returns an array containing the constants of this enum class, in the order they are declared.

values() - Static method in enum class io.mats3.matssocket.MatsSocketServer.ActiveMatsSocketSession.MatsSocketSessionState

Returns an array containing the constants of this enum class, in the order they are declared.

values() - Static method in enum class io.mats3.matssocket.MatsSocketServer.MatsSocketCloseCodes

Returns an array containing the constants of this enum class, in the order they are declared.

values() - Static method in enum class io.mats3.matssocket.MatsSocketServer.MatsSocketEnvelopeWithMetaDto.Direction

Returns an array containing the constants of this enum class, in the order they are declared.

values() - Static method in enum class io.mats3.matssocket.MatsSocketServer.MatsSocketEnvelopeWithMetaDto.IncomingResolution

Returns an array containing the constants of this enum class, in the order they are declared.

values() - Static method in enum class io.mats3.matssocket.MatsSocketServer.MessageType

Returns an array containing the constants of this enum class, in the order they are declared.

values() - Static method in enum class io.mats3.matssocket.MatsSocketServer.SessionEstablishedEvent.SessionEstablishedEventType

Returns an array containing the constants of this enum class, in the order they are declared.

values() - Static method in enum class io.mats3.matssocket.MatsSocketServer.SessionRemovedEvent.SessionRemovedEventType

Returns an array containing the constants of this enum class, in the order they are declared.

VIOLATED_POLICY - Enum constant in enum class io.mats3.matssocket.MatsSocketServer.MatsSocketCloseCodes

Standard code 1008 - From Server side, Client should REJECT all outstanding and "crash"/reboot application: used when we cannot authenticate.

W

WebSocketOutgoingEnvelopes - Class in io.mats3.matssocket.impl

Handles async sending of not-"information bearing messages", that is, messages that are idempotent.

WELCOME - Enum constant in enum class io.mats3.matssocket.MatsSocketServer.MessageType

The reply to a MatsSocketServer.MessageType.HELLO, where the MatsSocketSession is established, and the MatsSocketSessionId is returned.

WrongUserException(String) - Constructor for exception io.mats3.matssocket.ClusterStoreAndForward.WrongUserException

X

x - Variable in class io.mats3.matssocket.MatsSocketServer.MatsSocketEnvelopeDto.LogLineDto

x - Variable in class io.mats3.matssocket.MatsSocketServer.MatsSocketEnvelopeDto

_

_binaryType - Variable in class io.mats3.matssocket.impl.ClusterStoreAndForward_SQL_DbMigrations

_textType - Variable in class io.mats3.matssocket.impl.ClusterStoreAndForward_SQL_DbMigrations

A B C D E F G H I J L M N O P R S T U V W X _
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form