Public Member Functions | |
ConnectQueueEntry (org::xmlBlaster::util::Global &global, org::xmlBlaster::util::qos::ConnectQosRef &connectQos, int priority=MAX_PRIORITY, org::xmlBlaster::util::Timestamp uniqueId=TimestampFactory::getInstance().getTimestamp()) | |
Constructor suited for operations like publishes. | |
ConnectQueueEntry (ConnectQueueEntry &entry) | |
copy constructor | |
MsgQueueEntry * | getClone () |
Create a new entry of myself. | |
~ConnectQueueEntry () | |
void * | getEmbeddedObject () |
gets the content of this queue entry (the embedded object). | |
virtual bool | isConnect () |
org::xmlBlaster::util::queue::MsgQueueEntry & | send (org::xmlBlaster::util::dispatch::I_ConnectionsHandler &connectionsHandler) |
size_t | getSizeInBytes () |
returns the size in bytes of this entry. | |
org::xmlBlaster::util::qos::ConnectQosRef | getConnectQos () |
| |
org::xmlBlaster::util::qos::ConnectReturnQosRef | getConnectReturnQos () |
| |
std::string | toXml (std::string &indent="") |
Definition at line 23 of file ConnectQueueEntry.h.
org::xmlBlaster::util::queue::ConnectQueueEntry::ConnectQueueEntry | ( | org::xmlBlaster::util::Global & | global, | |
org::xmlBlaster::util::qos::ConnectQosRef & | connectQos, | |||
int | priority = MAX_PRIORITY , |
|||
org::xmlBlaster::util::Timestamp | uniqueId = TimestampFactory::getInstance().getTimestamp() | |||
) |
Constructor suited for operations like publishes.
type | Only "MSG_RAW|connect" is supported |
Definition at line 17 of file ConnectQueueEntry.cpp.
References org::xmlBlaster::util::I_Log::call(), org::xmlBlaster::util::queue::MsgQueueEntry::log_, and org::xmlBlaster::util::queue::MsgQueueEntry::ME.
Referenced by getClone().
org::xmlBlaster::util::queue::ConnectQueueEntry::ConnectQueueEntry | ( | ConnectQueueEntry & | entry | ) |
org::xmlBlaster::util::queue::ConnectQueueEntry::~ConnectQueueEntry | ( | ) |
Definition at line 50 of file ConnectQueueEntry.cpp.
References org::xmlBlaster::util::queue::BlobHolder::data, and org::xmlBlaster::util::queue::BlobHolder::dataLen.
MsgQueueEntry * org::xmlBlaster::util::queue::ConnectQueueEntry::getClone | ( | ) | [virtual] |
Create a new entry of myself.
Implements org::xmlBlaster::util::queue::MsgQueueEntry.
Definition at line 45 of file ConnectQueueEntry.cpp.
References ConnectQueueEntry().
void * org::xmlBlaster::util::queue::ConnectQueueEntry::getEmbeddedObject | ( | ) | [virtual] |
gets the content of this queue entry (the embedded object).
In persistent queues this is the data which is stored as a blob.
Reimplemented from org::xmlBlaster::util::queue::MsgQueueEntry.
Definition at line 62 of file ConnectQueueEntry.cpp.
References org::xmlBlaster::util::I_Log::call(), org::xmlBlaster::util::MethodName::CONNECT, org::xmlBlaster::util::queue::MsgQueueEntry::connectQos_, org::xmlBlaster::util::queue::BlobHolder::data, org::xmlBlaster::util::queue::BlobHolder::dataLen, org::xmlBlaster::util::I_Log::dump(), org::xmlBlaster::util::queue::MsgQueueEntry::embeddedType_, org::xmlBlaster::util::Constants::ENTRY_TYPE_MSG_RAW, org::xmlBlaster::util::INTERNAL_ILLEGALARGUMENT, org::xmlBlaster::util::ReferenceHolder< T >::isNull(), org::xmlBlaster::util::queue::MsgQueueEntry::log_, and org::xmlBlaster::util::queue::MsgQueueEntry::ME.
int org::xmlBlaster::util::queue::ConnectQueueEntry::isConnect | ( | ) | [virtual] |
Reimplemented from org::xmlBlaster::util::queue::MsgQueueEntry.
Definition at line 58 of file ConnectQueueEntry.cpp.
MsgQueueEntry & org::xmlBlaster::util::queue::ConnectQueueEntry::send | ( | org::xmlBlaster::util::dispatch::I_ConnectionsHandler & | connectionsHandler | ) | [virtual] |
Reimplemented from org::xmlBlaster::util::queue::MsgQueueEntry.
Definition at line 107 of file ConnectQueueEntry.cpp.
References org::xmlBlaster::util::I_Log::call(), org::xmlBlaster::util::queue::MsgQueueEntry::connectQos_, org::xmlBlaster::util::dispatch::I_ConnectionsHandler::connectRaw(), org::xmlBlaster::util::queue::MsgQueueEntry::connectReturnQos_, org::xmlBlaster::util::I_Log::dump(), org::xmlBlaster::util::queue::MsgQueueEntry::log_, org::xmlBlaster::util::queue::MsgQueueEntry::ME, and toXml().
size_t org::xmlBlaster::util::queue::ConnectQueueEntry::getSizeInBytes | ( | ) | [virtual] |
returns the size in bytes of this entry.
Reimplemented from org::xmlBlaster::util::queue::MsgQueueEntry.
Definition at line 116 of file ConnectQueueEntry.cpp.
References org::xmlBlaster::util::queue::MsgQueueEntry::connectQos_, and org::xmlBlaster::util::ReferenceHolder< T >::isNull().
Referenced by org::xmlBlaster::test::TestQueue::testMaxNumOfBytes().
ConnectQosRef org::xmlBlaster::util::queue::ConnectQueueEntry::getConnectQos | ( | ) |
Definition at line 124 of file ConnectQueueEntry.cpp.
References org::xmlBlaster::util::queue::MsgQueueEntry::connectQos_.
Referenced by org::xmlBlaster::test::TestQueue::testOrder().
ConnectReturnQosRef org::xmlBlaster::util::queue::ConnectQueueEntry::getConnectReturnQos | ( | ) |
Definition at line 129 of file ConnectQueueEntry.cpp.
References org::xmlBlaster::util::queue::MsgQueueEntry::connectReturnQos_.
std::string org::xmlBlaster::util::queue::ConnectQueueEntry::toXml | ( | std::string & | indent = "" |
) | [virtual] |