Test your AI Agents with the all-new Agent to Agent Testing Platform.Learn More

How to use OnExecutionMessageReceived method of Microsoft.VisualStudio.TestPlatform.CommunicationUtilities.TestRequestSender class

Best Vstest code snippet using Microsoft.VisualStudio.TestPlatform.CommunicationUtilities.TestRequestSender.OnExecutionMessageReceived

TestRequestSender.cs

Source:TestRequestSender.cs

...233            this.onDisconnected = (disconnectedEventArgs) =>234            {235                this.OnTestRunAbort(eventHandler, disconnectedEventArgs.Error, true);236            };237            this.onMessageReceived = (sender, args) => this.OnExecutionMessageReceived(sender, args, eventHandler);238            this.channel.MessageReceived += this.onMessageReceived;239            var message = this.dataSerializer.SerializePayload(240                MessageType.StartTestExecutionWithSources,241                runCriteria,242                this.protocolVersion);243            if (EqtTrace.IsVerboseEnabled)244            {245                EqtTrace.Verbose("TestRequestSender.StartTestRun: Sending test run with message: {0}", message);246            }247            this.channel.Send(message);248        }249        /// <inheritdoc />250        public void StartTestRun(TestRunCriteriaWithTests runCriteria, ITestRunEventsHandler eventHandler)251        {252            this.messageEventHandler = eventHandler;253            this.onDisconnected = (disconnectedEventArgs) =>254            {255                this.OnTestRunAbort(eventHandler, disconnectedEventArgs.Error, true);256            };257            this.onMessageReceived = (sender, args) => this.OnExecutionMessageReceived(sender, args, eventHandler);258            this.channel.MessageReceived += this.onMessageReceived;259            var message = this.dataSerializer.SerializePayload(260                MessageType.StartTestExecutionWithTests,261                runCriteria,262                this.protocolVersion);263            if (EqtTrace.IsVerboseEnabled)264            {265                EqtTrace.Verbose("TestRequestSender.StartTestRun: Sending test run with message: {0}", message);266            }267            this.channel.Send(message);268        }269        /// <inheritdoc />270        public void SendTestRunCancel()271        {272            if (EqtTrace.IsVerboseEnabled)273            {274                EqtTrace.Verbose("TestRequestSender.SendTestRunCancel: Sending test run cancel.");275            }276            this.channel?.Send(this.dataSerializer.SerializeMessage(MessageType.CancelTestRun));277        }278        /// <inheritdoc />279        public void SendTestRunAbort()280        {281            if (EqtTrace.IsVerboseEnabled)282            {283                EqtTrace.Verbose("TestRequestSender.SendTestRunAbort: Sending test run abort.");284            }285            this.channel?.Send(this.dataSerializer.SerializeMessage(MessageType.AbortTestRun));286        }287        #endregion288        /// <inheritdoc />289        public void EndSession()290        {291            if (!this.IsOperationComplete())292            {293                if (EqtTrace.IsVerboseEnabled)294                {295                    EqtTrace.Verbose("TestRequestSender.EndSession: Sending end session.");296                }297                this.channel.Send(this.dataSerializer.SerializeMessage(MessageType.SessionEnd));298            }299        }300        /// <inheritdoc />301        public void OnClientProcessExit(string stdError)302        {303            // This method is called on test host exit. If test host has any errors, stdError304            // provides the crash call stack.305            if (EqtTrace.IsInfoEnabled)306            {307                EqtTrace.Info($"TestRequestSender.OnClientProcessExit: Test host process exited. Standard error: {stdError}");308            }309            this.clientExitErrorMessage = stdError;310            this.clientExited.Set();311            // Break communication loop. In somecases(E.g: When tests creates child processes to testhost) communication channel won't break if testhost exits.312            this.communicationEndpoint.Stop();313        }314        /// <inheritdoc />315        public void Close()316        {317            this.Dispose();318            EqtTrace.Info("Closing the connection");319        }320        /// <inheritdoc />321        public void Dispose()322        {323            if (this.channel != null)324            {325                this.channel.MessageReceived -= this.onMessageReceived;326            }327            this.communicationEndpoint.Stop();328        }329        private void OnExecutionMessageReceived(object sender, MessageReceivedEventArgs messageReceived, ITestRunEventsHandler testRunEventsHandler)330        {331            try332            {333                var rawMessage = messageReceived.Data;334                if (EqtTrace.IsVerboseEnabled)335                {336                    EqtTrace.Verbose("TestRequestSender.OnExecutionMessageReceived: Received message: {0}", rawMessage);337                }338                // Send raw message first to unblock handlers waiting to send message to IDEs339                testRunEventsHandler.HandleRawMessage(rawMessage);340                var message = this.dataSerializer.DeserializeMessage(rawMessage);341                switch (message.MessageType)342                {343                    case MessageType.TestRunStatsChange:344                        var testRunChangedArgs = this.dataSerializer.DeserializePayload<TestRunChangedEventArgs>(message);345                        testRunEventsHandler.HandleTestRunStatsChange(testRunChangedArgs);346                        break;347                    case MessageType.ExecutionComplete:348                        var testRunCompletePayload = this.dataSerializer.DeserializePayload<TestRunCompletePayload>(message);349                        testRunEventsHandler.HandleTestRunComplete(350                            testRunCompletePayload.TestRunCompleteArgs,351                            testRunCompletePayload.LastRunTests,352                            testRunCompletePayload.RunAttachments,353                            testRunCompletePayload.ExecutorUris);354                        this.SetOperationComplete();355                        break;356                    case MessageType.TestMessage:357                        var testMessagePayload = this.dataSerializer.DeserializePayload<TestMessagePayload>(message);358                        testRunEventsHandler.HandleLogMessage(testMessagePayload.MessageLevel, testMessagePayload.Message);359                        break;360                    case MessageType.LaunchAdapterProcessWithDebuggerAttached:361                        var testProcessStartInfo = this.dataSerializer.DeserializePayload<TestProcessStartInfo>(message);362                        int processId = testRunEventsHandler.LaunchProcessWithDebuggerAttached(testProcessStartInfo);363                        var data =364                            this.dataSerializer.SerializePayload(365                                MessageType.LaunchAdapterProcessWithDebuggerAttachedCallback,366                                processId,367                                this.protocolVersion);368                        if (EqtTrace.IsVerboseEnabled)369                        {370                            EqtTrace.Verbose("TestRequestSender.OnExecutionMessageReceived: Sending LaunchAdapterProcessWithDebuggerAttachedCallback message: {0}", data);371                        }372                        this.channel.Send(data);373                        break;374                }375            }376            catch (Exception exception)377            {378                this.OnTestRunAbort(testRunEventsHandler, exception, false);379            }380        }381        private void OnDiscoveryMessageReceived(ITestDiscoveryEventsHandler2 discoveryEventsHandler, MessageReceivedEventArgs args)382        {383            try384            {...

