---

AQQueue.h

#ifndef __AQQUEUE_H_
#define __AQQUEUE_H_

#include "ocicpp.h"
#include "OraError.h"
#include "AQMessage.h"

namespace OCICPP
{
using std::string;

class AQQueue
{
private:
    int     Initialized;
    string      queue_name;
    OCIEnv      *envhp;
    OCISvcCtx   *svchp;
    OCIError    *errhp;
    OCIType     *payload_tdo;
    int     Navigation;
    int     DequeueMode;
    int     Wait;

public:
        AQQueue();
    void    init(std::string& queue_name, OCIEnv *env, OCISvcCtx *svc, OCIError *err);
    string  Enqueue(OCICPP::AQMessage &msg);
    void    Dequeue(OCICPP::AQMessage &msg, std::string req_msg_id = "", std::string req_corr_id = "");
    void    DequeueByCorrelationIdentifier(OCICPP::AQMessage &msg, std::string req_corr_id);
    void    DequeueByMessageID(OCICPP::AQMessage &msg, std::string req_msg_id);

    void    setNavigation(int Navigation);
    void    setDequeueMode(int DequeueMode);
    void    setWait(int Wait);
};

} // namespace OCICPP


#endif

---