Patent ID: 7895600

Claim:
A method of optimizing propagation of non-persistent messages from a source database management system (DBMS) to a destination database management system (DBMS), said method comprising: receiving, by said destination DBMS, one or more non-persistent messages from a source non-persistent message queue of said source DBMS at a destination non-persistent message queue of said destination DBMS; consuming, by said destination DBMS, said non-persistent messages from said destination non-persistent message queue such that consumed non-persistent messages are removed from said destination non-persistent message queue; generating, by said destination DBMS, a sparseness factor based at least in part on a number of non-persistent messages in said destination non-persistent message queue, the highest non-persistent message number of said destination non-persistent message queue, and the lowest non-persistent message number of said destination non-persistent message queue; selectively spilling, by said destination DBMS, at least a portion of said non-persistent messages from said destination non-persistent message queue to a destination persistent message queue of said destination DBMS based on at least one parameter selected from a group consisting of: said sparseness factor, said number of non-persistent messages in said destination non-persistent message queue, and an amount of memory resources utilized by said destination non-persistent message queue; and sending, by said destination DBMS to said source DBMS, an acknowledgment including a watermark indication of consumed non-persistent messages from said destination non-persistent message queue, wherein spilled non-persistent messages that have not yet been consumed are characterized in the watermark indication as consumed.