Publish/subscribe mechanism for web services

• US 7,958,515 B2
• Filed: 02/22/2005
• Issued: 06/07/2011
• Est. Priority Date: 05/23/2003
• Status: Active Grant

• Current Assignee: Computer Associates Think Inc. (Broadcom, Inc.)
• Original Assignee: Computer Associates Think Inc. (Broadcom, Inc.)
• Inventors: Tcherevik, Dmitri
• Primary Examiner(s): Truong; Lechi
• Application Number:
  US11/063,374
• Publication Number:
  US 20060080120A1
• Time in Patent Office: 2,296 Days
• Field of Search: 719/318, 719/331
• US Class Current: 719/318
• CPC Class Codes: G06F 16/958 Organisation or management of web site content, e.g. publishing, maintaining pages or automatic linking
• CPC Class Codes: G06F 9/542 Event management; Broadcasting; Multicasting; Notifications
• CPC Class Codes: G06Q 30/02 Marketing; Price estimation or determination; Fundraising
• CPC Class Codes: H04L 12/1859 adapted to provide push services, e.g. data channels
• CPC Class Codes: H04L 67/02 based on web technology, e.g. hypertext transfer protocol [HTTP]
• CPC Class Codes: H04L 67/51 Discovery or management thereof, e.g. service location protocol [SLP] or web services

Abstract

A method for managing events in a web service environment is provided. A request for a subscription to desired events in an event class in an associated catalog namespace of a catalog repository is received from a subscribing application. The subscription request includes an event filter to select the desired events from a plurality of events described by the event class. An event which is received from a web evens source and described by the event class is processed through the event filter. If the received event matches the event filter, the received event is forwarded to the subscribing application through an event listener associated with the subscribing application.

Claims

1. A computerized method for managing events in a web service environment, comprising:

receiving at a web service process on a computer system from a subscribing application a request for a subscription to desired events in an event class in an associated catalog namespace of a catalog repository, the subscription request including an event filter to select the desired events from a plurality of events described by the event class;

registering, by the web service process on the computer system, an event listener associated with the subscribing application;

processing, by the web service process on the computer system, through the event filter an event which is received from an event source and is described by the event class, the event received through an event gateway from the event source over the Internet through an Internet protocol;

notifying, by the web service process on the computer system, the subscribing application of the received event through the registered event listener, if the received event matches the event filter; and

forwarding the received event through a local messaging protocol to a local subscriber if the received event matches an event filter included in a subscription request of the local subscriber.

2. The method of claim 1 further comprising defining the event class in a schema of the associated catalog namespace of the catalog repository to advertise the plurality of events described by the event class.

3. The method of claim 1, wherein the method is implemented through a web service.

4. The method of claim 1, wherein the subscription request also includes an endpoint of the subscribing application, and the received event is forwarded to the endpoint if the received event matches the event filter.

5. The method of claim 1, wherein the subscription request also includes a name of the event class, which describes the desired events, and a path of the catalog namespace in which the event class is defined.

6. The method of claim 5, wherein the subscribing application retrieves a handle to the event class from the catalog repository to determine (i) the name of the event class which describes the desired events and (ii) the path of the catalog namespace in which the event class is defined.

7. The method of claim 1, wherein the event filter is a query defined on the event class.

8. The method of claim 1, wherein the event listener identifies an endpoint of the subscribing application.

9. The method of claim 1, wherein the subscribing application is notified of the received event over the Internet through an Internet protocol.

10. The method of claim 1 further comprising decoding the received event, creating an event object associated with the received event as a member of the event class describing the received event, and broadcasting the event object through registered event listeners.

11. The method of claim 1, wherein the event source raises the event by posting a message to an endpoint associated with the event class.

12. The method of claim 1 further comprising receiving a subscription request from a local subscriber, and notifying the local subscriber of the received event through a local messaging protocol if the received event matches the event filter.

13. A computer system, comprising:

a processor; and

a program storage device readable by the computer system, tangibly embodying a program of instructions executable by the processor to perform the method claimed in claim 1.

14. A program storage device readable by a machine, tangibly embodying a program of instructions executable by the machine to perform the method claimed in claim 1.

15. One or more computer-readable non-transitory storage media embodying software this is operable when executed by one or more computer systems to:

receive from a subscribing application a request for a subscription to desired events in an event class in an associated catalog namespace of a catalog repository, the subscription request including an event filter to select the desired events from a plurality of events described by the event class;

register an event listener associated with the subscribing application;

process, through the event filter, an event which is received from an event source and is described by the event class, the event received through an event gateway from the event source over the Internet through an Internet protocol;

notify the subscribing application of the received event through the registered event listener, if the received event matches the event filter; and

forward the received event through a local messaging protocol to a local subscriber if the received event matches an event filter included in a subscription request of the local subscriber.

16. An apparatus for managing events in a web service environment, comprising:

a processor;

a catalog repository comprising one or more catalog namespaces; and

a publish/subscribe web service including a subscription management component and an event processing component, the publish/subscribe web service being embodied on a computer-readable medium and having instructions for causing the processor to perform operations comprising;

receiving at the subscription management component from a subscribing application a request for a subscription to one or more desired events in an event class in a catalog namespace of the catalog repository, the subscription request including an event filter to select the one or more desired events from a plurality of events described by the event class;

registering, by the subscription management component, an event listener associated with the subscribing application; and

processing, by the event processing component, an event which is received from an event source, and, if the received event is described by the event class and matches the event filter, notifying the subscribing application of the received event through the registered event listener; and

an event gateway, wherein the event processing component is operable to;

receive the event through the event gateway from a web event source over the Internet through an Internet protocol; and

forward the received event through a local messaging protocol to a local subscriber if the received event matches an event filter included in a subscription request of the local subscriber.