Versions in this module Expand all Collapse all v1 v1.1.2 Apr 30, 2025 v1.1.1 Apr 22, 2025 Changes in this version type RabbitMQ + ConnSuccess chan bool v1.0.1 Apr 21, 2025 Changes in this version + type Config struct + Host string + Password string + Port string + User string + Vhost string + type RabbitMQ struct + Addr string + Done chan bool + Durable bool + Exchange string + PrefetchCount int + QueueName string + RouteKey string + Type string + func New(config *Config, queueName, exchange, routeKey string, ...) (*RabbitMQ, error) + func (m *RabbitMQ) Close() error + func (m *RabbitMQ) Consume() (<-chan amqp.Delivery, error) + func (m *RabbitMQ) Push(data []byte) error + func (m *RabbitMQ) UnsafePush(data []byte) error Other modules containing this package github.com/fbaiyi/go-rabbitmq/v2
Go to main page