Create Oracle AQ tables and queues

gistfile1.sql

-- ecris schema queue @ CRDB

CREATE USER ecris IDENTIFIED BY ecris
     DEFAULT TABLESPACE tab
     TEMPORARY TABLESPACE temp;
     
GRANT CONNECT, RESOURCE, aq_administrator_role TO ecris;

begin

DBMS_AQADM.CREATE_QUEUE_TABLE(
     queue_table => 'ecris.TO_DDR_TABLE',
     queue_payload_type => 'sys.aq$_jms_text_message');

DBMS_AQADM.CREATE_QUEUE(
     queue_name => 'ecris.TO_DDR',
     queue_table => 'ecris.TO_DDR_TABLE');

DBMS_AQADM.START_QUEUE(
     queue_name => 'ecris.TO_DDR');

end;

-- cr_ddr schema queues @ CRDB

CREATE USER cr_ddr IDENTIFIED BY cr_ddr
     DEFAULT TABLESPACE tab
     TEMPORARY TABLESPACE temp;
     
GRANT CONNECT, RESOURCE, aq_administrator_role TO cr_ddr;

begin

DBMS_AQADM.CREATE_QUEUE_TABLE(
     queue_table => 'cr_ddr.TO_DDR_TABLE',
     queue_payload_type => 'sys.aq$_jms_text_message');

DBMS_AQADM.CREATE_QUEUE(
     queue_name => 'cr_ddr.TO_DDR',
     queue_table => 'cr_ddr.TO_DDR_TABLE');

DBMS_AQADM.START_QUEUE(
     queue_name => 'cr_ddr.TO_DDR');

DBMS_AQADM.CREATE_QUEUE_TABLE(
     queue_table => 'cr_ddr.TO_ECRIS_TABLE',
     queue_payload_type => 'sys.aq$_jms_text_message');

DBMS_AQADM.CREATE_QUEUE(
     queue_name => 'cr_ddr.TO_ECRIS',
     queue_table => 'cr_ddr.TO_ECRIS_TABLE');

DBMS_AQADM.START_QUEUE(
     queue_name => 'cr_ddr.TO_ECRIS');

end;