Message brokering for asynchronous status updates
View Patent ↗One example method of operation may include one or more of receiving one or more messages from one or more clients, transmitting receipt notice messages acknowledging the one or more messages were received, assigning the one or more messages to a first thread of a various threads in a thread pool, and determining whether the messages are processed in a threshold amount of time assigned to the first thread.
1. A method, comprising:
receiving one or more messages from one or more clients;
transmitting one or more receipt notice messages acknowledging the one or more messages were received;
determining whether a first condition exists;
assigning the one or more messages from a first thread pool to a second thread pool when the first condition exists;
processing the one or more messages based on whether a second condition exists, wherein the second condition is different from the first condition and includes a second predetermined responsiveness of at least one destination server; and
delivering the one or more messages, wherein the one or more messages correspond to an address of the at least one destination server and wherein the first condition includes a first predetermined responsiveness of the at least one destination server, wherein the first predetermined responsiveness is different from the second predetermined responsiveness.
2. The method of claim 1 , wherein
the first thread pool includes a thread lane having a first threshold time requirement corresponding to the first predetermined responsiveness, and
the second thread pool includes a second thread lane having a second threshold time requirement corresponding to the second predetermined responsiveness.
3. The method of claim 1 , wherein the the first predetermined responsiveness corresponds to at least one of a time of responsiveness of the at least one destination server relative to at least one prior message or at least one prior message not reaching the at least one destination server.
4. The method of claim 1 wherein:
the first condition includes the one or more messages not being processed within a first amount of time assigned to the first thread pool,
the second condition includes whether the one or more messages are processed within a second amount of time assigned to the second thread pool.
5. The method of claim 1 , further comprising assigning the one or more messages to the second thread pool when the first thread pool has exceeded a predetermined capacity.
6. The method of claim 1 , wherein:
the first predetermined responsiveness is a time responsiveness in a first range, and
the second predetermined responsiveness is a time responsiveness in a second range less than the first range.
7. The method of claim 1 , further comprising:
determining that the second condition does not exist; and
storing the one or more messages in a queue for a predefined amount of time and scheduling the one or more messages to be processed once the predefined amount of time has lapsed.
8. An apparatus, comprising:
a receiver configured to receive one or more messages from one or more clients;
a transmitter configured to transmit one or more receipt notice messages that acknowledges the one or more messages were received; and
a processor configured to:
determine whether a first condition exists;
assign the one or more messages from a first thread pool to a second thread pool when the first condition exists;
process the one or more messages based on whether a second condition exists, wherein the second condition is different from the first condition and includes a second predetermined responsiveness of at least one destination server; and
deliver the one or more messages, wherein the one or more messages correspond to an address of the at least one destination server and wherein the first condition includes a first predetermined responsiveness of the at least one destination server, wherein the first predetermined responsiveness is different from the second predetermined responsiveness.
9. The apparatus of claim 8 , wherein:
the first thread pool includes a thread lane having a first threshold time requirement corresponding to the first predetermined responsiveness, and
the second thread pool includes a second thread lane having a second threshold time requirement corresponding to the second predetermined responsiveness.
10. The apparatus of claim 8 , wherein the the first predetermined responsiveness corresponds to at least one of a time of responsiveness of the at least one destination server relative to at least one prior message or at least one prior message not reaching the at least one destination server.
11. The apparatus of claim 8 , wherein:
the first condition includes the one or more messages not being processed within a first amount of time assigned to the first thread pool,
the second condition includes whether the one or more messages are processed within a second amount of time assigned to the second thread pool.
12. The apparatus of claim 8 , wherein the processor is further configured to assign the one or more messages to the second thread pool when the first thread pool has exceeded a predetermined capacity.
13. The apparatus of claim 8 , wherein:
the first predetermined responsiveness is a time responsiveness in a first range, and
the second predetermined responsiveness is a time responsiveness in a second range less than the first range.
14. The apparatus of claim 8 , wherein the processor is further configured to
determining that the second condition does not exist; and
storing the one or more messages in a queue for a predefined amount of time and scheduling the one or more messages to be processed once the predefined amount of time has lapsed.
15. A non-transitory computer readable storage medium configured to store instructions that when executed cause a processor to perform:
receiving one or more messages from one or more clients;
transmitting one or more receipt notice messages acknowledging the one or more messages were received;
determining whether a first condition exists;
assigning the one or more messages from a first thread pool to a second thread pool when the first condition exists;
processing the one or more messages based on whether a second condition exists, wherein the second condition is different from the first condition and includes a second predetermined responsiveness of at least one destination server; and
delivering the one or more messages, wherein the one or more messages correspond to an address of the at least one destination server and wherein the first condition includes a first predetermined responsiveness of the at least one destination server, wherein the first predetermined responsiveness is different from the second predetermined responsiveness.
16. The non-transitory computer readable storage medium of claim 15 , wherein:
the first thread pool includes a thread lane having a first threshold time requirement corresponding to the first predetermined responsiveness, and
the second thread pool includes a second thread lane having a second threshold time requirement corresponding to the second predetermined responsiveness.
17. The non-transitory computer readable storage medium of claim 15 , wherein the the first predetermined responsiveness corresponds to at least one of a time of responsiveness of the at least one destination server relative to at least one prior message or at least one prior message not reaching the at least one destination server.
18. The non-transitory computer readable storage medium of claim 15 , wherein:
the first condition includes the one or more messages not being processed within a first amount of time assigned to the first thread pool,
the second condition includes whether the one or more messages are processed within a second amount of time assigned to the second thread pool.
19. The non-transitory computer readable storage medium of claim 15 , wherein assigning the one or more messages to the second thread pool is performed when the first thread pool has exceeded a predetermined capacity.
20. The non-transitory computer readable storage medium of claim 15 , wherein:
the first predetermined responsiveness is a time responsiveness in a first range,
the second predetermined responsiveness is a time responsiveness in a second range less than the first range, and
wherein the processor is to further perform: storing the one or more messages in a queue for a predefined amount of time and scheduling the one or more messages to be processed once the predefined amount of time has lapsed.