stomp

package
v1.0.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 20, 2023 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AckOnSuccess

func AckOnSuccess() broker.SubscribeOption

AckOnSuccess will automatically acknowledge messages when no error is returned

func Auth

func Auth(username string, password string) broker.Option

Auth sets the authentication information

func ConnectHeaders

func ConnectHeaders(h map[string]string) broker.Option

ConnectHeaders adds headers for the connection

func ConnectTimeout

func ConnectTimeout(ct time.Duration) broker.Option

ConnectTimeout sets the connection timeout duration

func Durable

func Durable() broker.SubscribeOption

Durable sets a durable subscription

func NewBroker

func NewBroker(opts ...broker.Option) broker.Broker

NewBroker returns a STOMP broker

func Receipt

func Receipt(ct time.Duration) broker.PublishOption

Receipt requests a receipt for the delivery should be received

func SubscribeContext

func SubscribeContext(ctx context.Context) broker.SubscribeOption

SubscribeContext set the context for broker.SubscribeOption

func SubscribeHeaders

func SubscribeHeaders(h map[string]string) broker.SubscribeOption

SubscribeHeaders sets headers for subscriptions

func SuppressContentLength

func SuppressContentLength(ct time.Duration) broker.PublishOption

SuppressContentLength requests that send does not include a content length

func VirtualHost

func VirtualHost(h string) broker.Option

VirtualHost adds host header to define the vhost

Types

This section is empty.

Jump to

Keyboard shortcuts

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