Method and system for stream processing web services

• US 7,720,984 B2
• Filed: 02/07/2006
• Issued: 05/18/2010
• Est. Priority Date: 02/07/2006
• Status: Active Grant

• Current Assignee: Cisco Technology, Inc. (Cisco Systems, Inc.)
• Original Assignee: Cisco Technology, Inc. (Cisco Systems, Inc.)
• Inventors: Jacobs, Philip Clifford, Ho, Ricky
• Primary Examiner(s): Chan; Wing F
• Assistant Examiner(s): Miah; Razu A
• Application Number:
  US11/349,593
• Publication Number:
  US 20070186004A1
• Time in Patent Office: 1,561 Days
• Field of Search: 709230-238, 709/219, 707/3, 707/100
• US Class Current: 709/231
• CPC Class Codes: G06F 9/546 Message passing systems or structures, e.g. queues
• CPC Class Codes: H04L 65/403 Arrangements for multi-party communication, e.g. for conferences data switching systems for conference H04L12/18; arrangements for connecting several subscribers to a common circuit, i.e. affording conference facilities H04M3/56; television conferencing systems H04N7/15
• CPC Class Codes: H04L 65/765 intermediate
• CPC Class Codes: H04L 67/142 Managing session states for stateless protocols; Signalling session states; State transitions; Keeping-state mechanisms
• CPC Class Codes: H04L 67/51 Discovery or management thereof, e.g. service location protocol [SLP] or web services
• CPC Class Codes: H04L 67/63 Routing a service request depending on the request content or context
• CPC Class Codes: H04M 2201/40 using speech recognition speech recognition per se G10L15/00
• CPC Class Codes: H04M 3/56 Arrangements for connecting several subscribers to a common circuit, i.e. affording conference facilities video conference systems H04N7/15

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.

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; 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.

2. The stream processing unit as recited in claim 1 wherein said stream of message data is handled therewith according to a session wherein said messages are originated with a service provider, wherein a data flow relating to said session is routed according to a topology created for said session and wherein said service provider and said topology are selected at an establishment time corresponding to said session.

3. The stream processing unit as recited in claim 1 wherein said processing comprises sinking said message data.

4. The stream processing unit as recited in claim 1 further comprising a grammar tree state machine that controls said processor according to said trigger point.

5. The stream processing unit as recited in claim 1 further comprising a message buffer associated with each said input pipe configured to store said accumulation.

6. The stream processing unit as recited in claim 5 wherein said grammar comprises:

a definition of a grouping of data corresponding to said accumulation; and

data flow associated with said stream of data.

7. The stream processing unit as recited in claim 6 wherein said data flow comprises one or more of a split and a join operation.

8. The stream processing unit as recited in claim 1 wherein said grammar comprises metadata associated with code comprising said messages.

13. The stream processing unit as recited in claim 1 wherein the trigger point is included in the plurality of interrelated messages.

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.

10. The method as recited in claim 9 wherein said processing comprises sinking said data, wherein a functionality performing said processing comprises said destination application.

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.