topic fix

protocol/cloudEvent.go

@@ -24,9 +24,9 @@ func SendMessage(message map[string]interface{}, mediatee *database.Mediatee) er
 
 	switch config.CurrentConfiguration.CloudForwarding.Protocol {
 	case config.HTTP:
-		return sendCloudEvent(message, mediatee)
+		return sendCloudEvent(message, mediatee, mediatee.Topic)
 	case config.NATS:
-		return sendCloudEvent(message, mediatee)
+		return sendCloudEvent(message, mediatee, mediatee.Topic)
 	case config.HYBRID:
 		// implement hybrid mode if cloud event provider supports it
 		return errors.New("hybrid mode not supported: message will not be sent")
@@ -116,8 +116,7 @@ func ReceiveMessage(mediator *mediator.Mediator) {
 	wg.Wait()
 }
 
-func sendCloudEvent(message any, mediatee *database.Mediatee) (err error) {
-	topic := mediatee.Topic
+func sendCloudEvent(message any, mediatee *database.Mediatee, topic string) (err error) {
 	if topic == "" {
 		topic = "default-http"
 	}

protocol/coordinateMediation.go

@@ -398,7 +398,7 @@ func (h *CoordinateMediation) handleMediationRequest(message didcomm.Message, be
 		Did:          mediatee.RoutingKey,
 	}
 
-	err = sendCloudEvent(inv, mediatee)
+	err = sendCloudEvent(inv, mediatee, config.CurrentConfiguration.CloudForwarding.Nats.Topic)
 
 	return response, err
 }