util/qos/MsgQosFactory.h

Go to the documentation of this file.

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

#ifndef _UTIL_QOS_MSGQOSFACTORY_H
#define _UTIL_QOS_MSGQOSFACTORY_H

#include <util/parser/XmlHandlerBase.h>
#include <util/Destination.h>
#include <util/qos/MsgQosData.h>
#include <util/SessionName.h>
#include <util/cluster/RouteInfo.h>
#include <string>
#include <util/qos/storage/QueuePropertyFactory.h>



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

class Dll_Export MsgQosFactory : public parser::XmlHandlerBase
{
private:
   std::string          ME;
   MsgQosData*          msgQosDataP_;
   Destination          destination_;
   org::xmlBlaster::util::cluster::RouteInfo routeInfo_;
   org::xmlBlaster::util::qos::storage::QueuePropertyFactory queuePropertyFactory_;

   bool inState_; // QosData
   bool inSubscribe_;
   bool inRedeliver_;
   bool inTopic_;
   bool inQueue_;
   bool inPersistence_;
   bool inDestination_;
   bool inSender_;
   bool inPriority_;
   bool inClientProperty_;
   bool inExpiration_;
   bool inRcvTimestamp_; // QosData
   bool inIsVolatile_;
   bool inIsPersistent_; // QosData
   bool inReadonly_;
   bool inRoute_;  // QosData
   bool sendRemainingLife_;
   bool inQos_;

   std::string LIFE_TIME;
   std::string FORCE_DESTROY;
   std::string REMAINING_LIFE;
   std::string READ_ONLY;
   std::string DESTROY_DELAY;
   std::string CREATE_DOM_ENTRY;
   std::string NANOS;
   std::string ID;
   std::string STRATUM;
   std::string TIMESTAMP;
   std::string DIRTY_READ;
   std::string INDEX;
   std::string SIZE;

   ClientProperty* clientProperty_;

   // Private copy ctor and assignement
   MsgQosFactory(const MsgQosFactory& data);
   MsgQosFactory& operator=(const MsgQosFactory& data);

public:
   MsgQosFactory(org::xmlBlaster::util::Global& global);

   ~MsgQosFactory();

   MsgQosData readObject(const std::string& xmlQos);

   void startElement(const std::string &name, const parser::AttributeMap& attrs);

   void characters(const std::string &ch);

   void endElement(const std::string &name);

   void sendRemainingLife(bool sendRemainingLife);
   
   bool sendRemainingLife();

};

}}}}

#endif