TestRequestSender2.cs

Source:TestRequestSender2.cs

...220            this.onDisconnected = (disconnectedEventArgs) =>221                {222                    this.OnTestRunAbort(eventHandler, disconnectedEventArgs.Error, true);223                };224            this.onMessageReceived = (sender, args) => this.OnExecutionMessageReceived(sender, args, eventHandler);225            this.channel.MessageReceived += this.onMessageReceived;226            var message = this.dataSerializer.SerializePayload(227                MessageType.StartTestExecutionWithSources,228                runCriteria,229                this.protocolVersion);230            this.channel.Send(message);231        }232        /// <inheritdoc />233        public void StartTestRun(TestRunCriteriaWithTests runCriteria, ITestRunEventsHandler eventHandler)234        {235            this.messageEventHandler = eventHandler;236            this.onDisconnected = (disconnectedEventArgs) =>237                {238                    this.OnTestRunAbort(eventHandler, disconnectedEventArgs.Error, true);239                };240            this.onMessageReceived = (sender, args) => this.OnExecutionMessageReceived(sender, args, eventHandler);241            this.channel.MessageReceived += this.onMessageReceived;242            var message = this.dataSerializer.SerializePayload(243                MessageType.StartTestExecutionWithTests,244                runCriteria,245                this.protocolVersion);246            this.channel.Send(message);247        }248        /// <inheritdoc />249        public void SendTestRunCancel()250        {251            this.channel?.Send(this.dataSerializer.SerializeMessage(MessageType.CancelTestRun));252        }253        /// <inheritdoc />254        public void SendTestRunAbort()255        {256            this.channel?.Send(this.dataSerializer.SerializeMessage(MessageType.AbortTestRun));257        }258        #endregion259        /// <inheritdoc />260        public void EndSession()261        {262            if (!this.IsOperationComplete())263            {264                this.channel.Send(this.dataSerializer.SerializeMessage(MessageType.SessionEnd));265            }266        }267        /// <inheritdoc />268        public void OnClientProcessExit(string stdError)269        {270            // This method is called on test host exit. If test host has any errors, stdError271            // provides the crash call stack.272            EqtTrace.Info("TestRequestSender.OnClientProcessExit: Test host process exited. Standard error: " + stdError);273            this.clientExitErrorMessage = stdError;274            this.clientExited.Set();275            // Note that we're not explicitly disconnecting the communication channel; wait for the276            // channel to determine the disconnection on its own.277        }278        /// <inheritdoc />279        public void Close()280        {281            this.Dispose();282            EqtTrace.Info("Closing the connection");283        }284        /// <inheritdoc />285        public void Dispose()286        {287            if (this.channel != null)288            {289                this.channel.MessageReceived -= this.onMessageReceived;290            }291            this.communicationServer.Stop();292        }293        private void OnExecutionMessageReceived(object sender, MessageReceivedEventArgs messageReceived, ITestRunEventsHandler testRunEventsHandler)294        {295            try296            {297                var rawMessage = messageReceived.Data;298                // Send raw message first to unblock handlers waiting to send message to IDEs299                testRunEventsHandler.HandleRawMessage(rawMessage);300                var message = this.dataSerializer.DeserializeMessage(rawMessage);301                switch (message.MessageType)302                {303                    case MessageType.TestRunStatsChange:304                        var testRunChangedArgs = this.dataSerializer.DeserializePayload<TestRunChangedEventArgs>(message);305                        testRunEventsHandler.HandleTestRunStatsChange(testRunChangedArgs);306                        break;307                    case MessageType.ExecutionComplete:...

