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. |