High availability for event forwarding

• US 20070074066A1
• Filed: 11/13/2006
• Published: 03/29/2007
• Est. Priority Date: 05/01/2002
• Status: Abandoned Application

• Current Assignee: BEA Systems Incorporated (Oracle Corporation)
• Original Assignee: BEA Systems Incorporated (Oracle Corporation)
• Inventors: Upton, Mitch, Golding, Christa, Potter, Tim
• Application Number:
  US11/559,344
• Publication Number:
  US 20070074066A1
• Time in Patent Office: Days
• US Class Current: 714/5
• CPC Class Codes: G06F 11/1438 Restarting or rejuvenating
• CPC Class Codes: G06F 11/1471 involving logging of persistent data for recovery
• CPC Class Codes: G06F 2209/544 Remote
• CPC Class Codes: G06F 9/542 Event management; Broadcasting; Multicasting; Notifications
• CPC Class Codes: H04L 67/1001 for accessing one among a plurality of replicated servers
• CPC Class Codes: H04L 67/1008 based on parameters of servers, e.g. available memory or workload monitoring of computer activity G06F11/30
• CPC Class Codes: H04L 67/1036 Load balancing of requests to servers for services different from user content provisioning, e.g. load balancing across domain name servers
• CPC Class Codes: Y10S 707/99942 Manipulating data structure, e.g. compression, compaction, compilation
• CPC Class Codes: Y10S 707/99943 Generating database or data structure, e.g. via user interface
• CPC Class Codes: Y10S 707/99944 Object-oriented database structure
• CPC Class Codes: Y10S 707/99945 Object-oriented database structure processing

Abstract

High availability event forwarding can be obtained utilizing distributed queues in a server cluster. Each server can receive an event from a data system, such as a database or SAP™ system. Event queues exist oil servers in the cluster can store an event until, for example, the event is delivered to a user or retrieved for processing. An event processor examines the load of each event queue and selects tie event queue with the lightest load The event processor generates an alias for the selected queue, such that a user, integration system, or client application does not need to know the identity of the physical queue storing the event, but only needs to refer to the ‘distributed queue’ or alias. After a physical queue is selected and an alias assigned, the event is forwarded to the selected queue. This description is not intended to be a complete description of, or limit the scope of, the invention. Other features, aspects, and objects of the invention can be obtained from a review of the specification, the figures, and the claims.

Claims

1. A system for high availability event forwarding in an integration system comprising:

a cluster of servers, each server in the cluster adapted to receive an event;

event queues on at least some of the servers in said cluster of servers, the event queues adapted to store the event; and

an event processor on at least one server in said cluster of servers, the event processor adapted to determine the available event queue with the lightest load and forward the event to that event queue

2. A system according to claim 1, wherein:

the event processor further adapted to generate an alias for the event queue to which the event is forwarded, wherein the alias abstracts the server location of the determined event queue from a user.

3. A system according to claim 1, further comprising:

a data system adapted to generate an event.

4. A. system according to claim 3, wherein:

said data system is selected from the group consisting of databases, EIS systems, and SAP™

systems.

5. A system according to claim 3, further comprising:

an event router adapted to receive the event from the data system and forward the event to the cluster of servers.

6. A system according to claim 1, further comprising:

a listener on at least one server in the cluster, the listener adapted to listen for the event on each event queue in the cluster.

7. A system according to claim 6, further comprising:

a listener on each server in the cluster, each listener adapted to listen for tile event on each eve qt queue in the cluster.

8. A system according to claim 6, wherein said listener listens for the event on the event queue using the alias.

9. A method for high availability event forwarding in an integration system, comprising.:

receiving an event to server in a cluster of servers;

determining which server in the cluster contains the event queue with the lightest load; and

forwarding the event to the event queue with the lightest load and assigning the alias to that event queue

10. A method according to claim 9, further comprising:

creating an alias for the event queue with the lightest load, wherein the alias abstracts the server location of the determined event queue from a user.

11. A method according to claim. 9, further comprising:

generating the event with a data system.

12. A method according to claim 11 further

receiving the event from the data system to an event router and forwarding the event to the cluster of servers.

13. A method according to claim 9, further comprising:

listening for the event on each event queue in the cluster using a listener on at least one server an the cluster.

14. A method according to claim 9, further comprising:

listening for the event on each event queue in the cluster using a listener on each server in the cluster.

15. A computer program product for execution by a server computer for high availability event forwarding in an integration system, comprising:

computer code to receive an event to server in a cluster of servers;

computer code to determine which server in the cluster contains the event queue with the lightest load; and

computer code to forward the event to the event queue with the lightest load and assigning the alias to that event queue

16. The computer program product of claim 15, further comprising:

computer code to create an alias for the event queue with the lightest load, wherein the alias abstracts the server location of the determined event queue from a user.