Persistent messaging

Abstract

A message is written into a shared memory location in a distributed file system by a message producer. An associated message reference is written into a message queue. The associated message reference points to the shared memory location. The associated message reference is read from the message queue by the remote message consumer and the message is accessed in the distributed file system on receiving a notification of the associated message reference in the message queue.

What is claimed is: 
     
         1 . A method for managing persistent messages between a message producer and a remote message consumer in a computing environment, the method comprising:
 writing a message into a shared memory location in a distributed file system by the message producer;   writing an associated message reference into a message queue, wherein the associated message reference pointing to the shared memory location; and   reading the associated message reference from the message queue by the remote message consumer and accessing the message in the distributed file system on receiving a notification of the associated message reference in the message queue.   
     
     
         2 . The method of  claim 1 , further including acknowledging by the remote message consumer that the associated message reference has been received. 
     
     
         3 . The method of  claim 2 , further including removing the associated message reference from the message queue on receipt of the acknowledgement. 
     
     
         4 . The method of  claim 1 , further including saving the message in the shared memory location by the distributed filing system and returning a message reference of the shared memory location for writing into the message queue. 
     
     
         5 . The method of  claim 1 , further including passing the associated message reference synchronously to the remote message consumer, wherein the notification contains the associated message reference. 
     
     
         6 . A method for managing persistent messages between a message producer and a remote message consumer in a computing environment, the method comprising:
 writing a message into a shared memory location in a distributed file system;   receiving an associated message reference with the shared memory location of the message in the distributed file system;   writing an associated message reference into a message queue; and   reading the associated message reference from the message queue by the remote message consumer thereby accessing the message in the distributed file system thereby access the message in the distributed file system.   
     
     
         7 . The method of  claim 6 , further including acknowledging by the remote message consumer that the associated message reference has been received. 
     
     
         8 . The method of  claim 7 , further including removing the associated message reference from the message queue on receipt of the acknowledgement. 
     
     
         9 . The method of  claim 6 , further including saving the message in the shared memory location by the distributed filing system and returning a message reference of the shared memory location for writing into the message queue. 
     
     
         10 . The method of  claim 6 , further including passing the associated message reference synchronously to the remote message consumer, wherein the notification contains the associated message reference. 
     
     
         11 . A system for managing persistent messages between a message producer and remote message consumer in a computing environment, the system comprising:
 a messaging platform; and   at least one processor device operable in the computing storage environment and in communication with the messaging platform, wherein the at least one processor device:
 writes a message into a shared memory location in a distributed file system by the message producer, 
 writes an associated message reference into a message queue, wherein the associated message reference pointing to the shared memory location, and 
 reads the associated message reference from the message queue by the remote message consumer and accessing the message in the distributed file system on receiving a notification of the associated message reference in the message queue. 
   
     
     
         12 . The system of  claim 11 , wherein the at least one processor device acknowledges by the remote message consumer that the associated message reference has been received. 
     
     
         13 . The system of  claim 12 , wherein the at least one processor device removes the associated message reference from the message queue on receipt of the acknowledgement. 
     
     
         14 . The system of  claim 11 , wherein the at least one processor device saves the message in the shared memory location by the distributed filing system and returning a message reference of the shared memory location for writing into the message queue. 
     
     
         15 . The system of  claim 11 , wherein the at least one processor device passes the associated message reference synchronously to the remote message consumer, wherein the notification contains the associated message reference. 
     
     
         16 . A system for managing persistent messages between a message producer and remote message consumer in a computing environment, the system comprising:
 a messaging platform; and   at least one processor device operable in the computing storage environment and in communication with the messaging platform, wherein the at least one processor device:
 writes a message into a shared memory location in a distributed file system, 
 receives an associated message reference with the shared memory location of the message in the distributed file system, 
 writes an associated message reference into a message queue, and 
 reads the associated message reference from the message queue by the remote message consumer thereby accessing the message in the distributed file system thereby access the message in the distributed file system. 
   
     
     
         17 . The system of  claim 16 , wherein the at least one processor device acknowledges by the remote message consumer that the associated message reference has been received. 
     
     
         18 . The system of  claim 17 , wherein the at least one processor device removes the associated message reference from the message queue on receipt of the acknowledgement. 
     
     
         19 . The system of  claim 16 , wherein the at least one processor device saves the message in the shared memory location by the distributed filing system and returning a message reference of the shared memory location for writing into the message queue. 
     
     
         20 . The system of  claim 16 , wherein the at least one processor device passes the associated message reference synchronously to the remote message consumer, wherein the notification contains the associated message reference. 
     
     
         21 . A computer program product for managing persistent messages between a message producer and remote message consumer in a computing by a processor device, the computer program product comprising a non-transitory computer-readable storage medium having computer-readable program code portions stored therein, the computer-readable program code portions comprising:
 a first executable portion that writes a message into a shared memory location in a distributed file system by the message producer;   a second executable portion that writes an associated message reference into a message queue, wherein the associated message reference pointing to the shared memory location; and   a third executable portion that reads the associated message reference from the message queue by the remote message consumer and accessing the message in the distributed file system on receiving a notification of the associated message reference in the message queue.   
     
     
         22 . The computer program product of  claim 21 , further including a fourth executable portion that acknowledges by the remote message consumer that the associated message reference has been received. 
     
     
         23 . The computer program product of  claim 22 , further including a fifth executable portion that removes the associated message reference from the message queue on receipt of the acknowledgement. 
     
     
         24 . The computer program product of  claim 21 , further including a fourth executable portion that saves the message in the shared memory location by the distributed filing system and returning a message reference of the shared memory location for writing into the message queue. 
     
     
         25 . The computer program product of  claim 21 , further including a fourth executable portion that passes the associated message reference synchronously to the remote message consumer, wherein the notification contains the associated message reference. 
     
     
         26 . A computer program product for managing persistent messages between a message producer and remote message consumer in a computing by a processor device, the computer program product comprising a non-transitory computer-readable storage medium having computer-readable program code portions stored therein, the computer-readable program code portions comprising:
 a first executable portion that writes a message into a shared memory location in a distributed file system;   a second executable portion that receives an associated message reference with the shared memory location of the message in the distributed file system;   a third executable portion that writes an associated message reference into a message queue; and   a fourth executable portion that reads the associated message reference from the message queue by the remote message consumer thereby accessing the message in the distributed file system thereby access the message in the distributed file system.   
     
     
         27 . The computer program product of  claim 26 , further including a fifth executable portion that acknowledges by the remote message consumer that the associated message reference has been received. 
     
     
         28 . The computer program product of  claim 27 , further including a sixth executable portion that removes the associated message reference from the message queue on receipt of the acknowledgement. 
     
     
         29 . The computer program product of  claim 26 , further including a fifth executable portion that saves the message in the shared memory location by the distributed filing system and returning a message reference of the shared memory location for writing into the message queue. 
     
     
         30 . The computer program product of  claim 26 , further including a fifth executable portion that passes the associated message reference synchronously to the remote message consumer, wherein the notification contains the associated message reference.