util/queue/RamQueuePlugin.h

Go to the documentation of this file.

/*------------------------------------------------------------------------------
Name:      RamQueuePlugin.h
Project:   xmlBlaster.org
Copyright: xmlBlaster.org, see xmlBlaster-LICENSE file
------------------------------------------------------------------------------*/

#ifndef _UTIL_QUEUE_RAMQUEUE_H
#define _UTIL_QUEUE_RAMQUEUE_H

#include <util/xmlBlasterDef.h>
#include <util/ReferenceHolder.h>
#include <util/queue/I_Queue.h>
#include <util/queue/MsgQueueEntry.h>
#include <util/thread/ThreadImpl.h>
#include <util/I_Log.h>
#include <set>

namespace org { namespace xmlBlaster { namespace util { namespace queue {

typedef std::set<EntryType, std::greater<EntryType> > StorageType;

class Dll_Export RamQueuePlugin : public I_Queue
{
protected:
   std::string        ME;
   org::xmlBlaster::util::Global&       global_;
   org::xmlBlaster::util::I_Log&          log_;
   org::xmlBlaster::util::qos::storage::ClientQueueProperty property_;
   StorageType   storage_;
   long          numOfBytes_;
   org::xmlBlaster::util::thread::Mutex accessMutex_;

public:
   RamQueuePlugin(org::xmlBlaster::util::Global& global, const org::xmlBlaster::util::qos::storage::ClientQueueProperty& property);

   RamQueuePlugin(const RamQueuePlugin& queue);

   RamQueuePlugin& operator =(const RamQueuePlugin& queue);
   
   virtual ~RamQueuePlugin();
    
   void put(const MsgQueueEntry &entry);

   const std::vector<EntryType> peekWithSamePriority(long maxNumOfEntries=-1, long maxNumOfBytes=-1) const;

   long randomRemove(const std::vector<EntryType>::const_iterator &start, const std::vector<EntryType>::const_iterator &end);

   long getNumOfEntries() const;

   long getMaxNumOfEntries() const;

   int64_t getNumOfBytes() const;

   int64_t getMaxNumOfBytes() const;

   void clear();

    bool empty() const;

   std::string getType() { static std::string type = "RAM"; return type; }

   std::string getVersion() { static std::string version = "1.0"; return version; }

   void destroy() { return; }
};

}}}} // namespace

#endif