aqmessage.h

oracle引用库

#ifndef __AQMESSAGE_H_
#define __AQMESSAGE_H_

#include <string>
#include "ocicpp.h"
#include "OraError.h"

using std::string;

namespace OCICPP
{


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