stomp

Documentation

Index

• func AckOnSuccess() broker.SubscribeOption
• func Auth(username string, password string) broker.Option
• func ConnectHeaders(h map[string]string) broker.Option
• func ConnectTimeout(ct time.Duration) broker.Option
• func Durable() broker.SubscribeOption
• func NewBroker(opts ...broker.Option) broker.Broker
• func Receipt(ct time.Duration) broker.PublishOption
• func SubscribeContext(ctx context.Context) broker.SubscribeOption
• func SubscribeHeaders(h map[string]string) broker.SubscribeOption
• func SuppressContentLength(ct time.Duration) broker.PublishOption
• func VirtualHost(h string) broker.Option

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