Granted Patent B2

US 8,832,304 · App. 13/177,882 · Granted Sep 9, 2014

Abstract

Claims (50)

1. A method for providing subscription notifications, comprising the steps of:

using at least one processor to perform:

receiving, by a registrar, a request from a subscriber to register a subscription, the request including (i) an identifier of a topic, (ii) an identifier of a protocol corresponding to a first adaptor and supported by the subscriber, and (iii) a parameter associated with the protocol;

validating, by the first adaptor, the request to register the subscription based on the parameter;

storing the subscription as subscription data, including the identifier of the topic, an identifier of the first adaptor, and the parameter, if a determination is made by the validating that the subscription data is valid,

wherein the subscription data is organized as a hierarchical data structure including a plurality of topics and sub-topics, each of the topics and sub-topics being associated with one or more subscribers and adaptors;

receiving, from a publisher, a message to be published, the message including the identifier of the topic;

identifying, in the subscription data, a plurality of adaptors, including the first adaptor, to be used for the topic based on the identifier of the topic included in the message, wherein the plurality of adaptors corresponds to a plurality of protocols, respectively; and

publishing, by the plurality of adaptors using the plurality of protocols, respectively, a plurality of notifications corresponding to the message.

2. The method according to claim 1 , further comprising the steps of:

determining whether the first adaptor was used prior to the request; and

dynamically loading the first adaptor corresponding to the request if a determination is made by the determining that the first adaptor has not been used prior to the request.

3. The method according to claim 1 , wherein the parameter is one of a plurality of parameters included in the request, and wherein the validating step includes determining that the request includes the plurality of parameters that are required for the first adaptor to publish a corresponding one of the plurality of notifications using the protocol corresponding to the first adaptor.

4. The method according to claim 1 , further comprising the steps of:

transmitting, to the publisher, identifiers of the plurality of adaptors, thereby enabling the publisher to invoke calls to the plurality of adaptors to communicate the plurality of notifications, respectively.

5. The method according to claim 1 , wherein the request further includes a designation of the subscriber for the topic.

6. The method according to claim 1 , wherein a plurality of subscriptions are associated with each of the plurality of adaptors.

7. A system for providing subscription notifications, comprising:

at least one processor configured to perform as:

a registrar operable to receive, from a subscriber, a request to register a subscription, the request including (i) an identifier of a topic, (ii) an identifier of a protocol corresponding to a first adaptor and supported by the subscriber, and (iii) a parameter associated with the protocol;

a plurality of adaptors, including the first adaptor,

the first adaptor being operable to validate the request to register the subscription based on the parameter, and

the plurality of adaptors corresponding to a plurality of protocols, respectively,

the plurality of adaptors being operable to publish, using the plurality of protocols, respectively, a plurality of notifications corresponding to a message to be published;

a notifier operable to:

store the subscription as subscription data, including the identifier of the topic, an identifier of the first adaptor, and the parameter, if a determination is made by the validating that the subscription data is valid,

wherein the subscription data is organized as a hierarchical data structure including a plurality of topics and sub-topics, each of the topics and sub-topics being associated with one or more subscribers and adaptors,

receive, from a publisher, the message to be published, the message including the identifier of the topic, and

identify, in the subscription data, a plurality of adaptors, including the first adaptor, to be used for the topic based on the identifier of the topic included in the message.

8. The system according to claim 7 , wherein the registrar is further operable to determine whether the first adaptor was used prior to the request and cause the first adaptor corresponding to the request to be dynamically loaded if a determination is made that the first adaptor has not been used prior to the request.

9. The system according to claim 7 , wherein the parameter is one of a plurality of parameters included in the request, and wherein the adaptor is further operable to validate the request by determining that the request includes the plurality of parameters that are required for the first adaptor to publish a corresponding one of the plurality of notifications using the protocol corresponding to the first adaptor.

10. The system according to claim 7 , wherein the notifier is further operable to transmit, to the publisher, identifiers of the plurality of adaptors, thereby enabling the publisher to invoke calls to the plurality of adaptors to communicate the plurality of notifications, respectively.

11. The system according to claim 7 , wherein the request further includes a designation of the subscriber for the topic.

12. The system according to claim 7 , wherein a plurality of subscriptions are associated with each of the plurality of adaptors.

13. A non-transitory computer-readable medium having stored thereon instructions, which when executed by a computer system cause the computer system to perform:

receiving, by a registrar, a request from a subscriber to register a subscription, the request including (i) an identifier of a topic, (ii) an identifier of a protocol corresponding to a first adaptor and supported by the subscriber, and (iii) a parameter associated with the protocol;

validating, by the first adaptor, the request to register the subscription based on the parameter;

storing the subscription as subscription data, including the identifier of the topic, an identifier of the first adaptor, and the parameter, if a determination is made by the validating that the subscription data is valid,

wherein the subscription data is organized as a hierarchical data structure including a plurality of topics and sub-topics, each of the topics and sub-topics being associated with one or more subscribers and adaptors;

receiving, from a publisher, a message to be published, the message including the identifier of the topic;

identifying, in the subscription data, a plurality of adaptors, including the first adaptor, to be used for the topic based on the identifier of the topic included in the message, wherein the plurality of adaptors corresponds to a plurality of protocols, respectively; and

publishing, by the plurality of adaptors using the plurality of protocols, respectively, a plurality of notifications corresponding to the message.

14. The non-transitory computer-readable medium according to claim 13 , further comprising instructions, which when executed by the computer system cause the computer system to perform:

determining whether the first adaptor was used prior to the request; and

dynamically loading the first adaptor corresponding to the request if a determination is made by the determining that the first adaptor has not been used prior to the request.

15. The non-transitory computer-readable medium according to claim 13 , wherein the parameter is one of a plurality of parameters included in the request, and wherein the validating includes determining that the request includes the plurality of parameters that are required for the first adaptor to publish a corresponding one of the plurality of notifications using the protocol corresponding to the first adaptor.

16. The non-transitory computer-readable medium according to claim 13 , further comprising instructions, which when executed by the computer system cause the computer system to perform:

transmitting, to the publisher, identifiers of the plurality of adaptors, thereby enabling the publisher, to invoke calls to the adaptor plurality of adaptors to communicate the plurality of notifications, respectively.

17. The non-transitory computer-readable medium according to claim 13 , wherein the request further includes a designation of the subscriber for the topic.

18. The non-transitory computer-readable medium according to claim 13 , wherein a plurality of subscriptions are associated with each of the plurality of adaptors.

Assignments (16)