org::xmlBlaster::util::queue::PublishQueueEntry Class Reference

Inheritance diagram for org::xmlBlaster::util::queue::PublishQueueEntry:

[legend]Collaboration diagram for org::xmlBlaster::util::queue::PublishQueueEntry:

[legend]List of all members.

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)
	Parameters: type  "MSG_RAW|publish" std::string getEmbeddedType() const { return org::xmlBlaster::util::Constants::ENTRY_TYPE_MSG_RAW + "|" + org::xmlBlaster::util::MethodName::PUBLISH }
size_t	getSizeInBytes ()
	returns the size in bytes of this entry.
org::xmlBlaster::client::qos::PublishReturnQos *	getPublishReturnQos ()
std::string	toXml (std::string &indent="")

---

Detailed Description

Definition at line 23 of file PublishQueueEntry.h.

---

Constructor & Destructor Documentation

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.

Parameters:

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

)

copy constructor

Definition at line 34 of file PublishQueueEntry.cpp.

---

Member Function Documentation

PublishQueueEntry & org::xmlBlaster::util::queue::PublishQueueEntry::operator=

(

PublishQueueEntry &

entry

)

assignment constructor

Definition at line 41 of file PublishQueueEntry.cpp.

MsgQueueEntry * org::xmlBlaster::util::queue::PublishQueueEntry::getClone

(

)

[virtual]

Create a new entry of myself.

Returns:

The cloned entry, is is allocated with new and it is your responsibility to delete it

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]

Parameters:

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]

Reimplemented from org::xmlBlaster::util::queue::MsgQueueEntry.

Referenced by send().

---

The documentation for this class was generated from the following files:

• util/queue/PublishQueueEntry.h
• util/queue/PublishQueueEntry.cpp