diff --git a/src/ZB.MOM.WW.MxGateway.Worker.Tests/Ipc/WorkerPipeSessionTests.cs b/src/ZB.MOM.WW.MxGateway.Worker.Tests/Ipc/WorkerPipeSessionTests.cs index ceb5696..1db3fd0 100644 --- a/src/ZB.MOM.WW.MxGateway.Worker.Tests/Ipc/WorkerPipeSessionTests.cs +++ b/src/ZB.MOM.WW.MxGateway.Worker.Tests/Ipc/WorkerPipeSessionTests.cs @@ -1130,6 +1130,11 @@ public sealed class WorkerPipeSessionTests }; } + // A generic STA-dispatched command used by the dispatch/heartbeat/ + // shutdown-race tests. Register is a real MXAccess command kind (not a + // worker control command), so it flows through IWorkerRuntimeSession + // .DispatchAsync — unlike Ping/GetSessionState/etc., which are answered on + // the message-loop thread without touching the STA. private static WorkerEnvelope CreateCommandEnvelope(string correlationId, ulong sequence = 2) { return new WorkerEnvelope @@ -1142,10 +1147,10 @@ public sealed class WorkerPipeSessionTests { Command = new MxCommand { - Kind = MxCommandKind.Ping, - Ping = new PingCommand + Kind = MxCommandKind.Register, + Register = new RegisterCommand { - Message = "ping", + ClientName = "test-client", }, }, EnqueueTimestamp = Timestamp.FromDateTimeOffset(DateTimeOffset.UtcNow),