A system including instructions recorded on a computer-readable medium and executable by at least one processor, the system comprising: a message handler, at a sink node of a network of nodes (102A-102E), configured to cause the at least one processor to receive a plurality of messages, wherein each of the messages contains a plurality of events, the events having a temporal relationship to one another and wherein each of the messages is transmitted from node to node through the network from a source node to the sink node and is incrementally updated each time the message traverses an intervening node which is configured to update latency information associated with the network transmission of the message from the source node to the sink node; a header inspector executed by the message handler and configured to cause the at least one processor to inspect a header of each of the received messages and to extract the latency information included therein, the latency information characterizing a transmission duration experienced by each of the messages in traveling from the source node to the sink node through the network; a window manager configured to cause the at least one processor to receive the extracted latency information from the message handler and to compare the latency information extracted from the header of each of the messages with expected latency information to adapt in real-time a time window relative to the events contained in said message or to adjust the events contained in said message relative to the time window in order to correct any delays experienced by a given event relative to another event contained in said message which is related for purposes of processing within the context of the time window; and an event processor configured to cause the at least one processor to receive the relevant events of said message in a manner which accurately reflects temporal relationships there between from the window manager and to process the events relative to the time window. a message handler, at a sink node of a network of nodes (102A-102E), configured to cause the at least one processor to receive a plurality of messages, wherein each of the messages contains a plurality of events, the events having a temporal relationship to one another and wherein each of the messages is transmitted from node to node through the network from a source node to the sink node and is incrementally updated each time the message traverses an intervening node which is configured to update latency information associated with the network transmission of the message from the source node to the sink node; a header inspector executed by the message handler and configured to cause the at least one processor to inspect a header of each of the received messages and to extract the latency information included therein, the latency information characterizing a transmission duration experienced by each of the messages in traveling from the source node to the sink node through the network; a window manager configured to cause the at least one processor to receive the extracted latency information from the message handler and to compare the latency information extracted from the header of each of the messages with expected latency information to adapt in real-time a time window relative to the events contained in said message or to adjust the events contained in said message relative to the time window in order to correct any delays experienced by a given event relative to another event contained in said message which is related for purposes of processing within the context of the time window; and an event processor configured to cause the at least one processor to receive the relevant events of said message in a manner which accurately reflects temporal relationships there between from the window manager and to process the events relative to the time window.