org::xmlBlaster::util::queue::ConnectQueueEntry Class Reference

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

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

[legend]List of all members.

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 ()
	Returns: Can be null ref.isNull()
org::xmlBlaster::util::qos::ConnectReturnQosRef	getConnectReturnQos ()
	Returns: Can be null ref.isNull()
std::string	toXml (std::string &indent="")

---

Detailed Description

Definition at line 23 of file ConnectQueueEntry.h.

---

Constructor & Destructor Documentation

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.

Parameters:

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

)

copy constructor

Definition at line 30 of file ConnectQueueEntry.cpp.

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.

---

Member Function Documentation

MsgQueueEntry * org::xmlBlaster::util::queue::ConnectQueueEntry::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 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

(

)

Returns:

Can be null ref.isNull()

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

(

)

Returns:

Can be null ref.isNull()

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]

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

Referenced by send().

---

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

• util/queue/ConnectQueueEntry.h
• util/queue/ConnectQueueEntry.cpp