Versions in this module Expand all Collapse all v1 v1.0.2 Jul 7, 2024 v1.0.1 Jul 7, 2024 Changes in this version + const ExchangeTypeDirect + const ExchangeTypeFanout + const ExchangeTypeTopic + var DefaultConfirmPublish = false + var DefaultExchange = Exchange + var DefaultPrefetchCount = 0 + var DefaultPrefetchGlobal = false + var DefaultRabbitURL = "amqp://guest:guest@127.0.0.1:5672" + var DefaultRequeueOnError = false + var DefaultWithoutExchange = false + func AckOnSuccess() broker.SubscribeOption + func AppID(value string) broker.PublishOption + func ConfirmPublish() broker.Option + func ContentEncoding(value string) broker.PublishOption + func ContentType(value string) broker.PublishOption + func CorrelationID(value string) broker.PublishOption + func DeliveryMode(value uint8) broker.PublishOption + func DurableExchange() broker.Option + func DurableQueue() broker.SubscribeOption + func ExchangeName(e string) broker.Option + func ExchangeType(t MQExchangeType) broker.Option + func Expiration(value string) broker.PublishOption + func ExternalAuth() broker.Option + func Headers(h map[string]interface{}) broker.SubscribeOption + func MessageId(value string) broker.PublishOption + func NewBroker(opts ...broker.Option) broker.Broker + func PrefetchCount(c int) broker.Option + func PrefetchGlobal() broker.Option + func Priority(value uint8) broker.PublishOption + func PublishDeliveryMode(mode uint8) client.PublishOption + func QueueArguments(h map[string]interface{}) broker.SubscribeOption + func ReplyTo(value string) broker.PublishOption + func RequeueOnError() broker.SubscribeOption + func ServerAckOnSuccess() server.SubscriberOption + func ServerDurableQueue() server.SubscriberOption + func SubscribeContext(ctx context.Context) broker.SubscribeOption + func Timestamp(value time.Time) broker.PublishOption + func TypeMsg(value string) broker.PublishOption + func UserID(value string) broker.PublishOption + func WithoutExchange() broker.Option + type Exchange struct + Durable bool + Name string + Type MQExchangeType + type ExternalAuthentication struct + func (auth *ExternalAuthentication) Mechanism() string + func (auth *ExternalAuthentication) Response() string + type MQExchangeType string
Go to main page