p2p/protocol/stomp library
STOMP (Simple Text Oriented Messaging Protocol) implementation for libp2p.
This package provides a STOMP 1.2 protocol implementation that allows libp2p peers to communicate using the STOMP messaging protocol.
STOMP is a simple interoperable protocol designed for asynchronous message passing between clients via mediating servers. It defines a text based wire-format for messages passed between these clients and servers.
This is an implementation of the STOMP 1.2 specification adapted for libp2p peer-to-peer communication.
Classes
- PendingAck
- Pending acknowledgment for a message
- StompAckManager
- Manager for pending message acknowledgments
- StompClient
- STOMP client for connecting to STOMP servers over libp2p
- StompCommands
- STOMP frame commands
- StompConstants
- STOMP protocol constants
- StompEscaping
- STOMP escape sequences for header values
- StompFrame
- Represents a STOMP frame with command, headers, and body
- StompFrameFactory
- Factory methods for creating common STOMP frames
- StompFrameParser
- Parser for STOMP frames
- StompFrameSerializer
- Serializer for STOMP frames
- StompFrameValidator
- Validator for STOMP frames
- StompHeaders
- STOMP header names
- StompMessage
- Represents a STOMP message received from a subscription
- StompProtocols
- Constants for the STOMP protocol implementation. Protocol IDs for STOMP
- StompServer
- STOMP server for handling client connections over libp2p
- StompServerConnection
- Represents a client connection to the STOMP server
- StompService
- STOMP service that provides both client and server functionality for libp2p
- StompServiceFactory
- Helper class for creating STOMP services with common configurations
- StompServiceOptions
- Configuration options for the STOMP service
- StompServiceStats
- Statistics about the STOMP service
- StompSubscription
- Represents a STOMP subscription
- StompSubscriptionManager
- Manager for STOMP subscriptions
- StompTransaction
- Represents a STOMP transaction
- StompTransactionFrameFactory
- Helper for creating transaction-related frames
- StompTransactionManager
- Manager for STOMP transactions
- StompTransactionStats
- Transaction statistics
- StompTransactionTimeoutManager
- Transaction timeout manager
- StompUtils
- Utility functions for STOMP
Enums
- StompAckMode
- Acknowledgment modes for STOMP subscriptions
- StompClientState
- STOMP client connection state
- StompDestinationType
- Types of STOMP destinations
- StompServerConnectionState
- STOMP server connection state
- StompTransactionState
- Transaction state for tracking
Extensions
- StompHostExtension on Host
- Extension methods for Host to easily add STOMP functionality
Exceptions / Errors
- StompAckException
- Exception thrown when STOMP message acknowledgment fails
- StompAuthenticationException
- Exception thrown when STOMP authentication fails
- StompConnectionException
- Exception thrown when STOMP connection fails
- StompDestinationException
- Exception thrown when STOMP destination is invalid
- StompException
- STOMP protocol exceptions and error handling. Base exception for all STOMP-related errors
- StompFrameException
- Exception thrown when a STOMP frame is malformed
- StompFrameSizeException
- Exception thrown when STOMP frame size limits are exceeded
- StompHeartBeatException
- Exception thrown when STOMP heart-beat fails
- StompProtocolException
- Exception thrown when STOMP protocol negotiation fails
- StompSendException
- Exception thrown when STOMP message sending fails
- StompServerErrorException
- Exception thrown when STOMP server sends an ERROR frame
- StompStateException
- Exception thrown when STOMP state is invalid for the requested operation
- StompSubscriptionException
- Exception thrown when a STOMP subscription operation fails
- StompTimeoutException
- Exception thrown when STOMP timeout occurs
- StompTransactionException
- Exception thrown when a STOMP transaction operation fails