delivery_channel_manager

type DeliveryChannelManager interface {
	GetDeliveryChan(queue string) <-chan amqp.Delivery
	InitDeliveryChannelForQueue(queue string) error
	Close()
	ReconnectDeliveryChannel() error
	NotifiedConnectionError()
	ConnectionErrorSolved()
	GetConnectionErrorChan() <-chan bool
}