OnExecutionMessageReceived

Using AI Code Generation

1using System;2using System.Collections.Generic;3using System.Linq;4using System.Text;5using System.Threading.Tasks;6using Microsoft.VisualStudio.TestPlatform.CommunicationUtilities;7using Microsoft.VisualStudio.TestPlatform.ObjectModel.Client;8using Microsoft.VisualStudio.TestPlatform.ObjectModel;9using Microsoft.VisualStudio.TestPlatform.ObjectModel.Logging;10{11    {12        static void Main(string[] args)13        {14            var testRequestSender = new TestRequestSender(uri);15            testRequestSender.InitializeCommunication();16            testRequestSender.DiscoverTests(new List<string>() { "C:\\Temp\\TestProject1.dll" }, null, new TestPlatformOptions());17            testRequestSender.OnExecutionMessageReceived += testRequestSender_OnExecutionMessageReceived;18            testRequestSender.RunTests(new List<string>() { "C:\\Temp\\TestProject1.dll" }, null, new TestPlatformOptions());19            Console.Read();20        }21        static void testRequestSender_OnExecutionMessageReceived(object sender, TestRunMessageEventArgs e)22        {23            Console.WriteLine(e.Message);24        }25    }26}27using System;28using System.Collections.Generic;29using System.Linq;30using System.Text;31using System.Threading.Tasks;32using Microsoft.VisualStudio.TestPlatform.CommunicationUtilities;33using Microsoft.VisualStudio.TestPlatform.ObjectModel.Client;34using Microsoft.VisualStudio.TestPlatform.ObjectModel;35using Microsoft.VisualStudio.TestPlatform.ObjectModel.Logging;36{37    {38        static void Main(string[] args)39        {40            var testRequestHandler = new TestRequestHandler(uri);41            testRequestHandler.InitializeCommunication();42            testRequestHandler.DiscoverTests(new List<string>() { "C:\\Temp\\TestProject1.dll" }, null, new TestPlatformOptions());43            testRequestHandler.OnExecutionMessageReceived += testRequestHandler_OnExecutionMessageReceived;44            testRequestHandler.RunTests(new List<string>() { "C:\\Temp\\TestProject1.dll" }, null, new TestPlatformOptions());45            Console.Read();46        }47        static void testRequestHandler_OnExecutionMessageReceived(object sender, TestRunMessageEventArgs e)48        {49            Console.WriteLine(e.Message);50        }51    }52}

