Systems and methods for guaranteeing delivery of pushed data to remote clients
Systems and methods are provided, which provide for validation of message delivery utilizing push functionality. Such systems and methods expedite delivery of data while utilizing reliable periodic pull to validate message delivery by querying a group or groups of recipients. The invention may then receive responses from execution of periodic pull functionality and initiate known tasks or preconfigured actions in accordance with any particular response received or not received.
1. A system for the guaranteed delivery of data to remote consumers, comprised of
a data publishing source managing messages within a message queue,
a message identifier associated to each message and thereafter retained by the data publishing source,
a persistent push channel through which said messages can be sent,
a consumer which receives messages and associated message identifier,
a messaging sequencer facilitating the identification of said message identifier of said messages received by a consumer,
a periodic pull request from the consumer to the data publishing source comprised of the last message identifier received by the consumer,
a validation performed by the data publishing source comparing the message identifier sent by the consumer as part of said periodic pull request against the last message identifier sent by the data publishing source.
2. The system of claim 1 , wherein an instruction to initiate synchronization activities is returned to said consumer by said data publishing source when a validation error is detected.
3. The system of claim 1 , wherein an instruction to take no further action is returned to said consumer by said data publishing source when a validation error is detected.
4. The system of claim 1 , wherein the data publishing source associates said message identifier and a timestamp to messages.
5. The system of claim 1 , wherein said data publishing source associates a timestamp with each message in addition to said message identifier.
6. The system of claim 1 , wherein the messaging sequencer initiatives a request for messages identified as missed by a consumer.
7. The system of claim 1 , wherein the data publishing source notifies consumer to initiate synchronization activities when said validation performed by said data publishing source identifies the consumer sent message identifier to be out of synchronization with the message identifier last sent from the data publishing source.
8. The system of claim 1 , wherein said consumer utilizes a threshold time to determine how long the consumer will wait for actual delivery of a message before initiating synchronization activities.
9. The system of claim 1 , wherein said message sequencer reorganizes messages into correct sequence when out of order delivery is identified.
10. The system of claim 1 , wherein said encryption enabling software is utilized to encrypt messages while in transit between said data publishing source and said consumer or said consumer and said data publishing source.
11. A method for guaranteed delivery of data to remote consumers, comprising the following steps:
a data publishing source manages messages within a message queue,
a message identifier is associated to each message and thereafter retained by the data publishing source,
said messages are sent through persistent push channel,
said messages and associated message identifier are received by a consumer,
a messaging sequencer facilitates the identification of message identifier of messages received by a consumer,
a periodic pull request is made from the consumer to the data publishing source comprised of the last message identifier received by the consumer,
a validation is performed by the data publishing source comparing the message identifier sent by the consumer as part of said periodic pull request against the last message identifier sent by the data publishing source.
12. The method of claim 11 , wherein an instruction to initiate synchronization activities is returned to said consumer by said data publishing source when a validation error is detected.
13. The method of claim 11 , wherein an instruction to take no further action is returned to said consumer by said data publishing source when a validation error is detected.
14. The method of claim 11 , wherein the data publishing source associates said message identifier and a timestamp to messages.
15. The method of claim 11 , wherein said data publishing source associates a timestamp with each message in addition to said message identifier.
16. The method of claim 11 , wherein the messaging sequencer initiatives a request for messages identified as missed by a consumer.
17. The method of claim 11 , wherein the data publishing source notifies consumer to initiate synchronization activities when said validation performed by said data publishing source identifies the consumer sent message identifier to be out of synchronization with the message identifier last sent from the data publishing source.
18. The method of claim 11 , wherein said consumer utilizes a threshold time to determine how long the consumer will wait for actual delivery of a message before initiating synchronization activities.
19. The method of claim 11 , wherein said message sequencer reorganizes messages into correct sequence when out of order delivery is identified.
20. The method of claim 11 , wherein said encryption enabling software is utilized to encrypt messages while in transit between said data publishing source and said consumer or said consumer and said data publishing source.