Versions in this module Expand all Collapse all v1 v1.0.0 Apr 20, 2023 Changes in this version + var DefaultExchange = Exchange + var DefaultPrefetchCount = 0 + var DefaultPrefetchGlobal = false + var DefaultRabbitURL = "amqp://guest:guest@127.0.0.1:5672" + var DefaultRequeueOnError = false + func AckOnSuccess() broker.SubscribeOption + func DeliveryMode(value uint8) broker.PublishOption + func DurableExchange() broker.Option + func DurableQueue() broker.SubscribeOption + func ExchangeName(e string) broker.Option + func ExternalAuth() broker.Option + func Headers(h map[string]interface{}) broker.SubscribeOption + func NewBroker(opts ...broker.Option) broker.Broker + func PrefetchCount(c int) broker.Option + func PrefetchGlobal() broker.Option + func Priority(value uint8) broker.PublishOption + func QueueArguments(h map[string]interface{}) broker.SubscribeOption + func RequeueOnError() broker.SubscribeOption + func SubscribeContext(ctx context.Context) broker.SubscribeOption + type Exchange struct + Durable bool + Name string + type ExternalAuthentication struct + func (auth *ExternalAuthentication) Mechanism() string + func (auth *ExternalAuthentication) Response() string