Public Member Functions | ||||
PublishQueueEntry (org::xmlBlaster::util::Global &global, org::xmlBlaster::util::MessageUnit &msgUnit, int priority=NORM_PRIORITY, org::xmlBlaster::util::Timestamp uniqueId=TimestampFactory::getInstance().getTimestamp()) | ||||
Constructor. | ||||
~PublishQueueEntry () | ||||
PublishQueueEntry (PublishQueueEntry &entry) | ||||
copy constructor | ||||
PublishQueueEntry & | operator= (PublishQueueEntry &entry) | |||
assignment constructor | ||||
MsgQueueEntry * | getClone () | |||
Create a new entry of myself. | ||||
virtual bool | isPublish () | |||
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::client::qos::PublishReturnQos * | getPublishReturnQos () | |||
std::string | toXml (std::string &indent="") |
Definition at line 23 of file PublishQueueEntry.h.
org::xmlBlaster::util::queue::PublishQueueEntry::PublishQueueEntry | ( | org::xmlBlaster::util::Global & | global, | |
org::xmlBlaster::util::MessageUnit & | msgUnit, | |||
int | priority = NORM_PRIORITY , |
|||
org::xmlBlaster::util::Timestamp | uniqueId = TimestampFactory::getInstance().getTimestamp() | |||
) |
Constructor.
You can provide a name different from 'publish'. Normally the entry has the priority specified in the org::xmlBlaster::client::qos::PublishQos of the message unit. However, if you pass a non-negative priority, it will be taken as the priority of this entry, in other words, the priority of the message unit will be ignored.
type | Only "MSG_RAW|publish" is supported |
Definition at line 19 of file PublishQueueEntry.cpp.
References org::xmlBlaster::util::I_Log::call(), org::xmlBlaster::util::qos::QosData::getPriority(), org::xmlBlaster::util::MessageUnit::getQos(), org::xmlBlaster::util::queue::MsgQueueEntry::log_, org::xmlBlaster::util::queue::MsgQueueEntry::ME, and org::xmlBlaster::util::queue::MsgQueueEntry::priority_.
Referenced by getClone().
org::xmlBlaster::util::queue::PublishQueueEntry::~PublishQueueEntry | ( | ) |
Definition at line 30 of file PublishQueueEntry.cpp.
org::xmlBlaster::util::queue::PublishQueueEntry::PublishQueueEntry | ( | PublishQueueEntry & | entry | ) |
PublishQueueEntry & org::xmlBlaster::util::queue::PublishQueueEntry::operator= | ( | PublishQueueEntry & | entry | ) |
MsgQueueEntry * org::xmlBlaster::util::queue::PublishQueueEntry::getClone | ( | ) | [virtual] |
Create a new entry of myself.
Implements org::xmlBlaster::util::queue::MsgQueueEntry.
Definition at line 48 of file PublishQueueEntry.cpp.
References PublishQueueEntry().
int org::xmlBlaster::util::queue::PublishQueueEntry::isPublish | ( | ) | [virtual] |
Reimplemented from org::xmlBlaster::util::queue::MsgQueueEntry.
Definition at line 70 of file PublishQueueEntry.cpp.
MsgQueueEntry & org::xmlBlaster::util::queue::PublishQueueEntry::send | ( | org::xmlBlaster::util::dispatch::I_ConnectionsHandler & | connectionsHandler | ) | [virtual] |
type | "MSG_RAW|publish" std::string getEmbeddedType() const { return org::xmlBlaster::util::Constants::ENTRY_TYPE_MSG_RAW + "|" + org::xmlBlaster::util::MethodName::PUBLISH } |
Reimplemented from org::xmlBlaster::util::queue::MsgQueueEntry.
Definition at line 53 of file PublishQueueEntry.cpp.
References org::xmlBlaster::util::I_Log::call(), org::xmlBlaster::util::I_Log::dump(), org::xmlBlaster::util::dispatch::I_ConnectionsHandler::getConnection(), org::xmlBlaster::util::queue::MsgQueueEntry::log_, org::xmlBlaster::util::queue::MsgQueueEntry::ME, org::xmlBlaster::util::queue::MsgQueueEntry::msgUnit_, org::xmlBlaster::client::protocol::I_XmlBlasterConnection::publish(), org::xmlBlaster::util::queue::MsgQueueEntry::publishReturnQos_, and toXml().
size_t org::xmlBlaster::util::queue::PublishQueueEntry::getSizeInBytes | ( | ) | [virtual] |
returns the size in bytes of this entry.
Reimplemented from org::xmlBlaster::util::queue::MsgQueueEntry.
Definition at line 74 of file PublishQueueEntry.cpp.
References org::xmlBlaster::util::MessageUnit::getSizeInBytes(), and org::xmlBlaster::util::queue::MsgQueueEntry::msgUnit_.
PublishReturnQos * org::xmlBlaster::util::queue::PublishQueueEntry::getPublishReturnQos | ( | ) |
Definition at line 65 of file PublishQueueEntry.cpp.
References org::xmlBlaster::util::queue::MsgQueueEntry::publishReturnQos_.
std::string org::xmlBlaster::util::queue::PublishQueueEntry::toXml | ( | std::string & | indent = "" |
) | [virtual] |