stompserver

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)