Distributed nonstop architecture for an event processing system

• US 7,257,611 B1
• Filed: 05/02/2000
• Issued: 08/14/2007
• Est. Priority Date: 04/12/2000
• Status: Expired due to Term

• Current Assignee: Oracle International Corporation (Oracle Corporation)
• Original Assignee: Oracle International Corporation (Oracle Corporation)
• Inventors: Shankar, Ravi, Labuda, David S.
• Primary Examiner(s): WON, MICHAEL YOUNG
• Application Number:
  US09/562,785
• Time in Patent Office: 2,660 Days
• Field of Search: 705/30, 705/32, 709/208, 709/201, 709/209, 709/225, 709/229, 709/212, 709/318, 709/205, 709/211, 709/217, 709/234, 709/203, 709/218, 709/219, 709/202, 709/223, 709/224, 455/2.01, 455/3.02, 455/405, 713/323
• US Class Current: 709/201
• CPC Class Codes: G06Q 10/1091 Recording time for administrative or management purposes
• CPC Class Codes: G06Q 40/02 Banking, e.g. interest calculation or account maintenance credit or loans G06Q40/03
• CPC Class Codes: G06Q 40/12 Accounting
• CPC Class Codes: H04L 47/10 Flow control; Congestion control
• CPC Class Codes: H04L 69/40 for recovering from a failure of a protocol instance or entity, e.g. service redundancy protocols, protocol state redundancy or protocol service redirection management of faults, events, alarms or notifications in data switching networks H04L41/06

Abstract

Methods and architectures for implementing a fault tolerant real time event processing system are provided. The system includes at least one satellite and at least one primary data center. The system remains operational when the primary data center is unavailable to the satellite. The system includes business logic that is divided into logic that can be run effectively at a satellite, and logic that can be run at the main data center to result in effective decisions. When the network connection is impaired or the main data center is unavailable, the satellite can process an incoming event locally. The system includes procedures so that events processed at a satellite during a period of noncommunication with the primary data center will be entered into the primary data center records at a later point.

Claims

1. A method for processing an event in a system comprising a satellite and a primary data center, comprising:

receiving an event at the satellite, the event corresponding to a service request from a user, the event including an indication of an account of the user;

the satellite determining whether the primary data center is available for processing the event, wherein the satellite determining whether the primary data center is available for processing the event includes the satellite sending a query to the primary data center and the satellite determining whether the primary data center responds to the query within a configurable interval, and wherein when the satellite determines that the primary data center responds to the query within the configurable interval, the primary data center is available;

if the primary data center is available, processing the event in connect mode by;

transmitting the event to the primary data center; and

executing first business logic at the primary data center, wherein the first business logic includes logic and data for processing events when the satellite is in connect mode, and

if the primary data center is unavailable, processing the event in disconnect mode by;

executing second business logic at the satellite, wherein the second business logic includes logic and data different from the first business logic for processing events when the satellite is in disconnect mode, and

storing information associated with the event at the satellite for later communication to the primary data center.

2. A method as in claim 1, wherein processing the event in disconnect mode further includes accessing data from the primary data center that is stored on the satellite.

3. A method as in claim 1, wherein processing the event in connect mode includes updating a summary field for an account associated with the event.

4. A method as in claim 1, further comprising sending said information to the primary data center when the primary data center becomes available.

5. A method as in claim 4, further comprising processing the information at the primary data center at a time of reception at the primary data center.

6. A method as in claim 4 further comprising checking the information for a special event.

7. A method as in claim 6, wherein the special event is a simultaneous login, and further comprising:

monitoring the information and a second set of information associated with a plurality of incoming events coming from the satellite for an associated logoff associated with the simultaneous login;

determining a rate associated with a connect time associated with the simultaneous login and the logoff; and

updating an accounting record in accordance with the rate and the connect time at the time the rate is determined.

8. A method as in claim 1, further comprising preprocessing the event at the satellite.

9. A method as in claim 8, wherein the preprocessing is done before the step of determining whether the primary data center is available.

10. A method as in claim 8, wherein the preprocessing is done after the step of determining whether the primary data center is available.

11. A method as in claim 8, wherein the preprocessing includes steps of:

verifying a login name associated with an account associated with the event;

verifying a password associated with the account;

verifying an account status associated with the account;

denying service if a result of any of the steps of verifying is negative.

12. A method as in claim 1, wherein processing the event in connect mode includes checking a current property of the account.

13. A method as in claim 12, wherein the current property is an account balance.

14. A method as in claim 12, wherein the current property is whether a login associated with the account is currently in use.

15. A method as in claim 1, wherein processing the event in connect mode includes sending a response to a source of the event.

16. A method as in claim 1, wherein processing the event in disconnect mode further includes sending a response to a source of the event.

17. A method as in claim 1, wherein processing the event in connect mode includes rating the event.

18. A method as in claim 17, wherein the event is a phone call.

