Method and system for messaging to a cluster
AssigneeSun Microsystems, Inc.
InventorsVenkateshwara T V, Ajay Kumar
Life of this patent
Estimating the term…
Abstract
A system and method for distributing and processing messages in a clustered environment may have a message producer, a message middleware component, and at a clustered message consumer coupled to the message middleware component through a router. The router may be configured to receive messages, select a node of the clustered consumer to handle each message, and send each message to a queue for the selected node. The router may balance a message load across the clustered nodes. The router of the clustered consumer may ensure that each message is processed by only one message consumer node of the cluster.
Claims24
A system, comprising:
- a message producer;
- a message middleware component configured to receive messages from the message producer;
- a cluster of nodes comprising at least two nodes;
- and
- a router configured to:
- receive a message from the message middleware component;
- select one of the at least two nodes to process the received message for the cluster, wherein each of the nodes of the cluster is operable to process the received message to produce a message result for the cluster;
- and
- send the received message to a queue for the selected node so that only one of the nodes in the cluster processes the message to produce the message result for the cluster.
A method, comprising:
- receiving a plurality of messages at a clustered message consumer comprising a plurality of message consumer nodes;
- for each message of the plurality of messages, selecting one of the nodes of the clustered message consumer to process the message to produce a message result, wherein each of the plurality of message consumer nodes is operable to process the message to produce a message result for the clustered message consumer;
- and
- routing each message of the plurality of messages to a queue of only the node in the clustered message consumer selected for that message so that each message is processed by only one message consumer node of the clustered message consumer.
A computer-readable storage medium comprising program instructions, wherein the program instructions are computer-executable to implement:
- receiving a plurality of messages at a clustered message consumer comprising a plurality of message consumer nodes;
- for each message of the plurality of messages, selecting one of the nodes of the clustered message consumer to process the message to produce a message result, wherein each of the plurality of message consumer nodes is operable to process the message to produce a message result for the clustered message consumer;
- and
- routing each message of the plurality of messages to a queue of only the node in the clustered message consumer selected for that message so that each message is processed by only one message consumer node of the clustered message consumer.
Dependencies are inferred from the claim text.