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 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.

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 the 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, wherein the message processor and message queue is part of a Java Messaging Service system.    
   
   
       2 . The system of  claim 1 , wherein the message processor generates an alias for the message queue.  
   
   
       3 . The system of  claim 1 , wherein the messages are events.  
   
   
       4 . The system of  claim 1 , wherein in case of a failure the message processor is migrated to another server.  
   
   
       5 . The system of  claim 1 , wherein the queues are a distributed queue.  
   
   
       6 . The system of claims  1 , wherein the queues are distributed event queue.  
   
   
       7 . 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, wherein the message processor and message queue are part of a Java Messaging Service system.    
   
   
       8 . The computer readable medium of  claim 7 , wherein the message processor is a Java Messaging Service server.  
   
   
       9 . The computer readable medium of  claim 7 , wherein the message processor generates an alias for the message queue.  
   
   
       10 . The computer readable medium of  claim 7 , wherein the messages are events.  
   
   
       11 . The computer readable medium of  claim 7 , wherein in case of a failure the message processor is migrated to another server.  
   
   
       12 . The computer readable medium of  claim 7 , wherein the queues are a distributed queue.  
   
   
       13 . A system comprising: 
 a cluster of servers; and    a Java Messaging Service server on one of the servers, the Java Messaging Service server adapted to receive and forward messages; wherein, in case of a failure, the Java Messaging Service server is migrated to another server of the cluster.    
   
   
       14 . The system of  claim 13 , wherein the Java Message Service server includes a message queue.  
   
   
       15 . The system of  claim 13 , wherein the Java Message Service server includes a message processor.