A method and apparatus for propagating and managing data, transactions and
events either within a database, or from one database to another is
provided. In one embodiment, messages are propagated from a source to a
first queue and a second queue with the queues associated with the same
database. The connection from the source to each queue maintains its own
propagation job. This method could also be employed with cluster
databases.