Zero latency enterprise enriched publish/subscribe

• US 7,856,420 B2
• Filed: 12/07/2001
• Issued: 12/21/2010
• Est. Priority Date: 04/19/2001
• Status: Active Grant

• Current Assignee: Valtrus Innovations Limited (f/k/a Dolya Holdco 9 Limited) (Key Patent Innovations Limited)
• Original Assignee: Hewlett-Packard Development Company, L.P. (HP Inc.)
• Inventors: Battas, Gregory, Zargham, Bahman
• Primary Examiner(s): Wong; Don
• Assistant Examiner(s): Nguyen; Merilyn P
• Application Number:
  US10/013,091
• Publication Number:
  US 20020165903A1
• Time in Patent Office: 3,301 Days
• Field of Search: 707/1, 707/101, 707/104.1, 707/600, 707/602, 707/608, 707/627, 707/628, 707/629, 705/37, 709/202, 717/103
• US Class Current: 707/627
• CPC Class Codes: G06Q 10/06 Resources, workflows, human or project management; Enterprise or organisation planning; Enterprise or organisation modelling

Abstract

Solutions for reducing latencies in enterprise operations and business processes adaptation particularly as related to enriched publish and subscribe are proposed by the present invention. These solutions are implemented in a zero latency enterprise (ZLE) framework that allows the enterprise to integrate its services, applications and data in real time. Namely, an enterprise equipped to run as a ZLE is capable of integrating, in real time, its enterprise-wide data, applications, business transactions, operations and values. An operational data store operates as an information broker between the applications such that applications publish messages to the central repository and subscribe to messages from the central, rather than exchange request-response messages directly with each other. Thus, enriched publish and subscribe improves information synchronization between applications and reduce the number of request-response messages the applications would otherwise exchange. Consequently, an enterprise conducting its business as a ZLE exhibits superior management of its resources, operations and customer care.

Claims

1. A method for enriched publish and subscribe in an enterprise running as a zero latency enterprise (ZLE), the enterprise experiencing a plurality of events occurring in association with business transactions conducted at a plurality of sites across the enterprise, the method comprising:

initiating, by a computer, in real time, a process responsive to an event, the process including publishing, by a computer, to a central repository one or more messages prompted by that event containing information from that even, respective information from the plurality of events being aggregated in the central repository where the aggregated information can, in real -time, be accessible and available for extraction and analysis from across the enterprise,

updating the aggregated information with information from the published messages,

creating enriched messages by enriching the messages with information from that event and/or corresponding information extracted from the central repository, and

subscribing the enriched messages.

2. A method as in claim 1, wherein the central repository operates as an information broker between applications such that applications publish messages to the central repository and subscribe to messages from the central, rather than exchange request-response messages directly with each other.

3. A method as in claim 2, wherein for a particular number (N) of applications, a combined number of the published and subscribed messages can be reduced from twice that particular number (2N) to a total number of 4 or 5 messages.

4. A method as in claim 2, further comprising:

predefining a schema for each of the applications, the schema identifying which of the plurality of events and types of data changes its respective application is interested in, the schema further identifying any information its respective application needs for performing tasks related to such events; and

storing each schema in the central repository for later use in enriching the new messages.

5. A method as in claim 2, wherein the applications cause the updating of aggregated information at the central repository upon a change of information in their environment.

6. A method as in claim 1, wherein the central repository provides a coherent view, in real time, of the aggregated information from across the enterprise, the process being founded on the coherent view of the aggregated information.

7. A method as in claim 1, wherein the published messages and subscribed messages are formatted in XML.

8. A method as in claim 1, wherein the central repository is based on a database which can be updated with information from new events while being queried and which can send the enriched messages to multiple subscribers, thereby leveraging an innate parallelism, scalability and reliability of the database.

9. A method as in claim 1, wherein the central repository includes relational database management functionality that caches and queues the published and subscribed messages.

10. A method as in claim 1, wherein the enriched new messages to which an application subscribes can include extracted information that was previously published to the central repository by other one or more applications.

11. A method as in claim 1, where the corresponding information is mined and/or analyzed in real time.

12. A system comprising a processor for enriched publish and subscribe in an enterprise running as a zero latency enterprise (ZLE), the enterprise experiencing a plurality of events occurring in association with business transactions conducted at a plurality of sites across the enterprise, the system comprising:

means for initiating, in real time, a process responsive to an event, the process including

means for publishing to a central repository one or more messages prompted by that event containing information from that even, respective information from the plurality of events being aggregated in the central repository where the aggregated information can, in real-time, be accessible and available for extraction and analysis from across the enterprise,

means for updating the aggregated information with information from the published messages,

means for creating enriched messages by enriching the messages with information from that event and/or corresponding information extracted from the central repository, and

means for subscribing the enriched messages.

13. A system as in claim 12, wherein the central repository operates as an information broker between applications such that applications publish messages to the central repository and subscribe to messages from the central, rather than exchange request-response messages directly with each other.

14. A system as in claim 12, wherein the central repository is based on a database which can be updated with information from new events while being queried and which can send the enriched messages to multiple subscribers, thereby leveraging an innate parallelism, scalability and reliability of the database.

15. A method as in claim 12, wherein the central repository includes relational database management functionality that caches and queues the published and subscribed messages.

16. A computer readable storage medium embodying computer program code configured to cause a computer to performs steps for providing enriched publish and subscribe in an enterprise running as a zero latency enterprise (ZLE), the enterprise experiencing a plurality of events occurring in association with business transactions conducted at a plurality of sites across the enterprise, the method comprising:

initiating, in real time, a process responsive to an event, the process including publishing to a central repository one or more messages prompted by that event containing information from that even, respective information from the plurality of events being aggregated in the central repository where the aggregated information can, in real-time, be accessible and available for extraction and analysis from across the enterprise,

updating the aggregated information with information from the published messages,

creating enriched messages by enriching the messages with information from that event and/or corresponding information extracted from the central repository, and

subscribing the enriched messages.