High availability for event forwarding

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.

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.