Versions in this module Expand all Collapse all v1 v1.1.0 Nov 1, 2022 v1.0.0 Apr 16, 2022 Changes in this version + 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
Go to main page