Automated delayed message redelivery

• US 9,716,684 B1
• Filed: 12/04/2015
• Issued: 07/25/2017
• Est. Priority Date: 12/16/2006
• Status: Active Grant

• Current Assignee: United Services Automobile Association
• Original Assignee: United Services Automobile Association
• Inventors: Bain, Frank L., Watson, James C.
• Primary Examiner(s): Butler, Sarai
• Application Number:
  US14/959,943
• Time in Patent Office: 599 Days
• Field of Search: 714 18
• CPC Class Codes: G06F 11/1443 Transmit or communication errors
• CPC Class Codes: G06F 2209/548 Queue
• CPC Class Codes: G06F 9/542 Event management; Broadcasting; Multicasting; Notifications
• CPC Class Codes: H04L 1/1848 Time-out mechanisms
• CPC Class Codes: H04L 51/23 Reliability checks, e.g. acknowledgments or fault reporting

Abstract

Method and system are disclosed for redelivering failed messages in asynchronous communication systems. The methods and systems automatically delay redelivery of such failed messages in order to allow required system resources to become available. In one implementation, the methods and systems provide two levels of redelivery: a micro level in which redelivery is attempted right away for a certain number of times, and a macro level in which a predefined, user-selectable delay is imposed before any additional micro level redeliveries are attempted. After a certain number of unsuccessful macro level redeliveries, the message is backed out to a backout queue for manual intervention by a system operator. Such an arrangement reduces or eliminates the burden on the system operator to manually resolve failed message deliveries.

Claims

1. A system comprising:

a processor; and

memory storing instructions that cause the processor to effectuate operations, the operations comprising;

modifying a message format of an event message upon occurrence of a predetermined event, said event message containing information pertaining to said predetermined event, said message format defining a data portion and an unused portion after modification;

storing message retry information to the unused portion based on said message format; and

publishing said event message to at least one subscriber.

2. The system according to claim 1, further comprising:

verifying that a publisher of the event message is authorized to publish the event message related to the predetermined event.

3. The system according to claim 1, wherein said retry information is stored to the unused portion at a point downstream of the publisher.

4. The system according to claim 1, wherein said message retry information includes one or more of the following:

a maximum number of immediate retries, a maximum number of delayed retries, a delayed retry counter, and a delay time.

5. The system according to claim 1, wherein said predetermined event includes a business level event.

6. The system according to claim 5, wherein said retry information includes information needed to retry an enrichment of said event message after waiting a predefined delay time.

7. The system according to claim 4, said delay time is based on downtime of system resources associated with one or more of the at least one subscriber.

8. A method comprising:

determining a message format of an event message associated with occurrence of a predetermined event, said event message containing information pertaining to said predetermined event;

modifying the message format of said event message, said message format designating a section of an unused portion for storing message retry information based on said format of said event message after modification; and

publishing said event message to at least one subscriber.

9. The method according to claim 8, wherein said predetermined event includes one or more of the following:

a device level event, a system level event, and an enterprise level event.

10. The method according to claim 8, wherein said publisher is a business application, said business application including one or more of the following:

a banking application, an insurance application, and a customer service application.

11. The method according to claim 8, further comprising:

retrying publication of said event message to the at least one subscriber based on said message retry information,

wherein said message retry information includes one or more of the following;

a maximum number of immediate retries, a maximum number of delayed retries, a delayed retry counter, and a delay time.

12. The method according to claim 8, wherein said unused portion includes a tag or header.

13. The method according to claim 12, wherein said retry information includes information needed to retry an enrichment of said event message after waiting a predefined delay time, the predefined delay time varies between two or more of the at least one subscriber.

14. The method according to claim 8, wherein said event message is published from said publisher to said at least one subscriber in an asynchronous manner.

15. A non-transitory computer-readable storage medium that is not a propagating signal, the non-transitory computer-readable storage medium encoded with computer readable instructions that cause a processor executing the computer readable instructions to effectuate operations, the operations comprising:

determining a message format of an event message associated with occurrence of a predetermined event, said event message containing information pertaining to said predetermined event;

modifying the message format of said event message, said message format designating a section of an unused portion of said event message for storing message retry information based on said format of said event message after modification; and

publishing said event message to at least one subscriber.

16. The non-transitory computer-readable storage medium that is not a propagating signal according to claim 15, said message format based on downstream processing of the event message after modification.

17. The non-transitory computer-readable storage medium that is not a propagating signal according to claim 15, wherein said retry information includes information needed to retry a customer change of address event.

18. The non-transitory computer-readable storage medium that is not a propagating signal according to claim 15, wherein said message retry information includes one or more of the following:

a maximum number of immediate retries, a maximum number of delayed retries, a delayed retry counter, and a delay time.

19. The non-transitory computer-readable storage medium that is not a propagating signal according to claim 18, wherein said delay time is stored in a subscriber configuration file.

20. The non-transitory computer-readable storage medium that is not a propagating signal according to claim 15, wherein said subscriber inserts message retry information on receipt of said event message.