oracle modernized queuing - reserve propagation
edit: seems something carrying twin queues same schema.
im perplexing examination reserve propagation nonetheless im observant annals finish queue. nonetheless simply since i dont have pieces place.
does anyone have exam box post? ill consolidate i attempted below. i found troubleshooting docs small light propagation such black box, its tough know since isnt moving.
heres i have; laughing.
create reinstate form test_payload object(
test_id number,
test_dt date);
declare
subscriber sys.aq$_agent;
begin
--- emanate imagining reserve start it
dbms_aqadm.create_queue_table( queue_table => 'test_mqt', queue_payload_type => 'test_payload',
multiple_consumers => loyal ); --- churned subscriber
dbms_aqadm.create_queue( 'test_q', 'test_mqt' );
dbms_aqadm.start_queue( queue_name => 'test_q' );
--- emanate finish reserve start it
dbms_aqadm.create_queue_table( queue_table => 'dest_mqt', queue_payload_type => 'test_payload',
multiple_consumers => loyal );
dbms_aqadm.create_queue( 'dest_q', 'dest_mqt' );
dbms_aqadm.start_queue( queue_name => 'dest_q' );
--- supplement subscriber news propagation
subscriber := sys.aq$_agent( 'test_local_sub', 'dest_q', zero );
dbms_aqadm.add_subscriber( queue_name => 'test_q', subscriber => subscriber );
dbms_aqadm.schedule_propagation( queue_name => 'test_q', destination_queue => 'dest_q' );
end;
declare
enqueue_options dbms_aq.enqueue_options_t;
message_properties dbms_aq.message_properties_t;
message_handle raw( 16 );
summary test_payload;
begin
summary := test_payload( 2, sysdate );
dbms_aq.enqueue( queue_name => 'test_q', enqueue_options => enqueue_options,
message_properties => message_properties, load => message, msgid => message_handle );
commit;
end;
declare
dequeue_options dbms_aq.dequeue_options_t;
message_properties dbms_aq.message_properties_t;
message_handle raw( 16 );
summary test_payload;
begin
dequeue_options.navigation := dbms_aq.first_message;
dbms_aq.dequeue( queue_name => 'dest_q', dequeue_options => dequeue_options,
message_properties => message_properties, load => message, msgid => message_handle );
dbms_output.put_line( 'test_id: ' || message.test_id );
dbms_output.put_line( 'test_date: ' || message.test_dt );
commit;
end;
Comments
Post a Comment