19. A method as in claim 1, wherein processing the event in disconnect mode further includes rating the event.

20. A method as in claim 19, wherein the event is a phone call.

21. A computer program product stored on a computer readable storage medium for processing an event in a system comprising a satellite and a primary data center, comprising:

computer code that receives an event at the satellite, the event corresponding to a service request from a user, the event including an indication of an account of the user;

computer code that determines whether the primary data center is available for processing the event, wherein the computer code that determines whether the primary data center is available for processing the event includes computer code that sends a query to the primary data center, computer code that determines whether the primary data center responds to the query within a configurable interval, and computer code that determines that the primary data center is available when the primary data center responds to the query within the configurable interval;

computer code that, if the primary data center is available, processes the event in connect mode, wherein the computer code that processes the event in connect mode includes computer code that transmits the event to the primary data center;

the primary data center being configured to execute first business logic that includes logic and data for processing events when the satellite is in connect mode; and

computer code that, if the primary data center is not available, processes the event in disconnect mode, wherein the computer code that processes the event in disconnect mode includes;

computer code that executes second business logic at the satellite, wherein the second business logic includes logic and data different from the first business logic for processing events when the satellite is in disconnect mode; and

computer code that stores information associated with the event for later communication to the primary data center.

22. The computer program product of claim 21, wherein the computer readable medium is a CD-ROM, floppy disk, tape, flash memory, system memory, or hard drive.

23. The computer program product of claim 21, wherein the computer code that processes the event in disconnect mode further includes computer code that accesses data from the primary data center that is stored on the satellite.

24. The computer program product of claim 21, wherein the computer code that processes the event in connect mode includes computer code that updates a summary field for an account associated with the event.

25. The computer program product of claim 21, further comprising computer code that sends said information to the primary data center when the primary data center becomes available.

26. The computer program product of claim 25, further comprising computer code that processes the information at the primary data center at a time of reception at the primary data center.

27. The computer program product of claim 25 further comprising computer code that checks the information for a special event.

28. The computer program product of claim 27, wherein the special event is a simultaneous login, and further comprising:

computer code that monitors the information and a second set of information associated with a plurality of incoming events coming from the satellite for an associated logoff associated with the simultaneous login;

computer code that determines a rate associated with a connect time associated with the simultaneous login and the logoff; and

computer code that updates an accounting record in accordance with the rate and the connect time at the time the rate is determined.

29. The computer program product of claim 21, further comprising computer code that preprocesses the event at the satellite.

30. The computer program product of claim 29, wherein the preprocessing is done before the step of determining whether the primary data center is available.

31. The computer program product of claim 29, wherein the preprocessing is done after the step of determining whether the primary data center is available.

32. The computer program product of claim 29, wherein the preprocessing includes:

computer code that verifies a login name associated with an account associated with the event;

computer code that verifies a password associated with the account;

computer code that verifies an account status associated with the account;

computer code that denies service if a result of any of the steps of verifying is negative.

33. The computer program product of claim 21, wherein processing the event in connect mode includes checking a current property of the account.

34. The computer program product of claim 33, wherein the current property is an account balance.

35. The computer program product of claim 33, wherein the current property is whether a login associated with the account is currently in use.

36. The computer program product of claim 21, wherein the computer code that processes the event in connect mode includes computer code that sends a response to a source of the event.

37. The computer program product of claim 21, wherein the computer code that processes the event in disconnect mode further includes computer code that sends a response to a source of the event.

38. The computer program product of claim 21, wherein the computer code that processes the event in connect mode includes computer code that rates the event.

39. The computer program product of claim 38, wherein the event is a phone call.

40. The computer program product of claim 21, wherein the computer code that processes the event in disconnect mode further includes computer code that rates the event.

41. The computer program product of claim 40, wherein the event is a phone call.

42. A method for processing an event in a system, the system including a satellite and a primary data center, the method comprising:

receiving an event at the satellite, the event corresponding to a service request from a user, the event including an indication of an account of the user;

the satellite determining whether the primary data center is available for processing the event, wherein the satellite determining whether the primary data center is available for processing the event includes the satellite sending a query to the primary data center and the satellite determining whether the primary data center responds to the query;

if the primary data center is available, pre-processing the event using first information stored on the satellite, sending the event to the primary data center, and processing the event at the primary data center when the event is received at the primary data center, wherein processing the event at the primary data center includes executing first business logic at the primary data center, wherein the first business logic includes logic and data for processing events when the satellite is in connect mode, and wherein the first information stored on the satellite is a subset of second information stored at the primary data center; and

if the primary data center is unavailable, determining whether to process the event at the satellite and processing the event at the satellite when it is determined that the event is to be processed at the satellite, wherein processing the event at the satellite includes;

executing second business logic at the satellite, wherein the second business logic includes logic and data different from the first business logic for processing events when the satellite is in disconnect mode; and

storing third information associated with the event for later communication to the primary data center.