Asynchronous mechanism and message pool

Abstract

In some disclosed aspects, a method of delivering messages over an electronic network includes retrieving, via an electronic processor, a first message from a message pool, determining, via the electronic processor, a delay associated with obtaining an identity of a remote receiver device of the retrieved first message, transmitting the first message to the remote receiver device if the delay is less than a threshold and storing the first message in a data store if the delay is greater than the threshold.

What is claimed is: 
     
         1 . A method of delivering messages over an electronic network, comprising:
 retrieving, via an electronic processor, a first message from a message pool;   determining, via the electronic processor, a delay associated with obtaining an identity of a remote receiver device of the retrieved first message;   transmitting the first message to the remote receiver device if the delay is less than a threshold; and   storing the first message in a data store if the delay is greater than the threshold.   
     
     
         2 . The method of  claim 1 , further comprising:
 storing the first message in a data store; and   retrieving a second message from the message pool while the first message is stored in the data store.   
     
     
         3 . The method of  claim 2 , further comprising:
 assigning a priority to the first message; and   assigning a priority to the second message, the second priority higher than the first priority.   
     
     
         4 . The method of  claim 1 , further comprising:
 receiving a signal from the remote receiver device that it is ready to receive the first message;   retrieving the first message from the data store in response to the received signal; and   transmitting the first message to the remote receiver device;   
     
     
         5 . The method of  claim 1 , further comprising:
 determining that a predetermined time period has passed since the first message was stored in the data store; and   storing the first message to a second transient data store based on the determination.   
     
     
         6 . The method of  claim 1 , further comprising:
 receiving a plurality of messages from the message pool;   writing each of the plurality of messages to one of a plurality of output queues based on information included in each message.   
     
     
         7 . The method of  claim 6 , wherein the information included in each message comprises one or more of a domain name of the remote receiver and a priority indication. 
     
     
         8 . The method of  claim 6 , wherein each of the plurality of output queues has an associated priority. 
     
     
         9 . The method of  claim 8 , further comprising transmitting messages from the plurality of output queues based on the associated priorities. 
     
     
         10 . The method of  claim 6 , further comprising:
 determining whether the first message has been previously transmitted;   writing the first message to a first output queue if the message was previously transmitted;   writing the first message to a second output queue if the message was not previously transmitted; and   prioritizing transmission of messages on the first output queue over writing of messages on the second output queue.   
     
     
         11 . An apparatus for delivering messages, comprising:
 a delivery processor configured to:
 retrieve a first message from a message pool, 
 determine a delay associated with obtaining an identity of a remote receiver of the retrieved first message, and 
 transmit the first message to the remote receiver if the delay is less than a threshold; and 
   a memory having one or more cells of a predetermined size, the delivery processor configured to store the first message in the memory if the delay is greater than the threshold.   
     
     
         12 . The apparatus of  claim 11 , further comprising:
 storing the first message in a data store; and   retrieving a second message from the message pool while the first message is stored in the data store.   
     
     
         13 . The apparatus of  claim 12 , further comprising:
 assigning a priority to the first message; and   assigning a priority to the second message, the second priority higher than the first priority.   
     
     
         14 . The apparatus of  claim 11 , wherein the delivery processor is further configured to:
 receive a signal from the remote receiver that it is ready to receive the first message;   retrieve the first message from the memory in response to the received signal; and   transmit the first message to the remote receiver;   
     
     
         15 . The apparatus of  claim 11 , wherein the delivery processor is further configured to:
 determine that a predetermined time period has passed since the first message was stored in the data store; and   store the first message to a second transient memory based on the determination.   
     
     
         16 . The apparatus of  claim 11 , wherein the delivery processor is further configured to:
 receive a plurality of messages from the message pool;   write each of the plurality of messages to one of a plurality of output queues based on information included in each message.   
     
     
         17 . The apparatus of  claim 16 , wherein the information included in each message comprises one or more of a domain name of the remote receiver and a priority indication. 
     
     
         18 . The apparatus of  claim 16 , wherein each of the plurality of output queues has an associated priority. 
     
     
         19 . The apparatus of  claim 18 , wherein the delivery processor is further configured to transmit messages from the plurality of output queues based on the associated priorities. 
     
     
         20 . The apparatus of  claim 16 , wherein the delivery processor is further configured to:
 determine whether the first message has been previously transmitted;   write the first message to a first output queue if the message was previously transmitted;   write the first message to a second output queue if the message was not previously transmitted; and   prioritize transmission of messages on the first output queue over writing of messages on the second output queue.