This illustration shows a messaging environment that includes the following Oracle databases:
ii1.example.com
ii2.example.com
The ii1.example.com
database has the following components:
The oe.orders
table.
A trigger named enqueue_orders
that fires when row is inserted into the oe.orders table. The trigger enqueues messages of order_id_date
type based on the insert into the streams_queue
queue.
A propagation named send_orders
that sends messages from the local streams_queue
queue to the streams_queue
queue at ii2.example.com
.
The ii2.example.com
database has the following components:
The streams_queue
queue.
A messaging client/subscriber named strmadmin
. When the strmadmin messaging client/subscriber is invoked, it uses the dequeue_orders
PL/SQL procedure to dequeue and process the messages in the streams_queue
queue.