Versions in this module Expand all Collapse all v1 v1.0.0 Apr 27, 2020 Changes in this version + func TestRabbitMQConnection(config Config) error + type Config interface + GetDatabase func() string + GetHost func() string + GetPassword func() string + GetPort func() int + GetUser func() string + type RabbitMQ struct + func NewRabbitMQ(config Config) (*RabbitMQ, error) + func (r *RabbitMQ) Close() + func (r *RabbitMQ) GetChannel() *amqp.Channel + func (r *RabbitMQ) Publish(data interface{}) error
Go to main page