Object connectivity through loosely coupled publish and subscribe events

• US 6,829,770 B1
• Filed: 02/23/1999
• Issued: 12/07/2004
• Est. Priority Date: 02/23/1999
• Status: Expired due to Term

• Current Assignee: Microsoft Technology Licensing LLC (Microsoft Corporation)
• Original Assignee: Microsoft Corporation
• Inventors: McCrady, Donald J., Pollack, Seth B., Dumitru, Donald W., Swartz, Stephen T., Hinson, Gerald L., Al-Ghosein, Mohsen
• Primary Examiner(s): An, Meng-Al T.
• Assistant Examiner(s): NGUYEN, VAN H
• Application Number:
  US09/257,363
• Time in Patent Office: 2,114 Days
• Field of Search: 709/100, 709/318, 709/201, 709/310, 709/206, 709/328
• US Class Current: 719/318
• CPC Class Codes: G06F 2209/543 Local
• CPC Class Codes: G06F 9/4488 Object-oriented
• CPC Class Codes: G06F 9/542 Event management; Broadcasting; Multicasting; Notifications

Abstract

An object-based event communications system supplies an event distribution object having an outgoing-from-publisher event interface and associated with unique identifiers defined for a publisher that is programmed to fire events by calling a method on the event distribution object'"'"'s outgoing-from-publisher event interface. The event communications system stores subscriptions of subscriber objects to methods of the outgoing-from-publisher event interface. On receiving a call from a publisher to its outgoing-from-publisher interface methods, the event distribution object multi-casts calls to counterpart methods of subscriber objects that have stored subscriptions to the respective outgoing-from-publisher interface methods.

Claims

1. An event communications system on a computer for efficiently distributing event information in software programmed according to an object model, the software having a publisher object and a subscriber object wherein the publisher object has code to call a method on an outgoing interface to signal an event and lacks information about an identity of the subscriber object, and wherein the subscriber object exposes an interface that receives a method call, the system comprising:

a data storage separate from the publisher and subscriber objects for storing subscriptions externally of the publisher and subscriber objects, a subscription out of the stored subscriptions representing a relationship of the subscriber object to an outgoing interface method and serving to link the publisher'"'"'s call to the outgoing interface method over to the subscriber object; and

an event handling object exposing the outgoing interface and having code of the outgoing interface method operative in response to the publisher object'"'"'s call to retrieve the subscription and issue the method call to the subscriber object interface based on the subscription so as to thereby deliver the event to the subscriber object;

wherein the interface exposed by the subscriber object matches the outgoing interface exposed by the event handling object.

2. The system of claim 1, wherein the event handling object is external to the publisher object and wherein the matching interfaces have identical interface structures.

3. The system of claim 1, wherein at least one of the subscriptions identifies the subscriber object by a class identifier associated with a class of the subscriber object, whereby the subscriber object need not be instantiated at a time that said at least one subscription is created and at a time that the publisher object calls the method on the outgoing interface to signal the event.

4. The system of claim 1, wherein another of the subscriptions identifies the subscriber object by an interface pointer directly linking to the interface of the subscriber object.

5. The system of claim 1, wherein the data storage persistently stores the subscriptions to survive interruptions in the subscriber object'"'"'s lifetime.

6. The system of claim 1 further comprising a subscription creation service for a program outside the subscriber object to programmatically create the subscription for the subscriber object, and store the subscription in the data storage.

7. A computer-readable storage medium having computer-executable program code stored thereon to implement an object-oriented event communications model for distributing events from a publisher to any subscribers of the events, the publisher being programmed to issue an event as a call to a method on an outgoing event interface exposed by an object which outgoing event interface and object are identified by unique identifiers defined for the publisher, the program code comprising:

code associating the unique identifiers to an event distribution object class having the outgoing event interface; and

object server code for supplying an event distribution object of the event distribution object class, the event distribution object having distribution code operative in response to the publisher'"'"'s call that issues the event so as to distribute the event to the event'"'"'s respective subscribers;

wherein the event'"'"'s subscribers expose counterpart outgoing event interfaces, and the distribution code multi-casts calls to methods on the counterpart outgoing event interfaces matching the publisher'"'"'s call.

8. The computer-readable storage medium of claim 7, wherein the outgoing event interface exposed by the distribution object has an interface definition defined for the publisher.

9. In a computer system, an event distribution object associated with a outgoing event interface definition, an identifier of the event distribution object'"'"'s class, and an identifier of an outgoing event interface, all defined for a publisher programmed to call methods of the outgoing event interface to cause the event distribution object to distribute events, the event distribution object comprising:

an outgoing event interface supported by the event distribution object and defined per the outgoing event interface definition of the publisher,

a plurality of subscribeable methods exposed through the outgoing event interface;

a multicasting distribution program loop operative in response to a publisher'"'"'s call to a subscribeable method of the outgoing event interface to determine any subscribers to the subscribeable method and issue calls to counterpart methods of said any subscribers; and

plural subscriptions comprising at least one transient subscription indicating a relationship of a subscriber to an event as indicated by an interface identifier of an instance of a subscriber as a subscriber reference and at least one persistent subscription indicating a relationship of a subscriber to an event as indicated by a class identifier as a subscriber reference;

wherein the outgoing event interface supported by the event distribution object matches an interface to counterpart methods of said any subscribers.