PUBLISH/SUBSCRIBE SYSTEM INTEROPERABILITY

• US 20130091295A1
• Filed: 10/06/2011
• Published: 04/11/2013
• Est. Priority Date: 10/06/2011
• Status: Abandoned Application

• Current Assignee: Microsoft Technology Licensing LLC (Microsoft Corporation)
• Original Assignee: Microsoft Corporation
• Inventors: Meijer, Henricus Johannes Maria, Manolescu, Dragos
• Application Number:
  US13/267,040
• Publication Number:
  US 20130091295A1
• Time in Patent Office: Days
• US Class Current: 709/231
• CPC Class Codes: G06Q 50/01 Social networking
• CPC Class Codes: H04L 51/00 User-to-user messaging in packet-switching networks, transmitted according to store-and-forward or real-time protocols, e.g. e-mail
• CPC Class Codes: H04L 51/56 Unified messaging, e.g. interactions between e-mail, instant messaging or converged IP messaging [CPM]

Abstract

Publish/subscribe (pub/sub) systems can be interoperable. Differences between various pub/sub systems can be addressed to enable creative combination of streams from diverse pub/sub systems, among other things. More specifically, pub/sub systems can be unified to facilitate interaction, and adjustments can be made to compensate for any message stream idiosyncrasies.

Claims

1. A method, comprising:

employing at least one processor configured to execute computer-executable instructions stored in memory to perform the following acts;

composing a message stream as a function of message streams from one or more publish/subscribe systems.

2. The method of claim 1 further comprises unifying interaction amongst the one or more publish/subscribe systems.

3. The method of claim 2 further comprises implementing a continuation-passing style interface over the one or more publish/subscribe systems.

4. The method of claim 1 further comprises transforming the message streams to a canonical format.

5. The method of claim 1, composing the message stream as a function of a query specified over the messages from the one or more publish/subscribe systems.

6. The method of claim 5, composing the message stream as a function of one or more general-purpose, programming-language-integrated, query operators.

7. The method of claim 5, the query is specified to address idiosyncrasies of the one or more publish/subscribe systems.

8. The method of claim 1, composing the message stream comprises composing two or more message streams from a single message stream.

9. The method of claim 1, performing an action based on content of the message stream.

10. A system, comprising:

a processor coupled to a memory, the processor configured to execute the following computer-executable components stored in the memory;

a first component configured to enable interaction with diverse publish/subscribe system implementations in a uniform manner.

11. The system of claim 10, the first component is configured to produce a message stream from two or more message streams from two or more diverse publish/subscribe system implementations.

12. The system of claim 10, the first component is configured to produce two or more message streams from a single message stream from one of the diverse publish/subscribe system implementations.

13. The system of claim 10, a query that defines the interaction with the diverse publish/subscribe system implementations.

14. The system of claim 13, the query comprises one or more general-purpose, programming-language-integrated, query operators.

15. The system of claim 13, the query accounts for differences between stream formats.

16. The system of claim 10, the first component is configured to convert a stream produced by two or more publish/subscribe system implementations that communicate with each other into a uniform representation.

17. A computer-readable storage medium having instructions stored thereon that enables at least one processor to perform the following acts:

generating a message stream as a function of interaction with one or more publish/subscribe systems by way of a uniform interface.

18. The computer-readable storage medium of claim 17, generating the message stream based on a query, comprising one or more general-purpose, programming-language-integrated, query operators.

19. The computer-readable storage medium of claim 18, generating the message based on a query that accounts for differences in stream formats.

20. The computer-readable storage medium of claim 18 further comprises generating multiple message streams from a single message stream provided by one or the one or more publish/subscribe systems.