PL/SQL Packages and Types Reference 10g Release 1 (10.1) Part Number B10802-01 |
|
|
View PDF |
The DBMS_STREAMS_MESSAGING
package, one of a set of Streams packages, provides interfaces to enqueue messages into and dequeue messages from a SYS.AnyData
queue.
See Also:
|
This chapter contains the following topic:
Subprogram | Description |
---|---|
Uses the specified Streams messaging client to dequeue a message from the specified queue | |
The current user enqueues a message into the specified queue |
These procedures use the specified Streams messaging client to dequeue a message from the specified queue.
Note: This procedure is overloaded. One version of this procedure contains the |
DBMS_STREAMS_MESSAGING.DEQUEUE( queue_name IN VARCHAR2, streams_name IN VARCHAR2, payload OUT SYS.AnyData, dequeue_mode IN VARCHAR2 DEFAULT 'REMOVE', navigation IN VARCHAR2 DEFAULT 'NEXT MESSAGE', wait IN BINARY_INTEGER DEFAULT FOREVER, msgid OUT RAW);
Parameter | Description |
---|---|
|
The name of the local queue from which messages will be dequeued, specified as For example, to specify a queue named |
|
The name of the Streams messaging client. For example, if the user If |
|
The payload that is dequeued |
|
Specify one of the following settings:
|
|
Specifies the position of the message that will be retrieved. First, the position is determined. Second, the search criterion is applied. Finally, the message is retrieved. Specify one of the following settings:
Note: Each message group contains the messages in a single transaction. See Also: Oracle Streams Advanced Queuing User's Guide and Reference for more information about dequeue options |
|
If If |
|
Specifies the message identifier of the message that is dequeued |
These procedures enable the current user to enqueue a message into the specified queue.
Note: This procedure is overloaded. One version of this procedure contains the |
DBMS_STREAMS_MESSAGING.ENQUEUE( queue_name IN VARCHAR2, payload IN SYS.AnyData, msgid OUT RAW);
To successfully enqueue messages into a queue, the current user must be mapped to a unique Advanced Queuing agent with the same name as the current user. You can run the DBMS_STREAMS_ADM.SET_UP_QUEUE
procedure and specify a user as the queue user to grant the necessary privileges to the user to perform enqueues. The Advanced Queuing agent is created automatically when you run SET_UP_QUEUE
and specify a queue user.