Method publish

shared/messaging/rabbitmq.go:140–148

(ctx context.Context, exchange, routingKey string, msg amqp.Publishing)

}

func (r *RabbitMQ) publish(ctx context.Context, exchange, routingKey string, msg amqp.Publishing) error {
	return r.Channel.PublishWithContext(ctx,
		exchange,   // exchange
		routingKey, // routing key
		false,      // mandatory
		false,      // immediate
		msg,
	)
}

func (r *RabbitMQ) setupDeadLetterExchange() error {
	// Declare the dead letter exchange