Public Methods | |
| AQQueue () | |
| void | init (string &queue_name, OCIEnv *env, OCISvcCtx *svc, OCIError *err) |
| string | Enqueue (OCICPP::AQMessage &msg) |
| void | Dequeue (OCICPP::AQMessage &msg, string req_msg_id="", string req_corr_id="") |
| void | DequeueByCorrelationIdentifier (OCICPP::AQMessage &msg, string req_corr_id) |
| void | DequeueByMessageID (OCICPP::AQMessage &msg, string req_msg_id) |
| void | setNavigation (int Navigation) |
| void | setDequeueMode (int DequeueMode) |
| void | setWait (int Wait) |
This class represents an advanced queue from the oracle server. This feature is available from Oracle 8 on within the Enterprise Edition. The current implementation does not provide structured payload, so the extensions available with the Object-option are not supported, currently.
|
|
Create an uninitialized advanced queue. |
|
|
Dequeues the next message matching the message id req_msg_id. and the correlation identifier req_corr_id. |
|
|
Dequeues the next message matching the correlation identifier req_corr_id. |
|
|
Dequeues the next message matching the message id req_msg_id. |
|
|
Enqueue a message msg in the queue. |
1.2.4-20010128 written by Dimitri van Heesch,
© 1997-2001