High speed subscribe-and-alert service using content graphs
AssigneeMassachusetts Institute of Technology
InventorJoanna L. Kulik
Life of this patent
Estimating the term…
Abstract
Described are techniques used in connection with subscribe and alert services as may be embodied in a subscription system. The subscription system uses a preprocessor for preprocessing subscription and notification messages prior to submission to the subscription/publication server. The preprocessor outputs a preprocessed message including one or more identifiers categorizing an input subscription or notification message. The preprocessor uses a content graph to produce the preprocessed message. The subscription system uses a content based routing system with a tree-like topology to process preprocessed subscriptions and notifications using content graphs maintained at each node in the system. Also described is a loss detection technique using sequence numbers.
Claims34
A method for processing messages in a subscription system comprising:
- preprocessing a message using a content graph to produce a preprocessed message including an identifier in accordance with said message;
- and
- submitting said preprocessed message to a server for processing wherein said server performs at least one action in accordance with said identifier included in said preprocessed message, wherein said message is a subscription message and said preprocessed message includes an identifier matching said subscription message, and
- wherein said server includes a plurality of routers in a hierarchical arrangement, and the method further comprises:
- receiving said preprocessed message at a router of the plurality of routers;
- storing, at said router, information in a content graph of said router, the information including information about a subscription in accordance with said preprocessed message;
- and
- forwarding said preprocessed message to one or more upstream routers of the plurality of routers at a higher level in said hierarchical arrangement than said router in accordance with a forwarding table of said router.
A computer program product stored in a memory for processing messages in a subscription system comprising code that:
- preprocesses a message using a content graph to produce a preprocessed message including an identifier in accordance with said message;
- and
- submits said preprocessed message to a server for processing wherein said server performs at least one action in accordance with said identifier included in said preprocessed message, wherein said message is a subscription message and said preprocessed message includes an identifier matching said subscription message, and
- wherein said server includes a plurality of routers in a hierarchical arrangement, and the computer program product further comprising code that:
- receives said preprocessed message at a router of the plurality of routers;
- stores, at said router, information in a content graph of said router, the information including information about a subscription in accordance with said preprocessed message;
- and
- forwards said preprocessed message to one or more upstream routers of the plurality of routers at a higher level in said hierarchical arrangement than said router in accordance with a forwarding table of said router.
Dependencies are inferred from the claim text.