Method and system for stream processing web services
First Claim
Patent Images
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.
1 Assignment
0 Petitions
Accused Products
Abstract
Systems and methods for stream processing message data relating to a web service application are described. One system has an input pipe for receiving multiple interrelated session based messages according to an order with which they originate. A processor processes an accumulation of the messages upon reaching a trigger point related to grammar characterizing the messages.
-
Citations
13 Claims
-
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; andplace 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. - View Dependent Claims (2, 3, 4, 5, 6, 7, 8, 13)
-
-
9. A method for streaming data relating to a web service, comprising:
establishing a session, wherein said session allows a plurality of interrelated messages to flow from an originating application to a destination application according to the order with which said messages are originated; upon said establishing, sending data related to said session from said originating application to said destination application with said messages; accumulating said data until a trigger point related to a grammar characterizing said messages is reached, wherein the trigger point is a particular pattern of data included in the plurality of interrelated messages; analyzing information included in the plurality of interrelated messages for the particular pattern as the plurality of interrelated messages are streamed to a stream processing unit, 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; generating a new message during the processing of the accumulation of messages; and placing said new message in a particular output pipe for transmission over a packet switched network to a subsequent remote stream processing unit having a different network address than the stream processing unit, wherein the particular output pipe connects the stream processing unit to the subsequent remote stream processing unit over the packet switched network. - View Dependent Claims (10)
-
11. A computer usable medium having encoded thereon computer readable code for controlling a computer system to perform a process for streaming data relating to a web service, said process comprising:
-
establishing a session, wherein said session allows a plurality of interrelated messages to flow from an originating application to a destination application according to the order with which said messages are originated; upon said establishing, sending data related to said session from said originating application to said destination application with said messages; accumulating said data until a trigger point related to a grammar characterizing said message is reached, wherein the trigger point is a particular pattern of data included in the plurality of interrelated messages; analyzing information included in the plurality of interrelated messages for the particular pattern as the plurality of interrelated messages are streamed to a stream processing unit, 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; generating a new message during the processing of the accumulation of messages; and placing said new message in a particular output pipe for transmission over a packet switched network to a subsequent remote stream processing unit having a different network address than the stream processing unit, wherein the particular output pipe connects the stream processing unit to the subsequent remote stream processing unit over the packet switched network.
-
-
12. A system for streaming data relating to a web service, comprising:
-
means for establishing a session, wherein said session allows a plurality of interrelated messages to flow from an originating application to a destination application according to the order with which said messages are originated; means for, upon said establishing, sending data related to said session from said originating application to said destination application with said messages; means for accumulating said data until a trigger point related to a grammar characterizing said messages is reached, wherein the trigger point is a particular pattern of data included in the plurality of interrelated messages; means for analyzing information included in the plurality of interrelated messages for the particular pattern as the plurality of interrelated messages are streamed to a stream processing unit, 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; means for generating a new message during processing of the accumulation of messages; and means for placing said new message in a particular output pipe for transmission over a packet switched network to a subsequent remote stream processing unit having a different network address than the stream processing unit, wherein the particular output pipe connects the stream processing unit to the subsequent remote stream processing unit over the packet switched network.
-
Specification