Versions in this module Expand all Collapse all v1 v1.0.0 Jun 3, 2021 Changes in this version + func DefaultApply(exchange, queue, routingKey string, ch *amqp.Channel) (err error) + type ApplyTopology func(exchange, queue, routingKey string, ch *amqp.Channel) error + type Config struct + Host string + IsUse bool + Password string + Port int64 + Username string + func (c *Config) GetConnUtl() string + type ConsumeHandler func(d amqp.Delivery) error + type Wrapper struct + Addr string + Config amqp.Config + func New(addr string, cfg amqp.Config, exchange, queue, routingKey string, ...) *Wrapper + func NewDefaultMq(config *Config, ex, queue, routingKey string) *Wrapper + func (w *Wrapper) Channel(timeout time.Duration) (*amqp.Channel, error) + func (w *Wrapper) Close() error + func (w *Wrapper) Consume(consumer string, autoAck, exclusive, noLocal, noWait bool, args amqp.Table, ...) + func (w *Wrapper) Produce(mandatory, immediate bool, dat []byte) error
Go to main page