publisher

type AMQPChannel interface {
	PublishWithContext(ctx context.Context, exchange, key string, mandatory, immediate bool, msg amqp.Publishing) error
	NotifyClose(receiver chan *amqp.Error) chan *amqp.Error
	NotifyFlow(c chan bool) chan bool
	Close() error
	NotifyPublish(confirm chan amqp.Confirmation) chan amqp.Confirmation
	Confirm(noWait bool) error
}

type AMQPConnection interface {
}

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

type Message struct {
	Context      context.Context
	Exchange     string
	Key          string
	Mandatory    bool
	Immediate    bool
	ErrOnUnready bool
	Publishing   amqp.Publishing
	ResultCh     chan error
}

type Option func(p *Publisher)

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

type Ready struct{}

type State struct {
	Unready *Unready
	Ready   *Ready
}

type Unready struct {
	Err error
}