aqqueue.h

oracle引用库

#ifndef __AQQUEUE_H_
#define __AQQUEUE_H_

#include <string>

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

using std::string;

namespace OCICPP
{

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