Building the solution

In this solution, we will be constructing an application that embeds the StreamInsight Server in-process and pulls data from two separate feeds of data. Specifically, we are designing a very loosely coupled process where we use MSMQ as the medium between the event producers and the StreamInsight CEP engine. Each web server will send its machine event log entries to one MSMQ queue, and all the web click events will be distributed to a different MSMQ queue.

We will build MSMQ adapters for StreamInsight in a way that events are loaded into the CEP server as soon as they hit the queue. Our first LINQ query aggregates server log events per application, and keeps a sum of each type of event over one-minute intervals. Then we will add another LINQ query which uses the first query as input and joins to the click stream events for each website. When a particular website starts acting up, the "abandon cart" events should be amplified and we can make sure to immediately court...