1 PACKAGE dbms_streams_messaging AUTHID CURRENT_USER AS
2
3 -------------
4 -- CONSTANTS
5
6 -- constats for wait parameter in dequque
7 forever CONSTANT BINARY_INTEGER := -1;
8 no_wait CONSTANT BINARY_INTEGER := 0;
9
10 -------------
11 -- EXCEPTIONS
12 endofcurtrans EXCEPTION;
13 PRAGMA exception_init(endofcurtrans, -25235);
14
15 nomoremsgs EXCEPTION;
16 PRAGMA exception_init(nomoremsgs, -25228);
17
18
19 PROCEDURE enqueue(
20 queue_name IN VARCHAR2,
21 payload IN SYS.ANYDATA);
22
23 PROCEDURE enqueue(
24 queue_name IN VARCHAR2,
25 payload IN SYS.ANYDATA,
26 msgid OUT RAW);
27
28 -- queue_name: name of the queue. The queue must be a secure queue.
29 -- payload: the payload to be enqueued.
30 -- msgid: message ID returned. An overloaded procedure does not have this OUT
31 -- parameter.
32
33 PROCEDURE dequeue(
34 queue_name IN VARCHAR2,
35 streams_name IN VARCHAR2,
36 payload OUT SYS.ANYDATA,
37 dequeue_mode IN VARCHAR2 DEFAULT 'REMOVE',
38 navigation IN VARCHAR2 DEFAULT 'NEXT MESSAGE',
39 wait IN BINARY_INTEGER DEFAULT FOREVER);
40
41 PROCEDURE dequeue(
42 queue_name IN VARCHAR2,
43 streams_name IN VARCHAR2,
44 payload OUT SYS.ANYDATA,
45 dequeue_mode IN VARCHAR2 DEFAULT 'REMOVE',
46 navigation IN VARCHAR2 DEFAULT 'NEXT MESSAGE',
47 wait IN BINARY_INTEGER DEFAULT FOREVER,
48 msgid OUT RAW);
49
50 -- queue_name: name of the queue. The queue must be a secure queue.
51 -- streams_name: name of the stream
52 -- dequeue_mode: one of 'REMOVE', 'LOCKED', 'BROWSE'.
53 -- navigation: one of 'FIRST MESSAGE', 'NEXT MESSAGE', 'NEXT TRANSACTION'
54 -- payload: the payload to be dequeued.
55 -- msgid: message ID returned. An overloaded procedure does not have this
56 -- OUT parameter.
57
58 END dbms_streams_messaging;