---

AQMessage.h

#ifndef __AQMESSAGE_H_
#define __AQMESSAGE_H_

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

namespace OCICPP
{
using std::string;

class AQMessage
{
private:
    void*   payload;
    size_t  payload_sz;
    string  MessageID;
    string  CorrelationIdentifier;
    string  ExceptionQueue;
    int Delay;
    int Expiration;
    int Priority;

public:
    AQMessage();
    ~AQMessage();

    void    FreePayload(void);

    void    getPayload(string &Payload);
    void    getPayload(void **Payload, size_t *PayloadSize);
    void    setPayload(string &Payload);
    void    setPayload(void *Payload, size_t PayloadSize);

    string  getMessageID(void);
    void    setMessageID(string& MessageID);

    string  getCorrelationIdentifier(void);
    void    setCorrelationIdentifier(string& CorrelationIdentifier);

    string  getExceptionQueue(void);
    void    setExceptionQueue(string& ExceptionQueue);

    int getDelay(void);
    void    setDelay(int Delay);

    int getExpiration(void);
    void    setExpiration(int Expiration);

    int getPriority(void);
    void    setPriority(int Priority);
};

} // namespace OCICPP

#endif

---