Generic support for simple messaging protocols (like STOMP).
ClassDescriptionAn extension of
StompDecoderthat buffers content remaining in the input ByteBuffer after the parent class has read all (complete) STOMP frames from it.Raised when the connection for a STOMP session is lost rather than closed.Default implementation of
MessageHandlerthat handles messages by forwarding them to a STOMP broker.Contract for access to session counters.Base class for STOMP client implementations.Represents a STOMP command.Raised after a failure to encode or decode a STOMP message.Decodes one or more STOMP frames contained in a
ByteBuffer.An encoder for STOMP frames.Contract to handle a STOMP frame.A
MessageHeaderAccessorto use when creating a
Messagefrom a decoded STOMP frame, or when encoding a
Messageto a STOMP frame.Represents STOMP frame headers.Simple delegation to StompDecoder and StompEncoder.Represents a STOMP session with operations to send messages, create subscriptions and receive messages on those subscriptions.A handle to use to track receipts.A handle to use to unsubscribe or to track a receipt.A contract for client STOMP session lifecycle events including a callback when the session is established and notifications of transport or message handling failures.Abstract adapter class for
StompSessionHandlerwith mostly empty implementation methods except for
StompSessionHandlerAdapter.getPayloadType(org.springframework.messaging.simp.stomp.StompHeaders)which returns String as the default Object type expected for STOMP ERROR frame payloads.A
TcpConnectionHandlerfor use with STOMP connections, exposing further information about the connection.