1. A unit for processing a stream of message data relating to a web service application, comprising: at least one input pipe for receiving a plurality of interrelated messages according to an order with which said messages are originated; a processor for processing an accumulation of said messages upon reaching a trigger point related to a grammar characterizing said messages, wherein the trigger point is a particular pattern of data included in the plurality of interrelated messages; the processor configured to analyze information included in the plurality of interrelated messages for the particular pattern as the plurality of interrelated messages are streamed to the processor, and upon detecting the particular pattern in a currently received one of the interrelated messages, initiate processing of those previously received messages that did not include the particular pattern of data according to said analysis; at least one output pipe, wherein the at least one output pipe connects the stream processing unit to at least one remote stream processing unit over a packet switched network; and the processor configured to: generate a new message during the processing of the accumulation of messages; and place said new message in a particular output pipe for transmission over the packet switched network to a subsequent remote stream processing unit having a different network address than the stream processing unit, wherein said new message is sent thereto using the particular output pipe.