stompserver

Feb 8, 2026

Changes in this version

+ const CookieNameSession

+ const HeaderConnection

+ const HeaderUpgrade

+ const HeaderUpgradeValue

+ const HeaderXSessionID

+ const LogBlockedIPAttempted

+ const LogWebSocketClosed

+ const LogWebSocketConnection

+ const LogWebSocketFailed

+ const StatusMessageTooManyRequests

+ type IPBlockingChecker interface

+ ExtractRealIP func(remoteAddr string, headers map[string][]string) string

+ IsIPBlocked func(ip string) (bool, string)

+ TrackConnection func(ip string, sessionID string)

+ TrackDisconnection func(ip string, sessionID string)

Aug 20, 2025

Changes in this version

+ type IPBlockCheckHandler func(ip string) (blocked bool, errorMessage string)

type RawConnection

+ GetRemoteAddr func() string

type StompConn

+ GetIPAddress func() string

type StompServer

+ CloseConnectionsByIP func(ip string, errorMessage string)

+ SetIPBlockChecker func(checker IPBlockCheckHandler)

type WebSocketStompConnection

+ func (c *WebSocketStompConnection) GetRemoteAddr() string

Feb 10, 2025

Changes in this version

+ type AuthInfo struct

+ Id int

+ Roles []string

+ Username string

+ func (a *AuthInfo) HasRole(role string) bool

+ type Connection struct

+ Source string

+ type FrameHandlerFunc func(conn StompConn, f *frame.Frame) error

+ func ChainCommandMiddleware(reg MiddlewareRegistry, command string, coreHandler FrameHandlerFunc) FrameHandlerFunc

+ func ChainMiddleware(mws []MiddlewareFunc, final FrameHandlerFunc) FrameHandlerFunc

+ type MiddlewareFunc func(FrameHandlerFunc) FrameHandlerFunc

+ func AuthzMiddleware(action string) MiddlewareFunc

+ type MiddlewareRegistry map[string][]MiddlewareFunc

+ type RawConnResult struct

+ Conn RawConnection

+ Err error

type RawConnectionListener

+ GetConnectionCloseChannel func() chan *Connection

+ GetConnectionOpenChannel func() chan *Connection

type StompConfig

+ GetMiddlewareRegistry func() MiddlewareRegistry

+ SetMiddlewareRegistry func(registry MiddlewareRegistry)

type StompConn

+ GetEventsChannel func() chan *ConnEvent

+ GetSubscriptions func() map[string]*Subscription

+ SendError func(err error)

+ SendMessage func(msg string)

+ type Subscription struct

+ type WebSocketStompConnection struct

+ WSCon *websocket.Conn

+ func (c *WebSocketStompConnection) Close() error

+ func (c *WebSocketStompConnection) ReadFrame() (*frame.Frame, error)

+ func (c *WebSocketStompConnection) SetReadDeadline(t time.Time)

+ func (c *WebSocketStompConnection) WriteFrame(f *frame.Frame) error

Feb 5, 2023

Changes in this version

+ type ApplicationRequestHandlerFunction func(destination string, message []byte, connectionId string)

+ type ConnEvent struct

+ ConnId string

+ type RawConnection interface

+ Close func() error

+ ReadFrame func() (*frame.Frame, error)

+ SetReadDeadline func(t time.Time)

+ WriteFrame func(frame *frame.Frame) error

+ type RawConnectionListener interface

+ Accept func() (RawConnection, error)

+ Close func() error

+ func NewTcpConnectionListener(addr string) (RawConnectionListener, error)

+ func NewWebSocketConnectionFromExistingHttpServer(httpServer *http.Server, handler *mux.Router, endpoint string, ...) (RawConnectionListener, error)

+ func NewWebSocketConnectionListener(addr string, endpoint string, allowedOrigins []string) (RawConnectionListener, error)

+ type StompConfig interface

+ AppDestinationPrefix func() []string

+ HeartBeat func() int64

+ IsAppRequestDestination func(destination string) bool

+ func NewStompConfig(heartBeatMs int64, appDestinationPrefix []string) StompConfig

+ type StompConn interface

+ Close func()

+ GetId func() string

+ SendFrameToSubscription func(f *frame.Frame, sub *subscription)

+ func NewStompConn(rawConnection RawConnection, config StompConfig, events chan *ConnEvent) StompConn

+ type StompServer interface

+ OnApplicationRequest func(callback ApplicationRequestHandlerFunction)

+ OnSubscribeEvent func(callback SubscribeHandlerFunction)

+ OnUnsubscribeEvent func(callback UnsubscribeHandlerFunction)

+ SendMessage func(destination string, messageBody []byte)

+ SendMessageToClient func(connectionId string, destination string, messageBody []byte)

+ SetConnectionEventCallback func(connEventType StompSessionEventType, cb func(connEvent *ConnEvent))

+ Start func()

+ Stop func()

+ func NewStompServer(listener RawConnectionListener, config StompConfig) StompServer

+ type StompSessionEventType int

+ const ConnectionClosed

+ const ConnectionEstablished

+ const ConnectionStarting

+ const IncomingMessage

+ const SubscribeToTopic

+ const UnsubscribeFromTopic

+ type SubscribeHandlerFunction func(conId string, subId string, destination string, frame *frame.Frame)

+ type UnsubscribeHandlerFunction func(conId string, subId string, destination string)