Function PublishInChannel

internal/rabbit/publish.go:17–30

PublishInChannel publishes a message to a Rabbit exchange using a provided channel. For use in go routines.

(ch *amqp.Channel, exch, rKey string, message []byte)

// PublishInChannel publishes a message to a Rabbit exchange using
// a provided channel. For use in go routines.
func PublishInChannel(ch *amqp.Channel, exch, rKey string, message []byte) error {
	return ch.Publish(
		exch,  // exchane name
		rKey,  // routing key
		false, // mandatory
		false, // immediate
		amqp.Publishing{
			ContentType:  "application/json",
			DeliveryMode: amqp.Persistent,
			Timestamp:    time.Now(),
			Body:         message,
		},
	)
}