Merge pull request #22 from uio-bmi/feature/cancel_messages

Forward all messages from CEGA to local 'files' queue
uio-bmi · Feb 8, 2023 · 9aa7661 · 9aa7661
2 parents e4510db + 308cc69
commit 9aa7661
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/main.go b/main.go
@@ -124,7 +124,10 @@ func forwardDeliveryTo(fromCEGAToLEGA bool, channelFrom *amqp.Channel, channelTo
 		err = publishError(delivery, err)
 		failOnError(err, "Failed to publish error message")
 	}
-	if messageType != nil {
+	// Forward all messages from CEGA to a local queue handled by the SDA intercept service
+	if fromCEGAToLEGA {
+		routingKey = os.Getenv("LEGA_MQ_QUEUE")
+	} else if messageType != nil {
 		routingKey = messageType.(string)
 	}
 	err = channelTo.Publish(exchange, routingKey, false, false, *publishing)