OnExecutionMessageReceived

Using AI Code Generation

1using System;2using System.Collections.Generic;3using System.Linq;4using System.Text;5using System.Threading.Tasks;6using Microsoft.VisualStudio.TestPlatform.CommunicationUtilities;7using Microsoft.VisualStudio.TestPlatform.ObjectModel;8{9    {10        static void Main(string[] args)11        {12            TestRequestSender sender = new TestRequestSender();13            sender.InitializeCommunication();14            sender.OnExecutionMessageReceived += Sender_OnExecutionMessageReceived;15            sender.StartTestRun();16            Console.ReadLine();17        }18        private static void Sender_OnExecutionMessageReceived(object sender, Microsoft.VisualStudio.TestPlatform.ObjectModel.Client.TestRunMessageEventArgs e)19        {20            Console.WriteLine(e.Message);21        }22    }23}24using System;25using System.Collections.Generic;26using System.Linq;27using System.Text;28using System.Threading.Tasks;29using Microsoft.VisualStudio.TestPlatform.CommunicationUtilities;30using Microsoft.VisualStudio.TestPlatform.ObjectModel;31{32    {33        static void Main(string[] args)34        {35            TestRequestSender sender = new TestRequestSender();36            sender.InitializeCommunication();37            sender.OnDataReceived += Sender_OnDataReceived;38            sender.StartTestRun();39            Console.ReadLine();40        }41        private static void Sender_OnDataReceived(object sender, Microsoft.VisualStudio.TestPlatform.ObjectModel.Client.TestRunChangedEventArgs e)42        {43            Console.WriteLine(e.NewTestResults.Count);44        }45    }46}47using System;48using System.Collections.Generic;49using System.Linq;50using System.Text;51using System.Threading.Tasks;52using Microsoft.VisualStudio.TestPlatform.CommunicationUtilities;53using Microsoft.VisualStudio.TestPlatform.ObjectModel;54{55    {56        static void Main(string[] args)57        {58            TestRequestSender sender = new TestRequestSender();59            sender.InitializeCommunication();60            sender.OnTestRunComplete += Sender_OnTestRunComplete;61            sender.StartTestRun();62            Console.ReadLine();63        }64        private static void Sender_OnTestRunComplete(object sender, Microsoft.VisualStudio.TestPlatform.ObjectModel.Client.TestRunCompleteEventArgs e)65        {66            Console.WriteLine(e.IsCanceled);67        }68    }69}

OnExecutionMessageReceived

Using AI Code Generation

1using System;2using System.Collections.Generic;3using System.Linq;4using System.Text;5using System.Threading.Tasks;6{7    {8        static void Main(string[] args)9        {10            Microsoft.VisualStudio.TestPlatform.CommunicationUtilities.TestRequestSender sender = new Microsoft.VisualStudio.TestPlatform.CommunicationUtilities.TestRequestSender();11            sender.OnExecutionMessageReceived += Sender_OnExecutionMessageReceived;12        }13        private static void Sender_OnExecutionMessageReceived(object sender, Microsoft.VisualStudio.TestPlatform.CommunicationUtilities.TestPlatformMessageEventArgs e)14        {15            throw new NotImplementedException();16        }17    }18}

