fix(redundancy): PeerProbeSupervisor explicitly ignores co-mingled OpcUaProbeResult (integration review)
v2-ci / build (push) Failing after 34s
v2-ci / unit-tests (tests/Core/ZB.MOM.WW.OtOpcUa.Cluster.Tests) (push) Has been skipped
v2-ci / unit-tests (tests/Server/ZB.MOM.WW.OtOpcUa.ControlPlane.Tests) (push) Has been skipped
v2-ci / unit-tests (tests/Server/ZB.MOM.WW.OtOpcUa.OpcUaServer.Tests) (push) Has been skipped
v2-ci / unit-tests (tests/Server/ZB.MOM.WW.OtOpcUa.Runtime.Tests) (push) Has been skipped
v2-ci / unit-tests (tests/Server/ZB.MOM.WW.OtOpcUa.Security.Tests) (push) Has been skipped
v2-ci / integration (tests/Server/ZB.MOM.WW.OtOpcUa.Host.IntegrationTests) (push) Has been skipped
v2-ci / integration (tests/Server/ZB.MOM.WW.OtOpcUa.OpcUaServer.IntegrationTests) (push) Has been skipped

This commit is contained in:
Joseph Doherty
2026-06-15 13:40:16 -04:00
parent 4c78dcd358
commit 4af8e65af1
@@ -63,6 +63,10 @@ public sealed class PeerProbeSupervisor : ReceiveActor
Receive<RedundancyStateChanged>(OnSnapshot);
Receive<Terminated>(OnTerminated);
Receive<SubscribeAck>(_ => { });
// The redundancy-state topic also carries OpcUaProbeResult (published by our own
// PeerOpcUaProbeActor children + peers). The supervisor doesn't consume them — only
// OpcUaPublishActor does — so explicitly drop them to avoid unhandled-message noise.
Receive<PeerOpcUaProbeActor.OpcUaProbeResult>(_ => { });
}
/// <summary>Gets the current number of live peer-probe children.</summary>