PUBLICATION OF INFORMATIONAL MESSAGES TO SOFTWARE APPLICATIONS IN A COMPUTING ENVIRONMENT

• US 20100011074A1
• Filed: 06/30/2009
• Published: 01/14/2010
• Est. Priority Date: 05/28/2004
• Status: Active Grant

• Current Assignee: eBay Inc.
• Original Assignee: eBay Inc.
• Inventors: Tai, Sheio-Hsien, Kao, Daniel T., Billingsley, Eric, Wong, Laura
• Granted Patent: US 7,979,407 B2
• Time in Patent Office: Days
• US Class Current: 709/206
• CPC Class Codes: G06Q 10/10 Office automation; Time management
• CPC Class Codes: G06Q 30/06 Buying, selling or leasing transactions

Abstract

Systems and methods for publishing information to a plurality of software applications are provided. The methods may comprise identifying a plurality of records to transmit to the software applications based on a last sequential identification code in a high watermark table of a persistent store. The plurality of records may be generated subsequent to a previous record corresponding to the last sequential identification code. A plurality of corresponding messages each corresponding to a record of the plurality of records may be prepared. Each of those messages may then be transmit to at least one software application and may include a most recent message corresponding to a most recent record. In the high water mark table of the persistent store, an updated last sequential identification code may be stored as a pointer for subsequent reference. The updated last sequential identification code may correspond to the most recent message transmitted in the plurality of corresponding messages.

Claims

1. A method for publishing information to a plurality of software applications comprising:

identifying, based on a last sequential identification code in a high watermark table of a persistent store, a plurality of records to transmit to the plurality of software applications, the plurality of records generated subsequent to a previous record corresponding to the last sequential identification code;

preparing a plurality of corresponding messages, each corresponding message corresponding to a record of the plurality of records;

transmitting each message of the plurality of corresponding messages to at least one software application of the software applications, the plurality of corresponding messages including a most recent message corresponding to a most recent record; and

storing, in the high water mark table of the persistent store, an updated last sequential identification code corresponding to the most recent message transmitted in the plurality of corresponding messages, the updated last sequential identification code being stored as a pointer for subsequent reference.

2. The method of claim 1, wherein each record of the plurality of records is associated with an occurrence of an event in which the persistent store is modified.

3. The method of claim 1, wherein the identifying of the plurality of records to transmit is based, in part, on a request for retransmission of the previous record corresponding to the last sequential identification code.

4. The method of claim 1, further comprising:

receiving a request for retransmission of a message corresponding to a particular record, the particular record being identified in the request by a particular respective identification code; and

retransmitting the message corresponding to the particular record.

5. The method of claim 4, further comprising:

adding the request for retransmission to a queue;

intermittently processing a plurality of requests for retransmission in the queue, the processing for each request comprising retrieving information from the persistent store and preparing a corresponding message including the retrieved information.

6. The method of claim 5, further comprising:

awaiting elapse of a predetermined period of time between adding the request for the retransmission to the queue and retransmitting the message.

7. The method of claim 5, further comprising:

deleting from the queue a duplicate request identical to another request in the queue.

8. The method of claim 4, further comprising:

retrieving the message corresponding to the particular record from a cache.

9. The method of claim 1, wherein at least a first portion of each record of the plurality of records is stored in a main table of the persistent store and at least a second portion of each record is stored in a shadow table of the persistent store.

10. The method of claim 9, wherein the shadow table is configured as an index ordered table.

11. The method of claim 9, wherein the second portion and the first portion contain overlapping data.

12. The method of claim 9, wherein the shadow table includes the contents of each record and a corresponding sequential identification code of each record.

13. The method of claim 1, further comprising:

periodically updating the high water mark table using a timer.

14. The method of claim 1, wherein the preparing of the plurality of corresponding messages comprises reading the plurality of records from a view.

15. The method of claim 1, wherein the plurality of software applications comprises independent software applications.

16. A system to publish information to a plurality of software applications, the system comprising:

a processor;

a memory operably connected to the processor; and

instructions stored in the memory and executable by the processor to cause said system to;

identify, based on a last sequential identification code in a high watermark table of a persistent store in a memory of a computer system, a plurality of records to transmit to the plurality of software applications, the plurality of records generated subsequent to a previous record corresponding to the last sequential identification code;

prepare a plurality of corresponding messages, each corresponding message corresponding to a record of the plurality of records;

transmit each message of the plurality of corresponding messages to at least one software application of the plurality of software applications, the plurality of corresponding messages including a most recent message corresponding to a most recent record; and

store, in the high water mark table of the persistent store, an updated last sequential identification code corresponding to the most recent message transmitted in the plurality of corresponding messages, the updated last sequential identification code being stored as a pointer for subsequent reference.

17. The system of claim 16, wherein at least a first portion of each record of the plurality of records is stored in a main table of the persistent store and at least a second portion of each record is stored in a shadow table of the persistent store.

18. The system of claim 16, wherein each record of the plurality of records is associated with an occurrence of an event in which the persistent store is modified.

19. A computer-readable medium comprising computer readable program code configured to carry out, a method for publishing information to a plurality of software applications, the method comprising:

identifying, based on a last sequential identification code in a high watermark table of a persistent store in a memory of a computer system, a plurality of records to transmit to the plurality of software applications, the plurality of records generated subsequent to a previous record corresponding to the last sequential identification code;

preparing a plurality of corresponding messages, each corresponding message corresponding to a record of the plurality of records;

transmitting each message of the plurality of corresponding messages to at least one software application of the computer system, the plurality of corresponding messages including a most recent message corresponding to a most recent record; and

storing, in the high water mark table of the persistent store, an updated last sequential identification code corresponding to the most recent message transmitted in the plurality of corresponding messages, the updated last sequential identification code being stored as a pointer for subsequent reference.

20. The computer-readable medium of claim 19, wherein the method further comprises:

receiving a request for retransmission of a message corresponding to a particular record, the particular record being identified in the request by a particular respective identification code; and

retransmitting the message corresponding to the particular record.