DBA Data[Home] [Help]

APPS.OKC_AQ_PVT dependencies on OKC_AQ_MSG_TYP

Line 77: p_clob_msg IN system.okc_aq_msg_typ

73: END get_acn_type;
74:
75:
76: PROCEDURE enqueue_message (
77: p_clob_msg IN system.okc_aq_msg_typ
78: , p_corrid_rec IN corrid_rec_typ
79: , p_queue_name IN VARCHAR2
80: , p_delay IN NUMBER
81: , x_msg_handle OUT NOCOPY RAW)

Line 120: x_char_clob OUT NOCOPY system.okc_aq_msg_typ )

116:
117:
118:
119: PROCEDURE build_char_clob ( p_msg IN VARCHAR2,
120: x_char_clob OUT NOCOPY system.okc_aq_msg_typ )
121: IS
122: l_char_clob system.okc_aq_msg_typ;
123: --
124: l_proc varchar2(72) := ' OKC_AQ_PVT.'||'build_char_clob';

Line 122: l_char_clob system.okc_aq_msg_typ;

118:
119: PROCEDURE build_char_clob ( p_msg IN VARCHAR2,
120: x_char_clob OUT NOCOPY system.okc_aq_msg_typ )
121: IS
122: l_char_clob system.okc_aq_msg_typ;
123: --
124: l_proc varchar2(72) := ' OKC_AQ_PVT.'||'build_char_clob';
125: --
126:

Line 134: l_char_clob := system.okc_aq_msg_typ(empty_clob());

