internal

type Message struct {
	Exchange string
	Key      string
	Msg      amqp.Publishing
	Try      chan error
	Done     chan struct{}
}

type MessageQueue struct {
	// contains filtered or unexported fields
}