Versions in this module Expand all Collapse all v0 v0.0.2 Mar 13, 2023 Changes in this version type RabbitMQConfig + Config amqp.Config + Connection_url string + Consumer_tps int + Ctx context.Context + Debug bool + Durable bool + Producer_tps int + Queue_name string v0.0.1 Mar 13, 2023 Changes in this version + type RabbitMQ interface + Consume func(name string, prefetch int, handler func([]byte) error) error + GetStats func() (amqp.Queue, error) + Publish func(message []byte) error + func NewRabbitMq(cnf RabbitMQConfig) RabbitMQ + type RabbitMQConfig struct
Go to main page