Event locality using queue services
First Claim
Patent Images
1. A method for a multi-node system comprising a plurality of nodes, the method comprising:
- a first node of said plurality of nodes generating registration data, that for each node in said plurality of nodes, associates a named queue service with a message queue hosted on said each node, said first node generating said registration data at least in part in response to receipt of respective one or more messages from each other node of said plurality of nodes, said respective one or more messages being sent to register said each other node as owner of the respective message queue hosted on said each other node;
said first node sending a message to said each other node of said plurality of nodes to register said first node as owner of a respective message queue hosted on said first node; and
for said each other node of said plurality of nodes;
receiving from a client a connection request that requests the respective named queue service;
in response to receiving the connection request that requests the respective named queue service,based on said registration data, said first node determining that said each other node hosts said named queue service; and
said first node causing said client to connect to said each other node to interact with the respective message queue without having to transmit messages via said first node, wherein to interact with the respective message queue without having to transmit messages via said first node includes enqueuing or dequeuing messages from said message queue.
1 Assignment
0 Petitions
Accused Products
Abstract
An approach for reducing transport of messages between nodes of a multi-node system is presented wherein a message queue is associated with a queue service, and based on which node the message queue resides, one of the nodes is registered as hosting the associated queue service. In response to a client attempting to connect and requesting a particular queue service, the client is caused to connect to the node on which the queue service resides.
-
Citations
20 Claims
-
1. A method for a multi-node system comprising a plurality of nodes, the method comprising:
-
a first node of said plurality of nodes generating registration data, that for each node in said plurality of nodes, associates a named queue service with a message queue hosted on said each node, said first node generating said registration data at least in part in response to receipt of respective one or more messages from each other node of said plurality of nodes, said respective one or more messages being sent to register said each other node as owner of the respective message queue hosted on said each other node; said first node sending a message to said each other node of said plurality of nodes to register said first node as owner of a respective message queue hosted on said first node; and for said each other node of said plurality of nodes; receiving from a client a connection request that requests the respective named queue service; in response to receiving the connection request that requests the respective named queue service, based on said registration data, said first node determining that said each other node hosts said named queue service; and said first node causing said client to connect to said each other node to interact with the respective message queue without having to transmit messages via said first node, wherein to interact with the respective message queue without having to transmit messages via said first node includes enqueuing or dequeuing messages from said message queue. - View Dependent Claims (2, 3, 4, 5, 6, 7, 8, 9, 10)
-
-
11. A non-transitory computer-readable storage medium storing one or more sequences of instructions which, when executed by one or more processors, causes the one or more processors to perform the steps of:
-
a first node of said plurality of nodes generating registration data, that for each node in said plurality of nodes, associates a named queue service with a message queue hosted on said each node, said first node generating said registration data at least in part in response to receipt of respective one or more messages from each other node of said plurality of nodes, said respective one or more messages being sent to register said each other node as owner of the respective message queue hosted on said each other node; said first node sending a message to said each other node of said plurality of nodes to register said first node as owner of a respective message queue hosted on said first node; and for said each other node of said plurality of nodes; receiving from a client a connection request that requests the respective named queue service; in response to receiving the connection request that requests the respective named queue service, based on said registration data, said first node determining that said each other node hosts said named queue service; and said first node causing said client to connect to said each other node to interact with the respective message queue without having to transmit messages via said first node, wherein to interact with the respective message queue without having to transmit messages via said first node includes enqueuing or dequeuing messages from said message queue. - View Dependent Claims (12, 13, 14, 15, 16, 17, 18, 19, 20)
-
Specification