DBA Data[Home] [Help]

APPS.XDP_AQ_UTILITIES dependencies on XDP_ADAPTER_CORE_DB

Line 1522: lv_MessageProperties.correlation := XDP_ADAPTER_CORE_DB.pv_InstanceName || ':' || p_fe_name;

1518: -- Enqueue it with the commit on a seperate transaction.
1519: lv_EnqueueOptions.visibility := DBMS_AQ.ON_COMMIT;
1520: lv_MessageProperties.exception_queue := G_XDP_SCHEMA||'.'||'XDP_Channel_Exception_Q';
1521: if p_fe_name is not null then
1522: lv_MessageProperties.correlation := XDP_ADAPTER_CORE_DB.pv_InstanceName || ':' || p_fe_name;
1523: else
1524: lv_MessageProperties.correlation := XDP_ADAPTER_CORE_DB.pv_InstanceName;
1525: end if;
1526: DBMS_AQ.ENQUEUE(

Line 1524: lv_MessageProperties.correlation := XDP_ADAPTER_CORE_DB.pv_InstanceName;

1520: lv_MessageProperties.exception_queue := G_XDP_SCHEMA||'.'||'XDP_Channel_Exception_Q';
1521: if p_fe_name is not null then
1522: lv_MessageProperties.correlation := XDP_ADAPTER_CORE_DB.pv_InstanceName || ':' || p_fe_name;
1523: else
1524: lv_MessageProperties.correlation := XDP_ADAPTER_CORE_DB.pv_InstanceName;
1525: end if;
1526: DBMS_AQ.ENQUEUE(
1527: queue_name => G_XDP_SCHEMA||'.'||'XDP_WF_CHANNEL_Q',
1528: enqueue_options => lv_EnqueueOptions,

Line 1705: lv_DequeueOptions.correlation := XDP_ADAPTER_CORE_DB.pv_InstanceName || ':' || p_correlation_id;

1701: savepoint resume_wf;
1702: lv_DequeueOptions.visibility := DBMS_AQ.ON_COMMIT;
1703: lv_DequeueOptions.navigation := DBMS_AQ.FIRST_MESSAGE;
1704: if p_correlation_id is not null then
1705: lv_DequeueOptions.correlation := XDP_ADAPTER_CORE_DB.pv_InstanceName || ':' || p_correlation_id;
1706: else
1707: lv_DequeueOptions.correlation := XDP_ADAPTER_CORE_DB.pv_InstanceName || '%';
1708: end if;
1709: lv_DequeueOptions.wait := p_message_wait_timeout;

Line 1707: lv_DequeueOptions.correlation := XDP_ADAPTER_CORE_DB.pv_InstanceName || '%';

1703: lv_DequeueOptions.navigation := DBMS_AQ.FIRST_MESSAGE;
1704: if p_correlation_id is not null then
1705: lv_DequeueOptions.correlation := XDP_ADAPTER_CORE_DB.pv_InstanceName || ':' || p_correlation_id;
1706: else
1707: lv_DequeueOptions.correlation := XDP_ADAPTER_CORE_DB.pv_InstanceName || '%';
1708: end if;
1709: lv_DequeueOptions.wait := p_message_wait_timeout;
1710: lv_high_avail := false;
1711: