[Home] [Help]
PACKAGE: APPS.OKC_AQ_PVT
Source
1 Package OKC_AQ_PVT AUTHID CURRENT_USER AS
2 /* $Header: OKCRAQS.pls 120.0 2005/05/25 19:19:10 appldev noship $ */
3 ---------------------------------------------------------------------------
4 -- GLOBAL DATASTRUCTURES
5 ---------------------------------------------------------------------------
6 -- TYPES
7 -- declaring record of msg_rec_typ
8 TYPE msg_rec_typ IS RECORD (
9 element_name okc_action_attributes_v.element_name%TYPE,
10 element_value okc_action_att_vals.value%TYPE
11 );
12 -- declaring table of msg_tab_typ
13 TYPE msg_tab_typ IS TABLE OF msg_rec_typ;
14
15 -- declaring corrid record type
16 TYPE corrid_rec_typ IS RECORD (
17 corrid okc_actions_b.correlation%TYPE
18 );
19 ---------------------------------------------------------------------------
20 -- CONSTANTS
21
22 g_msg_expire CONSTANT BINARY_INTEGER default dbms_aq.never;
23 g_event_queue_name CONSTANT VARCHAR2(100) := OKC_QUEUE_PVT.event_queue_name;
24 g_outcome_queue_name CONSTANT VARCHAR2(100) := OKC_QUEUE_PVT.outcome_queue_name;
25 g_app_name CONSTANT VARCHAR2(3) := OKC_API.G_APP_NAME;
26 g_dequeue_wait CONSTANT BINARY_INTEGER default 5;
27 ---------------------------------------------------------------------------
28 -- PUBLIC VARIABLES
29 ---------------------------------------------------------------------------
30 -- EXCEPTIONS
31 ---------------------------------------------------------------------------
32 -- Procedures and Functions
33 ---------------------------------------------------------------------------
34 -- overloaded send_message procedure supports
35 -- varchar2 and clob message payloads
36
37
38 FUNCTION get_acn_type(p_corrid IN VARCHAR2) RETURN VARCHAR2;
39
40 PROCEDURE send_message
41 (p_api_version IN NUMBER,
42 p_init_msg_list IN VARCHAR2 DEFAULT okc_api.G_FALSE,
43 p_commit IN VARCHAR2 DEFAULT okc_api.G_FALSE,
44 x_msg_count OUT NOCOPY NUMBER,
45 x_msg_data OUT NOCOPY VARCHAR2,
46 x_return_status OUT NOCOPY VARCHAR2,
47 p_corrid_rec IN corrid_rec_typ,
48 p_msg_tab IN msg_tab_typ,
49 p_queue_name IN VARCHAR2,
50 p_delay IN INTEGER default dbms_aq.no_delay
51 );
52
53 /*PROCEDURE send_message
54 (p_api_version IN NUMBER,
55 p_init_msg_list IN VARCHAR2 DEFAULT okc_api.G_FALSE,
56 p_commit IN VARCHAR2 DEFAULT okc_api.G_FALSE,
57 x_msg_count OUT NOCOPY NUMBER,
58 x_msg_data OUT NOCOPY VARCHAR2,
59 x_return_status OUT NOCOPY VARCHAR2,
60 p_msg IN VARCHAR2,
61 p_queue_name IN VARCHAR2,
62 p_delay IN number default 0
63 );*/
64
65 PROCEDURE listen_event (
66 errbuf OUT NOCOPY VARCHAR2
67 ,retcode OUT NOCOPY VARCHAR2
68 , p_wait IN INTEGER
69 , p_sleep IN NUMBER
70 );
71
72 PROCEDURE listen_outcome (
73 errbuf OUT NOCOPY VARCHAR2
74 ,retcode OUT NOCOPY VARCHAR2
75 , p_wait IN INTEGER
76 , p_sleep IN NUMBER
77 );
78
79 PROCEDURE dequeue_event;
80 PROCEDURE dequeue_date_event;
81 PROCEDURE dequeue_outcome;
82 PROCEDURE dequeue_exception ( errbuf OUT NOCOPY VARCHAR2
83 ,retcode OUT NOCOPY VARCHAR2
84 ,p_msg_id IN VARCHAR2
85 );
86
87 PROCEDURE remove_message ( errbuf OUT NOCOPY VARCHAR2
88 ,retcode OUT NOCOPY VARCHAR2
89 ,p_msg_id IN VARCHAR2
90 );
91 PROCEDURE clear_message ( errbuf OUT NOCOPY VARCHAR2
92 ,retcode OUT NOCOPY VARCHAR2
93 );
94 PROCEDURE stop_listener;
95
96 END okc_aq_pvt;