publish

Oct 1, 2023

Changes in this version

+ type Channel interface

+ PublishWithContext func(ctx context.Context, exchange, key string, mandatory, immediate bool, ...) error

+ func Wrap(channel Channel, mws ...Middleware) Channel

+ type ChannelFunc func(ctx context.Context, exchange, key string, mandatory, immediate bool, ...) error

+ func (f ChannelFunc) PublishWithContext(ctx context.Context, exchange, key string, mandatory, immediate bool, ...) error

+ type Middleware func(Channel) Channel

+ func WithExpiration(expire time.Duration) Middleware

+ func WithHeaders(table amqp.Table) Middleware