PACKAGE: SYS.DBMS_STREAMS_MESSAGING

Source

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;