Explicitl relay messages for the topics we are interested in

bahner · Mar 16, 2024 · f48a144 · f48a144
1 parent 95c667f
commit f48a144
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/entity/actor/subscription.go b/entity/actor/subscription.go
@@ -33,6 +33,11 @@ func (a *Actor) Subscribe(ctx context.Context, e *entity.Entity) {
 		log.Errorf("Failed to subscribe to topic: %v", err)
 		return
 	}
+	cancelRelay, err := e.Topic.Relay()
+	if err != nil {
+		log.Errorf("actorSubscribe: failed to relay to topic: %v", err)
+	}
+	defer cancelRelay()
 
 	// Create a channel for messages.
 	messages := make(chan *p2ppubsub.Message, PUBSUB_MESSAGES_BUFFERSIZE)