130: okc_debug.Log('10: Entering ',2);
131: END IF;
132:
133:
134: l_char_clob := system.okc_aq_msg_typ(empty_clob());
135: DBMS_LOB.createtemporary ( l_char_clob.body
136: , TRUE
137: , DBMS_LOB.session );
138: DBMS_LOB.write ( l_char_clob.body

Line 158: PROCEDURE clob_to_char ( p_clob_msg IN system.okc_aq_msg_typ

154: END IF;
155: null;
156: END build_char_clob;
157:
158: PROCEDURE clob_to_char ( p_clob_msg IN system.okc_aq_msg_typ
159: , x_char_msg OUT NOCOPY varchar2)
160: IS
161: l_amount INTEGER;
162: l_clob_msg system.okc_aq_msg_typ;

Line 162: l_clob_msg system.okc_aq_msg_typ;

158: PROCEDURE clob_to_char ( p_clob_msg IN system.okc_aq_msg_typ
159: , x_char_msg OUT NOCOPY varchar2)
160: IS
161: l_amount INTEGER;
162: l_clob_msg system.okc_aq_msg_typ;
163: --
164: l_proc varchar2(72) := ' OKC_AQ_PVT.'||'clob_to_char';
165: --
166:

Line 174: l_clob_msg := system.okc_aq_msg_typ (empty_clob());

170: okc_debug.Log('10: Entering ',2);
171: END IF;
172:
173:
174: l_clob_msg := system.okc_aq_msg_typ (empty_clob());
175: dbms_lob.createtemporary(l_clob_msg.body,TRUE,dbms_lob.session);
176: l_clob_msg := p_clob_msg;
177: l_amount := DBMS_LOB.getlength ( l_clob_msg.body );
178: -- read clob message into char variable

Line 261: l_xml_clob system.okc_aq_msg_typ;

257: IS
258: l_api_name CONSTANT VARCHAR2(30) := 'SEND_MESSAGE';
259: l_api_version CONSTANT NUMBER := 1.0;
260: l_return_status VARCHAR2(1) := OKC_API.G_RET_STS_SUCCESS;
261: l_xml_clob system.okc_aq_msg_typ;
262: x_msg_handle RAW(16);
263: OKC_ENQUEUE_FAILED EXCEPTION;
264: PRAGMA EXCEPTION_INIT (OKC_ENQUEUE_FAILED, -99095 );
265: --

Line 392: l_char_clob system.okc_aq_msg_typ;

388: IS
389: l_api_name CONSTANT VARCHAR2(30) := 'SEND_MESSAGE';
390: l_api_version CONSTANT NUMBER := 1.0;
391: l_return_status VARCHAR2(1) := OKC_API.G_RET_STS_SUCCESS;
392: l_char_clob system.okc_aq_msg_typ;
393: x_msg_handle RAW(16);
394: OKC_ENQUEUE_FAILED EXCEPTION;
395: PRAGMA EXCEPTION_INIT (OKC_ENQUEUE_FAILED, -99095 );
396: --

Line 484: l_msg system.okc_aq_msg_typ;

480:
481: l_dq_options dbms_aq.dequeue_options_t;
482: l_msg_prop dbms_aq.message_properties_t;
483: l_msg_handle raw(16);
484: l_msg system.okc_aq_msg_typ;
485: CURSOR queue_cur
486: IS
487: SELECT h.msgid msgid ,
488: decode(h.subscriber#,0

Line 557: l_msg system.okc_aq_msg_typ;

553:
554: l_dq_options dbms_aq.dequeue_options_t;
555: l_msg_prop dbms_aq.message_properties_t;
556: l_msg_handle raw(16);
557: l_msg system.okc_aq_msg_typ;
558: CURSOR queue_cur
559: IS
560: SELECT h.msgid msgid ,
561: decode(h.subscriber#,0

Line 825: l_msg system.okc_aq_msg_typ;

821: IS
822: l_dq_options dbms_aq.dequeue_options_t;
823: l_msg_prop dbms_aq.message_properties_t;
824: l_msg_handle raw(16);
825: l_msg system.okc_aq_msg_typ;
826: l_sub_name varchar2(30);
827: l_msg_tab OKC_AQ_PVT.msg_tab_typ;
828: l_corrid OKC_AQ_PVT.corrid_rec_typ;
829: l_acn_id OKC_ACTIONS_V.ID%TYPE;

Line 1075: l_msg system.okc_aq_msg_typ;

1071: IS
1072: l_dq_options dbms_aq.dequeue_options_t;
1073: l_msg_prop dbms_aq.message_properties_t;
1074: l_msg_handle raw(16);
1075: l_msg system.okc_aq_msg_typ;
1076: l_sub_name varchar2(30);
1077: l_msg_tab OKC_AQ_PVT.msg_tab_typ;
1078: l_corrid OKC_AQ_PVT.corrid_rec_typ;
1079: l_cnh_id OKC_CONDITION_HEADERS_B.ID%TYPE;

Line 1287: l_msg system.okc_aq_msg_typ;

1283: IS
1284: l_dq_options dbms_aq.dequeue_options_t;
1285: l_msg_prop dbms_aq.message_properties_t;
1286: l_msg_handle raw(16);
1287: l_msg system.okc_aq_msg_typ;
1288: l_sub_name varchar2(30);
1289: l_msg_text varchar2(1000);
1290: l_msg_data varchar2(1000);
1291: l_msg_count number;

Line 1576: l_msg system.okc_aq_msg_typ;

1572: IS
1573: l_dq_options dbms_aq.dequeue_options_t;
1574: l_msg_prop dbms_aq.message_properties_t;
1575: l_msg_handle raw(16);
1576: l_msg system.okc_aq_msg_typ;
1577: l_sub_name varchar2(30);
1578: l_corrid OKC_AQ_PVT.corrid_rec_typ;
1579: l_api_name CONSTANT VARCHAR2(30) := 'DEQUEUE_EXCEPTION';
1580: l_api_version CONSTANT NUMBER := 1.0;

Line 1731: l_msg system.okc_aq_msg_typ;

1727: IS
1728: l_dq_options dbms_aq.dequeue_options_t;
1729: l_msg_prop dbms_aq.message_properties_t;
1730: l_msg_handle raw(16);
1731: l_msg system.okc_aq_msg_typ;
1732: l_sub_name varchar2(30);
1733: l_corrid OKC_AQ_PVT.corrid_rec_typ;
1734: l_api_name CONSTANT VARCHAR2(30) := 'REMOVE_MESSAGE';
1735: l_api_version CONSTANT NUMBER := 1.0;

Line 1864: l_msg system.okc_aq_msg_typ;

1860: IS
1861: l_dq_options dbms_aq.dequeue_options_t;
1862: l_msg_prop dbms_aq.message_properties_t;
1863: l_msg_handle raw(16);
1864: l_msg system.okc_aq_msg_typ;
1865: l_sub_name varchar2(30);
1866: l_corrid OKC_AQ_PVT.corrid_rec_typ;
1867: l_api_name CONSTANT VARCHAR2(30) := 'REMOVE_MESSAGE';
1868: l_api_version CONSTANT NUMBER := 1.0;