eventials.goevents/messaging/connection.go

package messaging

import (
	amqplib "github.com/streadway/amqp"
)

type Connection interface {
	Consumer(autoAck bool, exchange, queue string) (Consumer, error)
	Producer(exchange, queue string) (Producer, error)
	Close()
	NotifyConnectionClose() <-chan *amqplib.Error
	WaitUntilConnectionClose()
}