Dynamic partitioning of messaging system topics
AssigneeInternational Business Machines Corporation
InventorGabriel Garcia Montero
Life of this patent
Estimating the term…
Abstract
A dynamic topic partitioning messaging system. The messaging system can include a message server; one or more topics stored in the message server; one or more subtopics associated with at least one of the topics in the message server; and, a dynamic topic partitioning system configured to partition the topics into the subtopics. Notably, the message server can be Java message service (JMS) compliant. In that regard, the message server can reside in a single process address space. For example, the process address space can be a Java virtual machine (JVM).
Claims9
A messaging system comprising:
- at least one message server;
- a plurality of topics stored in said at least one message server;
- a plurality of subtopics associated with at least one of said topics in said at least one message server;
- and,
- a dynamic topic partitioning system configured to partition said at least one of said topics into said subtopics.
A dynamic topic partitioning system comprising:
- a message interface through which message publishers can post messages to selected topics, and from which message subscribers can request messages which have been published to selected topics;
- a subtopic store configured to distribute messages of said selected topics within associated subtopics;
- and,
- a request processor in which requests to post and retrieve messages to and from individual ones of said selected topics can be converted into message system requests to respectively post and retrieve messages to and from said associated subtopics in said subtopic store, said request processor processing each of said converted message system requests in individual threads of execution.
A message system servicing method comprising the steps of:
- intercepting message requests for a selected topic from subscribers in the message system;
- associating said message requests with a plurality of subtopics created for said selected topic;
- and,
- servicing said message requests with messages in said subtopics from within separate threads of execution for each subtopic-subscriber pair.
A machine readable storage having stored thereon a computer program for performing message system servicing, said computer program comprising a routine set of instructions for causing the machine to perform the steps of:
- intercepting message requests for a selected topic from subscribers in the message system;
- associating said message requests with a plurality of subtopics created for said selected topic;
- and,
- servicing said message requests with messages in said subtopics from within separate threads of execution for each subtopic-subscriber pair.
Dependencies are inferred from the claim text.