producer

func ConfirmOne ¶

func ConfirmOne(confirms <-chan amqp.Confirmation)

One would typically keep a channel of publishings, a sequence number, and a set of unacknowledged sequence numbers and loop until the publishing channel is closed.

func NewPublish ¶

func NewPublish(exchange,
	exchangeType,
	routingKey,
	body string,
	reliable bool,
	confirmOne func(confirms <-chan amqp.Confirmation),
	setupConn func() (*amqp.Connection, error),
) error