OnExecutionMessageReceived

Using AI Code Generation

1using System;2using System.Collections.Generic;3using System.Linq;4using System.Text;5using System.Threading.Tasks;6using Microsoft.VisualStudio.TestPlatform.CommunicationUtilities;7using Microsoft.VisualStudio.TestPlatform.CommunicationUtilities.Interfaces;8{9    {10        static void Main(string[] args)11        {12            TestRequestSender sender = new TestRequestSender();13            sender.InitializeCommunication();14            sender.OnExecutionMessageReceived += Sender_OnExecutionMessageReceived;15            sender.StartTestRun();16        }17        private static void Sender_OnExecutionMessageReceived(object sender, TestRunMessageEventArgs e)18        {19            Console.WriteLine(e.Message);20        }21    }22}23using System;24using System.Collections.Generic;25using System.Linq;26using System.Text;27using System.Threading.Tasks;28using Microsoft.VisualStudio.TestPlatform.CommunicationUtilities;29using Microsoft.VisualStudio.TestPlatform.CommunicationUtilities.Interfaces;30{31    {32        static void Main(string[] args)33        {34            TestRequestSender sender = new TestRequestSender();35            sender.InitializeCommunication();36            sender.StartTestRun();37            sender.OnExecutionMessageReceived += Sender_OnExecutionMessageReceived;38        }39        private static void Sender_OnExecutionMessageReceived(object sender, TestRunMessageEventArgs e)40        {41            Console.WriteLine(e.Message);42        }43    }44}45.NET Core SDK (reflecting any global.json):46Host (useful for support):

OnExecutionMessageReceived

Using AI Code Generation

