BEGIN
dbms_aqadm.create_queue_table( queue_table=>'nverma.ICP_SEND_Q',
queue_payload_type=> 'SYS.AQ$_JMS_TEXT_MESSAGE',
sort_list=> 'ENQ_TIME',
comment=> 'This statement creates the queue table.',
multiple_consumers=> FALSE,
message_grouping=>DBMS_AQADM.NONE,
compatible=>'8.1',
storage_clause=> 'TABLESPACE USERS'
);
END;
/
BEGIN
dbms_aqadm.create_queue(queue_name=>'ICP_SEND_Q',
queue_table=> 'nverma.ICP_SEND_Q',
queue_type=> DBMS_AQADM.NORMAL_QUEUE,
max_retries=> '3',
retry_delay=> '30',
retention_time=> 30*24*60*60,
comment=> 'This statement creates a queue.'
);
END;
/
BEGIN
dbms_aqadm.start_queue (queue_name => 'ICP_SEND_Q');
END;
/
No comments:
Post a Comment