util/qos/MsgQosData.h

Go to the documentation of this file.

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

#ifndef _XMLBLASTER_UTIL_QOS_MSGQOSDATA_H
#define _XMLBLASTER_UTIL_QOS_MSGQOSDATA_H

#include <util/xmlBlasterDef.h>
#include <util/qos/QosData.h>

#include <util/Destination.h>
#include <util/qos/TopicProperty.h>
#include <util/cluster/RouteInfo.h>
#include <util/cluster/NodeId.h>
#include <util/Prop.h>
#include <vector>
#include <string>

namespace org { namespace xmlBlaster { namespace util { namespace qos {

class Dll_Export MsgQosData : public QosData
{
private:

   mutable bool isExpired_; // = false; // cache the expired state for performance reasons

   org::xmlBlaster::util::qos::TopicProperty* topicProperty_;
 // TODO: Change to use glob instead of org::xmlBlaster::util::Global singleton! What about performance? Put variable into org::xmlBlaster::util::Global?
   long maxLifeTime_;

/*
   {
      return org::xmlBlaster::util::Global.instance().getProperty().get("message.maxLifeTime", -1L);
   }
*/

   std::string subscriptionId_;

   Prop<bool> subscribable_;

   int redeliver_;
   long queueIndex_; //  = -1L;
   long queueSize_; // = -1L;

   Prop<bool> forceUpdate_; // = DEFAULT_forceUpdate;
   Prop<bool> forceDestroy_;

   long lifeTime_; // = -1;

   long remainingLifeStatic_; // = -1;

   void init();

protected:
   std::vector<Destination> destinationList_;


   // TODO: Pass with client QoS!!!
   bool receiveTimestampHumanReadable_; // = org::xmlBlaster::util::Global.instance().getProperty().get("cb.receiveTimestampHumanReadable", false);

   void copy(const MsgQosData& data);

public:
//   long size_;

   MsgQosData(org::xmlBlaster::util::Global& global, const std::string& serialData="");

   MsgQosData(const MsgQosData& data);

   MsgQosData& operator=(const MsgQosData& data);

   virtual ~MsgQosData();

   void setSubscribable(const bool isSubcribeable);

   bool isSubscribable() const;

   bool isPtp() const;

   void setVolatile(bool volatileFlag);

   bool isVolatile() const;

   bool isVolatileDefault() const;

   void setSubscriptionId(const std::string& subscriptionId);

   std::string getSubscriptionId() const;

   void setForceUpdate(bool forceUpdate);

   bool isForceUpdate() const;

   void setReadonly(bool readonly);

   bool isReadonly() const;

   void setRedeliver(int redeliver);

   void incrRedeliver();

   int getRedeliver() const;

   void setQueueSize(long queueSize);

   long getQueueSize() const;

   void setQueueIndex(long queueIndex);

   long getQueueIndex() const;

   long getLifeTime()const;

   void setLifeTime(long lifeTime);

   long getRemainingLife() const;

   long getRemainingLifeStatic() const;

   void setRemainingLifeStatic(long remainingLifeStatic);

   bool isExpired() const;

   long getMaxLifeTime() const;

   std::string getXmlRcvTimestamp();

   void touchRcvTimestamp();

   std::vector<Destination> getDestinations() const;

   void addDestination(const Destination& destination);

   virtual std::string toXml(bool clearText, const std::string& extraOffset="") const;

   virtual std::string toXml(const std::string& extraOffset="") const;

   virtual MsgQosData* getClone() const;

   void setTopicProperty(const org::xmlBlaster::util::qos::TopicProperty& prop);

   org::xmlBlaster::util::qos::TopicProperty getTopicProperty();

   bool hasTopicProperty() const;

   void setForceDestroy(bool forceDestroy);

   bool isForceDestroy() const;

};

}}}}

#endif