CPC G06F 3/1236 (2013.01) [G06F 3/1203 (2013.01); G06F 3/1285 (2013.01)] | 18 Claims |
1. A system, comprising:
memory; and
one or more processors in communication with the memory, the one or more processors configured to:
assign, by a leader, a range of addresses of a database to each of a plurality of coordinators, wherein each coordinator manages communications with a subset of one or more peripheral devices connected to the system;
receive, by a writer, an incoming message;
enqueue, by the writer, the message in the database; and
notify, by the writer based on an address of the enqueued message, one of the plurality of coordinators having the range of addresses that includes the address of the enqueued message.
|
11. A method, comprising:
connecting a recipient device to a reader of a queued message service (QMS) node;
receiving, at a writer of the QMS node, a message for the recipient device;
writing, by the writer of the QMS node, a payload of the message to a database;
notifying, by the writer, a coordinator of the QMS node that the message was written to the database; and
based on a status of the recipient device, instructing, by the coordinator, the reader to deliver the message from the database to the recipient device.
|