util/queue/ConnectQueueEntry.h

Go to the documentation of this file.

/*------------------------------------------------------------------------------
Name:      ConnectQueueEntry.h
Project:   xmlBlaster.org
Copyright: xmlBlaster.org, see xmlBlaster-LICENSE file
------------------------------------------------------------------------------*/
#ifndef _UTIL_QUEUE_CONNECTQUEUEENRY_H
#define _UTIL_QUEUE_CONNECTQUEUEENRY_H

#include <util/MethodName.h>
#include <util/queue/MsgQueueEntry.h>

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

class Dll_Export ConnectQueueEntry : public org::xmlBlaster::util::queue::MsgQueueEntry
{
   mutable BlobHolder blobHolder_;

   ConnectQueueEntry& operator =(const ConnectQueueEntry& entry);

public:

   ConnectQueueEntry(org::xmlBlaster::util::Global& global,
                     const org::xmlBlaster::util::qos::ConnectQosRef& connectQos,
                     int priority=MAX_PRIORITY,
                     org::xmlBlaster::util::Timestamp uniqueId = TimestampFactory::getInstance().getTimestamp());

   ConnectQueueEntry(const ConnectQueueEntry& entry);

   MsgQueueEntry *getClone() const;

   ~ConnectQueueEntry();

   const void* getEmbeddedObject() const;
   
   virtual bool isConnect() const;

   // this should actually be in another interface but since it is an only method we put it here.
   const org::xmlBlaster::util::queue::MsgQueueEntry& send(org::xmlBlaster::util::dispatch::I_ConnectionsHandler& connectionsHandler) const;

   size_t getSizeInBytes() const;

   org::xmlBlaster::util::qos::ConnectQosRef getConnectQos() const;

   org::xmlBlaster::util::qos::ConnectReturnQosRef getConnectReturnQos() const;

   std::string toXml(const std::string& indent="") const;

};

}}}} // namespace

#endif