wip

microsoft · Nov 23, 2024 · ae4cb9b · ae4cb9b
1 parent 985b165
commit ae4cb9b
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/dotnet/src/Microsoft.AutoGen/Agents/AgentBase.cs b/dotnet/src/Microsoft.AutoGen/Agents/AgentBase.cs
@@ -224,9 +224,9 @@ static async ((AgentBase Agent, CloudEvent Event) state) =>
     public Task CallHandler(CloudEvent item)
     {
         // Only send the event to the handler if the agent type is handling that type
-        // foreach of the keys in the EventTypes.EventsMap[] if it contains the item.type
 
-        foreach (var type in EventTypes.TypesMap[item.Type])
+        if (EventTypes.EventsMap[GetType()].Contains(item.Type) && 
+         item.Source == AgentId.Key)
         {
             var payload = item.ProtoData.Unpack(EventTypes.TypeRegistry);
             var convertedPayload = Convert.ChangeType(payload, EventTypes.Types[item.Type]);