DBA Data[Home] [Help]

APPS.FND_CP_OPP_IPC dependencies on DBMS_AQADM

Line 46: DBMS_AQADM.ADD_SUBSCRIBER(queue_name =>Q_Schema || '.' || QUEUE_NAME,

42:
43: pragma AUTONOMOUS_TRANSACTION;
44:
45: Begin
46: DBMS_AQADM.ADD_SUBSCRIBER(queue_name =>Q_Schema || '.' || QUEUE_NAME,
47: subscriber => sys.aq$_agent(OPPPREFIX || subscriber, NULL, NULL));
48:
49:
50: commit;

Line 75: DBMS_AQADM.ADD_SUBSCRIBER(queue_name =>Q_Schema || '.' || QUEUE_NAME,

71:
72: pragma AUTONOMOUS_TRANSACTION;
73:
74: Begin
75: DBMS_AQADM.ADD_SUBSCRIBER(queue_name =>Q_Schema || '.' || QUEUE_NAME,
76: subscriber => sys.aq$_agent(OPPPREFIX || subscriber, NULL, NULL),
77: rule => 'tab.user_data.message_group = ''' || groupid || '''');
78:
79:

Line 99: DBMS_AQADM.REMOVE_SUBSCRIBER(queue_name =>Q_Schema || '.' || QUEUE_NAME,

95:
96: pragma AUTONOMOUS_TRANSACTION;
97:
98: Begin
99: DBMS_AQADM.REMOVE_SUBSCRIBER(queue_name =>Q_Schema || '.' || QUEUE_NAME,
100: subscriber => sys.aq$_agent(OPPPREFIX || subscriber, NULL, NULL));
101:
102:
103: commit;

Line 192: DBMS_AQADM.REMOVE_SUBSCRIBER(queue_name => Q_Schema || '.' || QUEUE_NAME,

188: loop
189: fetch c1 into subname;
190: exit when c1%NOTFOUND;
191:
192: DBMS_AQADM.REMOVE_SUBSCRIBER(queue_name => Q_Schema || '.' || QUEUE_NAME,
193: subscriber => sys.aq$_agent(subname, NULL, NULL));
194: end loop;
195: close c1;
196: