Versions in this module Expand all Collapse all v0 v0.1.0 Nov 22, 2021 Changes in this version + func OpenConnection(addr string) (*amqp.Connection, error) + type Channel struct + func NewChannel(conn *amqp.Connection) Channel + func (c Channel) Create() (*amqp.Channel, error) + type Consumer struct + func NewConsumer(addr, exchange, queueName string, autoDelete bool, ...) *Consumer + func (c *Consumer) Handle(delivery <-chan amqp.Delivery) + func (c *Consumer) ReConnect() + func (c *Consumer) Run() error + func (c *Consumer) Start() error + func (c *Consumer) Stop() + type Producer struct + func NewProducer(addr, exchange string) *Producer + func (p *Producer) Publish(message string) error + func (p *Producer) ReConnect() + func (p *Producer) Run() error + func (p *Producer) Start() error + func (p *Producer) Stop() + type Queue struct + func NewQueue(channel *amqp.Channel, name string) Queue + func (q Queue) Create() (amqp.Queue, error)
Go to main page