add conditional checks

resonatehq · Dec 15, 2024 · 079a6da · 079a6da
1 parent ed66472
commit 079a6da
Showing 1 changed file with 9 additions and 6 deletions.
diff --git a/internal/app/subsystems/aio/sender/sender.go b/internal/app/subsystems/aio/sender/sender.go
@@ -221,12 +221,15 @@ func (w *SenderWorker) Process(sqe *bus.SQE[t_aio.Submission, t_aio.Completion])
 	util.Assert((logicalRecv != nil) != (physicalRecv != nil), "one of logical or physical recv must be nil, but not both")
 
 	var recv *receiver.Recv
-	// if logicalRecv != nil {
-	// 	recv = w.targets[*logicalRecv]
-	// } else {
-	// 	recv = physicalRecv
-	// }
-	recv, _ = SchemeToRecv(*logicalRecv)
+
+	if logicalRecv != nil {
+		recv = w.targets[*logicalRecv]
+		if recv == nil {
+			recv, _ = SchemeToRecv(*logicalRecv)
+		}
+	} else {
+		recv = physicalRecv
+	}
 
 	if recv == nil {
 		cqe.Error = fmt.Errorf("unknown receiver %s", *logicalRecv)