1using Microsoft.VisualStudio.TestPlatform.CommunicationUtilities;2using Microsoft.VisualStudio.TestPlatform.ObjectModel;3using System;4using System.Collections.Generic;5using System.Linq;6using System.Text;7using System.Threading.Tasks;8{9    {10        static void Main(string[] args)11        {12            var testRequestSender = new TestRequestSender();13            testRequestSender.InitializeCommunication();14            testRequestSender.WaitForRequestHandlerConnection(10000);15            testRequestSender.OnExecutionMessageReceived += TestRequestSender_OnExecutionMessageReceived;16            Console.ReadKey();17        }18        private static void TestRequestSender_OnExecutionMessageReceived(object sender, Microsoft.VisualStudio.TestPlatform.ObjectModel.MessageEventArgs<Microsoft.VisualStudio.TestPlatform.ObjectModel.TestMessageLevel> e)19        {20            Console.WriteLine(e.Message);21        }22    }23}24using Microsoft.VisualStudio.TestPlatform.CommunicationUtilities;25using Microsoft.VisualStudio.TestPlatform.ObjectModel;26using System;27using System.Collections.Generic;28using System.Linq;29using System.Text;30using System.Threading.Tasks;31{32    {33        static void Main(string[] args)34        {35            var testRequestSender = new TestRequestSender();36            testRequestSender.InitializeCommunication();37            testRequestSender.WaitForRequestHandlerConnection(10000);38            testRequestSender.OnExecutionMessageReceived += TestRequestSender_OnExecutionMessageReceived;39            Console.ReadKey();40        }41        private static void TestRequestSender_OnExecutionMessageReceived(object sender, Microsoft.VisualStudio.TestPlatform.ObjectModel.MessageEventArgs<Microsoft.VisualStudio.TestPlatform.ObjectModel.TestMessageLevel> e)42        {43            Console.WriteLine(e.Message);44        }45    }46}47using Microsoft.VisualStudio.TestPlatform.CommunicationUtilities;48using Microsoft.VisualStudio.TestPlatform.ObjectModel;49using System;50using System.Collections.Generic;51using System.Linq;52using System.Text;53using System.Threading.Tasks;54{55    {56        static void Main(string[] args)57        {58            var testRequestSender = new TestRequestSender();59            testRequestSender.InitializeCommunication();60            testRequestSender.WaitForRequestHandlerConnection(10000);

OnExecutionMessageReceived

Using AI Code Generation

1var testRequestSender = new TestRequestSender();2var testMessageEventHandler = new TestMessageEventHandler();3testRequestSender.OnExecutionMessageReceived += testMessageEventHandler.OnExecutionMessageReceived;4testRequestSender.InitializeCommunication();5var testRunCriteria = new TestRunCriteria(new List<string> { "1.cs" }, 1, false, new Dictionary<string, object> { });6testRequestSender.StartTestRun(testRunCriteria);7var testRequestSender = new TestRequestSender();8var testMessageEventHandler = new TestMessageEventHandler();9testRequestSender.OnExecutionMessageReceived += testMessageEventHandler.OnExecutionMessageReceived;10testRequestSender.InitializeCommunication();11var testRunCriteria = new TestRunCriteria(new List<string> { "2.cs" }, 1, false, new Dictionary<string, object> { });12testRequestSender.StartTestRun(testRunCriteria);13var testRequestSender = new TestRequestSender();14var testMessageEventHandler = new TestMessageEventHandler();15testRequestSender.OnExecutionMessageReceived += testMessageEventHandler.OnExecutionMessageReceived;16testRequestSender.InitializeCommunication();17var testRunCriteria = new TestRunCriteria(new List<string> { "3.cs" }, 1, false, new Dictionary<string, object> { });18testRequestSender.StartTestRun(testRunCriteria);19var testRequestSender = new TestRequestSender();20var testMessageEventHandler = new TestMessageEventHandler();21testRequestSender.OnExecutionMessageReceived += testMessageEventHandler.OnExecutionMessageReceived;22testRequestSender.InitializeCommunication();23var testRunCriteria = new TestRunCriteria(new List<string> { "4.cs" }, 1, false, new Dictionary<string, object> { });24testRequestSender.StartTestRun(testRunCriteria);25var testRequestSender = new TestRequestSender();26var testMessageEventHandler = new TestMessageEventHandler();27testRequestSender.OnExecutionMessageReceived += testMessageEventHandler.OnExecutionMessageReceived;28testRequestSender.InitializeCommunication();

OnExecutionMessageReceived

Using AI Code Generation

1using System;2using System.Collections.Generic;3using System.Linq;4using System.Text;5using System.Threading.Tasks;6using Microsoft.VisualStudio.TestPlatform.CommunicationUtilities;7using Microsoft.VisualStudio.TestPlatform.ObjectModel;8using Microsoft.VisualStudio.TestPlatform.ObjectModel.Client;9using Microsoft.VisualStudio.TestPlatform.ObjectModel.Logging;10using System.Diagnostics;11using System.Threading;12using System.Runtime.Serialization;13using System.Runtime.Serialization.Formatters.Binary;14using System.IO;15using System.Reflection;16{17    {18        public void Cancel()19        {20            throw new NotImplementedException();21        }22        public void RunTests(IEnumerable<string> sources, IRunContext runContext, IFrameworkHandle frameworkHandle)23        {24            TestRequestSender sender = new TestRequestSender();25            sender.InitializeCommunication();26            sender.OnExecutionMessageReceived += (object sender1, TestRunMessageEventArgs e) =>27            {28                frameworkHandle.SendMessage(TestMessageLevel.Informational, e.Message);29            };30            foreach (var source in sources)31            {32                sender.StartTestRun(new TestRunCriteria(new List<string> { source }, 1, false, new System.Xml.XmlDocument()));

Automation Testing Tutorials

Learn to execute automation testing from scratch with LambdaTest Learning Hub. Right from setting up the prerequisites to run your first automation test, to following best practices and diving deeper into advanced test scenarios. LambdaTest Learning Hubs compile a list of step-by-step guides to help you be proficient with different test automation frameworks i.e. Selenium, Cypress, TestNG etc.