Versions in this module Expand all Collapse all v1 v1.0.0 Aug 10, 2022 Changes in this version + type Client struct + func (c *Client) Ack(m *Message) error + func (c *Client) Begin() *Transaction + func (c *Client) BeginWithError(ctx context.Context) (*Transaction, error) + func (c *Client) Connect(opts *Options) *Client + func (c *Client) Disconnect() error + func (c *Client) Nack(m *Message) error + func (c *Client) Send(destination, contentType string, body []byte, opts *SendOptions) (err error) + func (c *Client) Server() string + func (c *Client) Session() string + func (c *Client) Subscribe(destination string, opts *SubscribeOptions) (*Subscription, error) + type Listener func(*Message) + type Message struct + func (m *Message) JSON(selector ...string) goja.Value + func (m *Message) String() string + type Options struct + Addr string + Headers map[string]string + Heartbeat struct{ ... } + Host string + MessageSendTimeout string + Pass string + Path string + Protocol string + Query string + ReadBufferSize int + ReadChannelCapacity int + ReceiptTimeout string + TLS bool + Timeout string + User string + Verbose bool + WriteBufferSize int + WriteChannelCapacity int + type RootModule struct + func New() *RootModule + func (*RootModule) NewModuleInstance(vu modules.VU) modules.Instance + type SendOptions struct + Headers map[string]string + Receipt bool + type StatsReadWriteClose struct + func (s *StatsReadWriteClose) Read(p []byte) (int, error) + func (s *StatsReadWriteClose) Write(p []byte) (int, error) + type Stomp struct + func (s *Stomp) Exports() modules.Exports + type SubscribeOptions struct + Ack string + Headers map[string]string + Id string + Listener Listener + type Subscription struct + func NewSubscription(client *Client, sc *stomp.Subscription, listener Listener) *Subscription + func (s *Subscription) Read() (msg *Message, err error) + func (s *Subscription) Unsubscribe(opts ...func(*frame.Frame) error) error + type Transaction struct + func (tx *Transaction) Ack(m *Message) error + func (tx *Transaction) Nack(m *Message) error + func (tx *Transaction) Send(destination, contentType string, body []byte, opts *SendOptions) (err error) + type VerboseReadWriteClose struct + func (v *VerboseReadWriteClose) Read(p []byte) (int, error) + func (v *VerboseReadWriteClose) Write(p []byte) (int, error)
Go to main page