stomp

type AckMode string

type Broker interface {
	// ListenAndServe is a blocking method that keeps accepting the client connections and handles the STOMP messages.
	ListenAndServe()

	// Shutdown should be called to bring down the underlying server gracefully.
	Shutdown()
}

type BrokerOpts struct {
	// Transport refers to the underlying protocol for STOMP.
	// Choices: TransportTCP, TransportWebsocket. Default: TransportTCP
	Transport Transport

	// Host is the name of the host or IP to bind the server to. Default: localhost
	Host string

	// Port is the port number for the server to listen on. Default: 61613 (DefaultPort)
	Port string

	// LoginFunc is a user defined function for authenticating the user. Default: nil
	// It is of the form `func(login, passcode string) error`
	LoginFunc LoginFunc

	// HeartbeatSendIntervalMsec is the interval in milliseconds by which the broker can send heartbeats.
	// The broker will negotiate using this value with the client. Default: 0 (no heartbeats)
	// It will not send the heartbeats by an interval any smaller than this value.
	HeartbeatSendIntervalMsec int

	// HeartbeatReceiveIntervalMsec is the interval in milliseconds by which the broker can receive heartbeats.
	// The broker will negotiate using this value with the client. Default: 0 (no heartbeats)
	// This is to tell the client that the broker cannot receive heartbeats by any shorter interval than this value.
	HeartbeatReceiveIntervalMsec int
}

type ClientHandler struct {
	SessionID string // Session ID for the connection with the STOMP Broker
	// contains filtered or unexported fields
}

type ClientOpts struct {
	VirtualHost              string             // Virtual host
	Login                    string             // AuthN Username
	Passcode                 string             // AuthN Password
	HeartbeatSendInterval    int                // Sending interval of heartbeats in milliseconds
	HeartbeatReceiveInterval int                // Receiving interval of heartbeats in milliseconds
	MessageHandler           MessageHandlerFunc // User-defined callback function to handle MESSAGE
}

type Command string

type Frame struct {
	// contains filtered or unexported fields
}

type FrameSource int

type Header string

type LoginFunc func(login, passcode string) error

type MessageHandlerFunc func(message *UserMessage)

type Session struct {
	// contains filtered or unexported fields
}

type Subscription struct {
	SubsID      string
	Destination string
	// contains filtered or unexported fields
}

type Transaction struct {
	TxID string
	// contains filtered or unexported fields
}

type Transport string

type UserMessage struct {
	Headers map[string]string // STOMP and custom headers received in MESSAGE
	Body    []byte            // MESSAGE payload
}