HIGH AVAILABILITY FOR EVENT FORWARDING

• US 20070156884A1
• Filed: 03/12/2007
• Published: 07/05/2007
• Est. Priority Date: 05/01/2002
• Status: Active Grant

• Current Assignee: Oracle International Corporation (Oracle Corporation)
• Original Assignee: BEA Systems Incorporated (Oracle Corporation)
• Inventors: Upton, Mitch, Golding, Christa, Potter, Tim
• Granted Patent: US 7,840,611 B2
• Time in Patent Office: Days
• US Class Current: 709/223
• 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 on 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 the 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.

Claims

1. A system for high availability message forwarding comprising:

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

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

a message processor on a server that stored the message in said cluster of servers, the message processor adapted to determine the appropriate message queue on a different server and forward the message to that message queue.

2. The system of claim 1, wherein the message processor is a JMS server.

3. The system of claim 1, wherein the message processor generates an alias for the message queue.

4. The system of claim 1, wherein the messages are events.

5. The system of claim 1, wherein in case of a failure the message processor is migrated to another server.

6. The system of claim 1, wherein the queues are a distributed queue.

7. The system of claims 1, wherein the queues are distributed event queue.

8. A computer readable medium containing server software code including:

a message processor to determine an appropriate message queue on a different server of a cluster and forward the message to that message queue; and

a message queue to receive messages from other message processors.

9. The computer readable medium of claim 8, wherein the message processor is a JMS server.

10. The computer readable medium of claim 8, wherein the message processor generates an alias for the message queue.

11. The computer readable medium of claim 8, wherein the messages are events.

12. The computer readable medium of claim 8, wherein, in case of a failure, the message processor is migrated to another server.

13. The computer readable medium of claim 8, wherein the queues are a distributed queue.

14. The computer readable medium of claims 8, wherein the queues are a distributed event queue.

15. A system comprising:

a cluster of servers; and

a message store and forward unit on one of the servers, the message store and forward unit adapted to receive and forward messages;

wherein, in case of a failure, the message store and forward unit is migrated to another server of the cluster.

16. The system of claim 15, wherein the store and forward unit includes a message queue.

17. The system of claim 15, wherein the store and forward unit includes a message processor.