System and method for providing a messaging kernel
First Claim
1. A system to provide a messaging kernel, comprising:
- a server running on one or more processors;
one or more topics, each of said one or more topic operable to accept a plurality of messages from one or more producers;
a plurality of queues subscribed to at least one of said one or more topic, wherein each of said plurality of queues operable to deliver one or more messages of the plurality of messages to one or more consumers, wherein the one or more topic operable to multicast the plurality of messages to each queue of the plurality of queues;
a reference counter, residing on the server, that maintains a reference count that indicates a total number of times that a message of the plurality of messages is referenced by the plurality of queues, wherein the reference count is reduced by one whenever a reference to the message is removed, wherein only one copy of the message is stored in the messaging kernel, and the copy of the message is removed when the reference count is reduced to zero;
a cursor to support non-destructive viewing and manipulation of the one or more messages of the plurality of messages in a particular queue of the plurality of queues, wherein the cursor uses a filter to scan the one or more messages of the plurality of messages in the particular queue, and wherein the cursor uses a message list to provide a snapshot to a state of the particular queue, wherein the message list contains messages that match one or more criteria specified in the filter that is associated with the cursor.
2 Assignments
0 Petitions
Accused Products
Abstract
The present invention enables a messaging kernel to serve as the basis for asynchronous messaging in a Web service platform. The kernel provides basic messaging features, including point-to-point and publish/subscribe messaging, persistent and non-persistent messages, a variety of acknowledgement modes, two-phase commit transactions, quotas, statistics, message sorting, and message paging. It also includes some novel features that maintain message order based on application requirements. This description is not intended to be a complete description of, or limit the scope of, the invention. Other features, aspects, and objects of the invention can be obtained from a review of the specification, the figures, and the claims.
-
Citations
17 Claims
-
1. A system to provide a messaging kernel, comprising:
-
a server running on one or more processors; one or more topics, each of said one or more topic operable to accept a plurality of messages from one or more producers; a plurality of queues subscribed to at least one of said one or more topic, wherein each of said plurality of queues operable to deliver one or more messages of the plurality of messages to one or more consumers, wherein the one or more topic operable to multicast the plurality of messages to each queue of the plurality of queues; a reference counter, residing on the server, that maintains a reference count that indicates a total number of times that a message of the plurality of messages is referenced by the plurality of queues, wherein the reference count is reduced by one whenever a reference to the message is removed, wherein only one copy of the message is stored in the messaging kernel, and the copy of the message is removed when the reference count is reduced to zero; a cursor to support non-destructive viewing and manipulation of the one or more messages of the plurality of messages in a particular queue of the plurality of queues, wherein the cursor uses a filter to scan the one or more messages of the plurality of messages in the particular queue, and wherein the cursor uses a message list to provide a snapshot to a state of the particular queue, wherein the message list contains messages that match one or more criteria specified in the filter that is associated with the cursor. - View Dependent Claims (2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15)
-
-
16. A method to provide a messaging kernel, comprising:
-
accepting a plurality of messages from one or more producers via one or more topics; multicasting the plurality of messages to a plurality of queues subscribed to at least one of said one or more topic; delivering one or more messages of the plurality of messages in the plurality of queues to one or more consumers; using a reference counter, residing on a server, that maintains a reference count that indicates a total number of times that a message of the plurality of messages is referenced by the plurality of queues, wherein the reference count is reduced by one whenever a reference to the message is removed, wherein only one copy of the message is stored in the messaging kernel, and the copy of the message is removed when the reference count is reduced to zero; and using a cursor to support non-destructive viewing and manipulation of the one or more messages of the plurality of messages in a particular queue of the plurality of queues, wherein the cursor uses a filter to scan the one or more messages of the plurality of messages in the particular queue, and wherein the cursor uses a message list to provide a snapshot to a state of the particular queue, wherein the message list contains messages that match one or more criteria specified in the filter that is associated with the cursor.
-
-
17. A non-transitory machine readable medium having instructions stored thereon that when executed cause a system to:
-
accept a plurality of messages from one or more producers via one or more topics; multicast the plurality of messages to a plurality of queues subscribed to at least one of said one or more topic; deliver one or more messages of the plurality of messages in the plurality of queues to one or more consumers; use a reference counter, residing on a server, that maintains a reference count that indicates a total number of times that a message of the plurality of messages is referenced by the plurality of queues, wherein the reference count is reduced by one whenever a reference to the message is removed, wherein only one copy of the message is stored in a messaging kernel, and the copy of the message is removed when the reference count is reduced to zero; and use a cursor to support non-destructive viewing and manipulation of the one or more messages of the plurality of messages in a particular queue of the plurality of queues, wherein the cursor uses a filter to scan the one or more messages of the plurality of messages in the particular queue, and wherein the cursor uses a message list to provide a snapshot to a state of the particular queue, wherein the message list contains messages that match one or more criteria specified in the filter that is associated with the cursor.
-
Specification