Versions in this module Expand all Collapse all v0 v0.1.0 Nov 30, 2022 Changes in this version + type Option func(*Publisher) + func BindingKey(bindingKey string) Option + func ExchangeName(exchangeName string) Option + func MessageTypeName(messageTypeName string) Option + type Publisher struct + func NewPublisher(amqpConn *amqp.Connection, logger *log.Logger, opts ...Option) (*Publisher, error) + func (p *Publisher) CloseChan() + func (p *Publisher) Publish(ctx context.Context, body []byte, contentType string) error
Go to main page