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; and
a processor for processing an accumulation of said messages upon reaching a trigger point related to a grammar characterizing said messages.
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
21 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; and
a processor for processing an accumulation of said messages upon reaching a trigger point related to a grammar characterizing said messages. - View Dependent Claims (2, 3, 4, 5, 6, 7, 8, 9)
-
-
10. 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 a destination application with said messages;
accumulating said data until a trigger point related to a grammar characterizing said message is reached; and
processing said data upon reaching said trigger point wherein said processing comprises a function related to said destination application. - View Dependent Claims (11, 12)
-
-
13. 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 a destination application with said messages;
accumulating said data until a trigger point related to a grammar characterizing said message is reached; and
processing said data upon reaching said trigger point wherein said processing comprises a function related to said destination application. - View Dependent Claims (14)
-
-
15. 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 a destination application with said messages;
means for accumulating said data until a trigger point related to a grammar characterizing said message is reached; and
means for processing said data upon reaching said trigger point wherein said processing comprises a function related to said destination application. - View Dependent Claims (16)
-
-
17. A system for controlling processing of a stream of message data relating to a web service application, comprising:
-
a coordinator for setting a stream processing session upon a request from a first network entity; and
at least one service provider selectable by said coordinator to provide a streaming Web service in response to said request wherein, upon said setting, said coordinator handshakes with said service provider to establish a pipe that effectively couples said service provider with said first network entity for exchanging said stream of message data between them. - View Dependent Claims (18)
-
-
19. A method for controlling processing of a stream of message data relating to a web service application, comprising:
-
setting a stream processing session upon a request from a first network entity;
selecting at least one service provider to provide a streaming Web service in response to said request;
handshaking with said service provider; and
establishing a pipe that effectively couples said service provider with said first network entity for exchanging said stream of message data between them.
-
-
20. A system for controlling processing of a stream of message data relating to a web service application, comprising:
-
means for setting a stream processing session upon a request from a first network entity;
means for selecting at least one service provider to provide a streaming Web service in response to said request;
means for handshaking with said service provider; and
means for establishing a pipe that effectively couples said service provider with said first network entity for exchanging said stream of message data between them.
-
-
21. An apparatus for controlling the processing of a stream of message data relating to a web service application, comprising:
-
a stream processing session setter, for establishing said session upon a request from a first network entity;
a selector functioning with said session setter, for selecting at least one service provider to provide a streaming Web service in response to said request;
a session commencer functioning with said selector, for handshaking with said service provider; and
a pipe setter functional with said session commencer, for establishing a pipe that effectively couples said service provider with said first network entity for exchanging said stream of message data between them.
-
Specification