stomp

package module

Go to main page

Versions in this module

v3

v3.1.3

Oct 24, 2024

Changes in this version

type Conn

+ func ConnectWithContext(ctx context.Context, conn io.ReadWriteCloser, opts ...func(*Conn) error) (*Conn, error)

+ func DialWithContext(ctx context.Context, network, addr string, opts ...func(*Conn) error) (*Conn, error)

v3.1.2

Aug 3, 2024

Changes in this version

type Conn

+ func (c *Conn) Stats() ConnectionStats

+ type ConnectionStats struct

+ CurrentReadChanSize int

+ CurrentWriteChanSize int

+ ReadsReceived int64

+ WritesSent int64

v3.1.1

Jul 14, 2024

v3.1.0

Mar 2, 2024

Changes in this version

+ const DefaultUnsubscribeReceiptTimeout

+ var ErrUnsubscribeReceiptTimeout = newErrorMessage("unsubscribe receipt timeout")

v3.0.6

Feb 6, 2024

Changes in this version

+ const DefaultDisconnectReceiptTimeout

+ var ErrDisconnectReceiptTimeout = newErrorMessage("disconnect receipt timeout")

v3.0.5

Mar 26, 2022

v3.0.4

Mar 21, 2022

v3.0.3

Sep 19, 2021

Changes in this version

+ const ReplyToHeader

v3.0.2

Jul 16, 2021

Changes in this version

+ type Logger interface

+ Debug func(message string)

+ Debugf func(format string, value ...interface{})

+ Error func(message string)

+ Errorf func(format string, value ...interface{})

+ Info func(message string)

+ Infof func(format string, value ...interface{})

+ Warning func(message string)

+ Warningf func(format string, value ...interface{})

v3.0.1

May 9, 2021

v3.0.0

Mar 25, 2021

Changes in this version

+ const DefaultHeartBeatError

+ const DefaultMsgSendTimeout

+ const DefaultRcvReceiptTimeout

+ var ConnOpt struct

+ var ErrAlreadyClosed = newErrorMessage("connection already closed")

+ var ErrCannotNackAutoSub = newErrorMessage("cannot send NACK for a subscription with ack:auto")

+ var ErrClosedUnexpectedly = newErrorMessage("connection closed unexpectedly")

+ var ErrCompletedSubscription = newErrorMessage("subscription is unsubscribed")

+ var ErrCompletedTransaction = newErrorMessage("transaction is completed")

+ var ErrInvalidCommand = newErrorMessage("invalid command")

+ var ErrInvalidFrameFormat = newErrorMessage("invalid frame format")

+ var ErrMsgReceiptTimeout = newErrorMessage("msg receipt timeout")

+ var ErrMsgSendTimeout = newErrorMessage("msg send timeout")

+ var ErrNackNotSupported = newErrorMessage("NACK not supported in STOMP 1.0")

+ var ErrNilOption = newErrorMessage("nil option")

+ var ErrNotReceivedMessage = newErrorMessage("cannot ack/nack a message, not from server")

+ var ErrUnsupportedVersion = newErrorMessage("unsupported version")

+ var SendOpt struct

+ var SubscribeOpt struct

+ type AckMode int

+ const AckAuto

+ const AckClient

+ const AckClientIndividual

+ func (a AckMode) ShouldAck() bool

+ func (a AckMode) String() string

+ type Conn struct

+ func Connect(conn io.ReadWriteCloser, opts ...func(*Conn) error) (*Conn, error)

+ func Dial(network, addr string, opts ...func(*Conn) error) (*Conn, error)

+ func (c *Conn) Ack(m *Message) error

+ func (c *Conn) Begin() *Transaction

+ func (c *Conn) BeginWithError() (*Transaction, error)

+ func (c *Conn) Disconnect() error

+ func (c *Conn) MustDisconnect() error

+ func (c *Conn) Nack(m *Message) error

+ func (c *Conn) Send(destination, contentType string, body []byte, opts ...func(*frame.Frame) error) error

+ func (c *Conn) Server() string

+ func (c *Conn) Session() string

+ func (c *Conn) Subscribe(destination string, ack AckMode, opts ...func(*frame.Frame) error) (*Subscription, error)

+ func (c *Conn) Version() Version

+ type Error struct

+ Frame *frame.Frame

+ Message string

+ func (e Error) Error() string

+ type Message struct

+ Body []byte

+ Conn *Conn

+ ContentType string

+ Destination string

+ Err error

+ Header *frame.Header

+ Subscription *Subscription

+ func (msg *Message) Read(p []byte) (int, error)

+ func (msg *Message) ReadByte() (byte, error)

+ func (msg *Message) ShouldAck() bool

+ type Subscription struct

+ C chan *Message

+ func (s *Subscription) AckMode() AckMode

+ func (s *Subscription) Active() bool

+ func (s *Subscription) Destination() string

+ func (s *Subscription) Id() string

+ func (s *Subscription) Read() (*Message, error)

+ func (s *Subscription) Unsubscribe(opts ...func(*frame.Frame) error) error

+ type Transaction struct

+ func (tx *Transaction) Abort() error

+ func (tx *Transaction) AbortWithReceipt() error

+ func (tx *Transaction) Ack(msg *Message) error

+ func (tx *Transaction) Commit() error

+ func (tx *Transaction) CommitWithReceipt() error

+ func (tx *Transaction) Conn() *Conn

+ func (tx *Transaction) Id() string

+ func (tx *Transaction) Nack(msg *Message) error

+ func (tx *Transaction) Send(destination, contentType string, body []byte, opts ...func(*frame.Frame) error) error

+ type Validator interface

+ Validate func(f *frame.Frame) error

+ func NewValidator(version Version) Validator

+ type Version string

+ const V10

+ const V11

+ const V12

+ func (v Version) CheckSupported() error

+ func (v Version) String() string

+ func (v Version) SupportsNack() bool

v3.0.0-alpha

Mar 13, 2021

Other modules containing this package

github.com/go-stomp/stomp

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL