org::xmlBlaster::util::qos::storage::QueuePropertyBase Class Reference

Inheritance diagram for org::xmlBlaster::util::qos::storage::QueuePropertyBase:

Inheritance graph
[legend]
Collaboration diagram for org::xmlBlaster::util::qos::storage::QueuePropertyBase:

Collaboration graph
[legend]
List of all members.

Public Member Functions

 QueuePropertyBase (org::xmlBlaster::util::Global &global, std::string &nodeId)
 
Parameters:
nodeId If not null, the command line properties will look for prop[nodeId] as well, e.g.

 QueuePropertyBase (QueuePropertyBase &prop)
QueuePropertyBaseoperator= (QueuePropertyBase &prop)
virtual ~QueuePropertyBase ()
void setRelating (std::string &relating)
 
Parameters:
relating To what is this queue related: Constants.RELATING_CALLBACK | Constants.RELATING_SUBJECT | Constants.RELATING_CLIENT

std::string getRelating ()
 Returns the queue type.
Timestamp getExpires ()
 Span of life of this queue.
void setExpires (Timestamp expires)
 Span of life of this queue.
long getMaxEntries ()
 Max number of messages for this queue.
void setMaxEntries (long maxEntries)
 Max number of messages for this queue.
std::string getType ()
 The plugin type.
void setType (std::string &type)
 The plugin type
.
std::string getVersion ()
 The plugin version.
void setVersion (std::string &version)
 The plugin version
.
long getMaxEntriesCache ()
 Max number of messages for the cache of this queue.
void setMaxEntriesCache (long maxEntriesCache)
 Max number of messages for the cache of this queue.
long getMaxBytes ()
 Max message queue size.
void setMaxBytes (long maxBytes)
 Max message queue size.
long getMaxBytesCache ()
 Max message queue size for the cache of this queue.
long getStoreSwapLevel ()
 Gets the storeSwapLevel for the queue (only used on cache queues).
void setStoreSwapLevel (long storeSwapLevel)
 Sets the storeSwapLevel for the queue (only used on cache queues).
long getStoreSwapBytes ()
 Gets the storeSwapBytes for the queue (only used on cache queues).
void setStoreSwapBytes (long storeSwapBytes)
 Sets the storeSwapBytes for the queue (only used on cache queues).
long getReloadSwapLevel ()
 Gets the reloadSwapLevel for the queue (only used on cache queues).
void setReloadSwapLevel (long reloadSwapLevel)
 Sets the reloadSwapLevel for the queue (only used on cache queues).
long getReloadSwapBytes ()
 Gets the reloadSwapBytes for the queue (only used on cache queues).
void setReloadSwapBytes (long reloadSwapBytes)
 Sets the reloadSwapBytes for the queue (only used on cache queues).
void setMaxBytesCache (long maxBytesCache)
 Max message queue size for the cache of this queue.
void setOnOverflow (std::string &onOverflow)
 Set the callback onOverflow, it should fit to the protocol-relating.
std::string getOnOverflow ()
 Returns the onOverflow.
void setOnFailure (std::string &onFailure)
 Set the callback onFailure, it should fit to the protocol-relating.
std::string getOnFailure ()
 Returns the onFailure.
bool onFailureDeadMessage ()
 The default mode is to send a dead letter if callback fails permanently.
AddressVector getAddresses ()
 Access the reference counted addresses.
std::string toXml (std::string &extraOffset="")
 Dump state of this object into a XML ASCII std::string.
org::xmlBlaster::util::GlobalgetGlobal ()
 returns the global object
std::string getPropertyPrefix ()
 Relating "connection", "history", "callback" etc.
void setpropertyPrefix (std::string &prefix)
std::string getPrefix ()
 The command line prefix to configure the queue or msgUnitStore.
std::string getPropName (std::string &token)
 Helper for logging output, creates the property key for configuration (the command line property).
std::string getRootTagName ()

Protected Member Functions

void copy (QueuePropertyBase &prop)
void initialize (std::string &propertyPrefix)
 Configure property settings, add your own defaults in the derived class.
void setMaxExpires (Timestamp maxExpires)
Timestamp getMaxExpires ()
void setMinExpires (Timestamp minExpires)
Timestamp getMinExpires ()

Protected Attributes

std::string ME
org::xmlBlaster::util::Globalglobal_
org::xmlBlaster::util::I_Loglog_
std::string type_
 The queue plugin type "CACHE" "RAM" "JDBC".
std::string version_
 The queue plugin version "1.0" or similar.
long maxEntriesDefault_
 The max setting allowed for queue maxEntries is adjustable with property "queue/maxEntries=1000" (1000 messages is default).
long maxEntriesCacheDefault_
 The max setting allowed for queue maxEntriesCache is adjustable with property "queue/maxEntriesCache=1000" (1000 messages is default).
long maxBytesDefault_
 The max setting allowed for queue maxBytes in Bytes is adjustable with property "queue/maxBytes=4194304" (4 MBytes is default).
long maxBytesCacheDefault_
 The max setting allowed for queue maxBytesCache in Bytes is adjustable with property "queue/maxBytesCache=4000" (4 MBytes is default).
Timestamp minExpires_
 The min span of life is one second, changeable with property e.g.
Timestamp maxExpires_
 The max span of life of a queue is currently forever (=0), changeable with property e.g.
std::string relating_
 The unique protocol relating, e.g.
Timestamp expires_
 Span of life of this queue in milliseconds.
long maxEntries_
 The max.
long maxBytes_
 The max.
long maxEntriesCache_
 The max.
long storeSwapLevel_
 The settings for the storeSwapLevel.
long storeSwapBytes_
 The settings for the storeSwapBytes.
long reloadSwapLevel_
 The settings for the storeSwapLevel.
long reloadSwapBytes_
 The settings for the storeSwapBytes.
long maxBytesCache_
 The max.
std::string onOverflow_
 Error handling when queue is full: Constants.ONOVERFLOW_DEADMESSAGE | Constants.ONOVERFLOW_DISCARDOLDEST.
std::string onFailure_
 Error handling when callback failed (after all retries etc.
AddressVector addressArr_
 The corresponding callback address.
std::string nodeId_
 To allow specific configuration parameters for specific cluster nodes.

Properties

std::string Prefix_
 Relating "connection", "history", "callback" etc.
std::string rootTagName_

Friends

class QueuePropertyFactory

Detailed Description

Definition at line 53 of file QueuePropertyBase.h.


Constructor & Destructor Documentation

org::xmlBlaster::util::qos::storage::QueuePropertyBase::QueuePropertyBase ( org::xmlBlaster::util::Global global,
std::string &  nodeId 
)

Parameters:
nodeId If not null, the command line properties will look for prop[nodeId] as well, e.g.

-queue/maxEntries and -queue/maxEntries[heron] will be searched

org::xmlBlaster::util::qos::storage::QueuePropertyBase::QueuePropertyBase ( QueuePropertyBase prop  ) 

Definition at line 160 of file QueuePropertyBase.cpp.

References copy().

org::xmlBlaster::util::qos::storage::QueuePropertyBase::~QueuePropertyBase (  )  [virtual]

Definition at line 174 of file QueuePropertyBase.cpp.

References addressArr_.


Member Function Documentation

void org::xmlBlaster::util::qos::storage::QueuePropertyBase::copy ( QueuePropertyBase prop  )  [protected]

Definition at line 129 of file QueuePropertyBase.h.

References addressArr_, expires_, maxBytes_, maxBytesCache_, maxBytesCacheDefault_, maxBytesDefault_, maxEntries_, maxEntriesCache_, maxEntriesCacheDefault_, maxEntriesDefault_, maxExpires_, nodeId_, onFailure_, onOverflow_, relating_, reloadSwapBytes_, reloadSwapLevel_, rootTagName_, storeSwapBytes_, storeSwapLevel_, type_, and version_.

Referenced by operator=(), org::xmlBlaster::util::qos::storage::MsgUnitStoreProperty::operator=(), org::xmlBlaster::util::qos::storage::HistoryQueueProperty::operator=(), org::xmlBlaster::util::qos::storage::ClientQueueProperty::operator=(), org::xmlBlaster::util::qos::storage::CbQueueProperty::operator=(), and QueuePropertyBase().

void org::xmlBlaster::util::qos::storage::QueuePropertyBase::initialize ( std::string &  propertyPrefix  )  [protected]

Configure property settings, add your own defaults in the derived class.

void org::xmlBlaster::util::qos::storage::QueuePropertyBase::setMaxExpires ( Timestamp  maxExpires  )  [protected]

Definition at line 161 of file QueuePropertyBase.h.

Timestamp org::xmlBlaster::util::qos::storage::QueuePropertyBase::getMaxExpires (  )  [protected]

Definition at line 166 of file QueuePropertyBase.h.

void org::xmlBlaster::util::qos::storage::QueuePropertyBase::setMinExpires ( Timestamp  minExpires  )  [protected]

Definition at line 171 of file QueuePropertyBase.h.

Timestamp org::xmlBlaster::util::qos::storage::QueuePropertyBase::getMinExpires (  )  [protected]

Definition at line 176 of file QueuePropertyBase.h.

QueuePropertyBase & org::xmlBlaster::util::qos::storage::QueuePropertyBase::operator= ( QueuePropertyBase prop  ) 

Reimplemented in org::xmlBlaster::util::qos::storage::CbQueueProperty, org::xmlBlaster::util::qos::storage::ClientQueueProperty, org::xmlBlaster::util::qos::storage::HistoryQueueProperty, and org::xmlBlaster::util::qos::storage::MsgUnitStoreProperty.

Definition at line 167 of file QueuePropertyBase.cpp.

References copy().

void org::xmlBlaster::util::qos::storage::QueuePropertyBase::setRelating ( std::string &  relating  ) 

Parameters:
relating To what is this queue related: Constants.RELATING_CALLBACK | Constants.RELATING_SUBJECT | Constants.RELATING_CLIENT

Reimplemented in org::xmlBlaster::util::qos::storage::CbQueueProperty.

string org::xmlBlaster::util::qos::storage::QueuePropertyBase::getRelating (  ) 

Returns the queue type.

Returns:
relating To what is this queue related: Constants.RELATING_CALLBACK | Constants.RELATING_SUBJECT

Definition at line 208 of file QueuePropertyBase.cpp.

References relating_.

Referenced by org::xmlBlaster::util::qos::storage::CbQueueProperty::isSessionRelated(), org::xmlBlaster::util::qos::storage::CbQueueProperty::isSubjectRelated(), and org::xmlBlaster::test::TestConnectQos::testQueueProperty().

Timestamp org::xmlBlaster::util::qos::storage::QueuePropertyBase::getExpires (  ) 

Span of life of this queue.

Returns:
Expiry time in milliseconds or 0L if forever

Definition at line 217 of file QueuePropertyBase.cpp.

References expires_.

void org::xmlBlaster::util::qos::storage::QueuePropertyBase::setExpires ( Timestamp  expires  ) 

Span of life of this queue.

Parameters:
Expiry time in milliseconds

Definition at line 226 of file QueuePropertyBase.cpp.

References expires_, maxExpires_, and minExpires_.

long org::xmlBlaster::util::qos::storage::QueuePropertyBase::getMaxEntries (  ) 

Max number of messages for this queue.


Returns:
number of messages

Definition at line 244 of file QueuePropertyBase.cpp.

References maxEntries_.

Referenced by org::xmlBlaster::util::qos::storage::HistoryQueueProperty::getSettings(), org::xmlBlaster::util::qos::storage::ClientQueueProperty::getSettings(), org::xmlBlaster::util::qos::storage::CbQueueProperty::getSettings(), and org::xmlBlaster::util::queue::SQLiteQueuePlugin::SQLiteQueuePlugin().

void org::xmlBlaster::util::qos::storage::QueuePropertyBase::setMaxEntries ( long  maxEntries  ) 

Max number of messages for this queue.


Parameters:
maxEntries 

Definition at line 254 of file QueuePropertyBase.cpp.

References maxEntries_.

Referenced by PublishDemo::publish(), and org::xmlBlaster::test::TestQueue::testMaxNumOfEntries().

string org::xmlBlaster::util::qos::storage::QueuePropertyBase::getType (  ) 

The plugin type.


Returns:
e.g. "CACHE"

Definition at line 265 of file QueuePropertyBase.cpp.

References type_.

Referenced by org::xmlBlaster::util::qos::ConnectQosData::getCallbackType(), org::xmlBlaster::util::qos::storage::HistoryQueueProperty::getSettings(), org::xmlBlaster::util::qos::storage::ClientQueueProperty::getSettings(), and org::xmlBlaster::util::qos::storage::CbQueueProperty::getSettings().

void org::xmlBlaster::util::qos::storage::QueuePropertyBase::setType ( std::string &  type  ) 

The plugin type
.

Parameters:
type 

string org::xmlBlaster::util::qos::storage::QueuePropertyBase::getVersion (  ) 

The plugin version.


Returns:
e.g. "1.0"

Definition at line 285 of file QueuePropertyBase.cpp.

References version_.

void org::xmlBlaster::util::qos::storage::QueuePropertyBase::setVersion ( std::string &  version  ) 

The plugin version
.

Parameters:
version 

long org::xmlBlaster::util::qos::storage::QueuePropertyBase::getMaxEntriesCache (  ) 

Max number of messages for the cache of this queue.


Returns:
number of messages

Definition at line 305 of file QueuePropertyBase.cpp.

References maxEntriesCache_.

void org::xmlBlaster::util::qos::storage::QueuePropertyBase::setMaxEntriesCache ( long  maxEntriesCache  ) 

Max number of messages for the cache of this queue.


Parameters:
maxEntries 

Definition at line 315 of file QueuePropertyBase.cpp.

References maxEntriesCache_.

long org::xmlBlaster::util::qos::storage::QueuePropertyBase::getMaxBytes (  ) 

Max message queue size.


Returns:
Get max. message queue size in Bytes

Definition at line 326 of file QueuePropertyBase.cpp.

References maxBytes_.

void org::xmlBlaster::util::qos::storage::QueuePropertyBase::setMaxBytes ( long  maxBytes  ) 

Max message queue size.


Returns:
Set max. message queue size in Bytes

Definition at line 336 of file QueuePropertyBase.cpp.

References maxBytes_.

Referenced by org::xmlBlaster::test::TestQueue::testMaxNumOfBytes().

long org::xmlBlaster::util::qos::storage::QueuePropertyBase::getMaxBytesCache (  ) 

Max message queue size for the cache of this queue.


Returns:
Get max. message queue size in Bytes

Definition at line 347 of file QueuePropertyBase.cpp.

References maxBytesCache_.

long org::xmlBlaster::util::qos::storage::QueuePropertyBase::getStoreSwapLevel (  ) 

Gets the storeSwapLevel for the queue (only used on cache queues).


Returns:
Get storeSwapLevel in bytes.

Definition at line 358 of file QueuePropertyBase.cpp.

References storeSwapLevel_.

Referenced by org::xmlBlaster::test::TestConnectQos::testQueueProperty().

void org::xmlBlaster::util::qos::storage::QueuePropertyBase::setStoreSwapLevel ( long  storeSwapLevel  ) 

Sets the storeSwapLevel for the queue (only used on cache queues).


Parameters:
Set storeSwapLevel in bytes.

Definition at line 368 of file QueuePropertyBase.cpp.

References storeSwapLevel_.

long org::xmlBlaster::util::qos::storage::QueuePropertyBase::getStoreSwapBytes (  ) 

Gets the storeSwapBytes for the queue (only used on cache queues).


Returns:
Get storeSwapBytes in bytes.

Definition at line 378 of file QueuePropertyBase.cpp.

References storeSwapBytes_.

Referenced by org::xmlBlaster::test::TestConnectQos::testQueueProperty().

void org::xmlBlaster::util::qos::storage::QueuePropertyBase::setStoreSwapBytes ( long  storeSwapBytes  ) 

Sets the storeSwapBytes for the queue (only used on cache queues).


Parameters:
Set storeSwapBytes in bytes.

Definition at line 388 of file QueuePropertyBase.cpp.

References storeSwapBytes_.

long org::xmlBlaster::util::qos::storage::QueuePropertyBase::getReloadSwapLevel (  ) 

Gets the reloadSwapLevel for the queue (only used on cache queues).


Returns:
Get reloadSwapLevel in bytes.

Definition at line 398 of file QueuePropertyBase.cpp.

References reloadSwapLevel_.

Referenced by org::xmlBlaster::test::TestConnectQos::testQueueProperty().

void org::xmlBlaster::util::qos::storage::QueuePropertyBase::setReloadSwapLevel ( long  reloadSwapLevel  ) 

Sets the reloadSwapLevel for the queue (only used on cache queues).


Parameters:
Set reloadSwapLevel in bytes.

Definition at line 408 of file QueuePropertyBase.cpp.

References reloadSwapLevel_.

long org::xmlBlaster::util::qos::storage::QueuePropertyBase::getReloadSwapBytes (  ) 

Gets the reloadSwapBytes for the queue (only used on cache queues).


Returns:
Get reloadSwapBytes in bytes.

Definition at line 418 of file QueuePropertyBase.cpp.

References reloadSwapBytes_.

Referenced by org::xmlBlaster::test::TestConnectQos::testQueueProperty().

void org::xmlBlaster::util::qos::storage::QueuePropertyBase::setReloadSwapBytes ( long  reloadSwapBytes  ) 

Sets the reloadSwapBytes for the queue (only used on cache queues).


Parameters:
Set reloadSwapBytes in bytes.

Definition at line 428 of file QueuePropertyBase.cpp.

References reloadSwapBytes_.

void org::xmlBlaster::util::qos::storage::QueuePropertyBase::setMaxBytesCache ( long  maxBytesCache  ) 

Max message queue size for the cache of this queue.


Returns:
Set max. message queue size in Bytes

Definition at line 438 of file QueuePropertyBase.cpp.

References maxBytesCache_.

void org::xmlBlaster::util::qos::storage::QueuePropertyBase::setOnOverflow ( std::string &  onOverflow  ) 

Set the callback onOverflow, it should fit to the protocol-relating.

Parameters:
onOverflow The callback onOverflow, e.g. "et@mars.univers"

string org::xmlBlaster::util::qos::storage::QueuePropertyBase::getOnOverflow (  ) 

Returns the onOverflow.

Returns:
e.g. "IOR:00001100022...." or "et@universe.com"

Definition at line 475 of file QueuePropertyBase.cpp.

References onOverflow_.

Referenced by org::xmlBlaster::util::qos::storage::HistoryQueueProperty::getSettings(), org::xmlBlaster::util::qos::storage::ClientQueueProperty::getSettings(), org::xmlBlaster::util::qos::storage::CbQueueProperty::getSettings(), org::xmlBlaster::util::qos::storage::MsgUnitStoreProperty::onOverflowDeadMessage(), org::xmlBlaster::util::qos::storage::HistoryQueueProperty::onOverflowDeadMessage(), and org::xmlBlaster::util::qos::storage::CbQueueProperty::onOverflowDeadMessage().

void org::xmlBlaster::util::qos::storage::QueuePropertyBase::setOnFailure ( std::string &  onFailure  ) 

Set the callback onFailure, it should fit to the protocol-relating.

Parameters:
onFailure The callback onFailure, e.g. "et@mars.univers"

string org::xmlBlaster::util::qos::storage::QueuePropertyBase::getOnFailure (  ) 

Returns the onFailure.

Returns:
e.g. "IOR:00001100022...." or "et@universe.com"

Definition at line 509 of file QueuePropertyBase.cpp.

References onFailure_.

Referenced by org::xmlBlaster::util::qos::storage::HistoryQueueProperty::getSettings(), org::xmlBlaster::util::qos::storage::ClientQueueProperty::getSettings(), org::xmlBlaster::util::qos::storage::CbQueueProperty::getSettings(), and onFailureDeadMessage().

bool org::xmlBlaster::util::qos::storage::QueuePropertyBase::onFailureDeadMessage (  ) 

The default mode is to send a dead letter if callback fails permanently.

Definition at line 517 of file QueuePropertyBase.cpp.

References getOnFailure(), and org::xmlBlaster::util::Constants::ONOVERFLOW_DEADMESSAGE.

AddressVector org::xmlBlaster::util::qos::storage::QueuePropertyBase::getAddresses (  ) 

Access the reference counted addresses.

Returns:
null if none available

Definition at line 528 of file QueuePropertyBase.cpp.

References addressArr_.

std::string org::xmlBlaster::util::qos::storage::QueuePropertyBase::toXml ( std::string &  extraOffset = ""  ) 

Dump state of this object into a XML ASCII std::string.


Parameters:
extraOffset indenting of tags for nice output
Returns:
The xml representation

Referenced by org::xmlBlaster::test::TestConnectQos::testQueueProperty().

Global & org::xmlBlaster::util::qos::storage::QueuePropertyBase::getGlobal (  ) 

returns the global object

Definition at line 587 of file QueuePropertyBase.cpp.

References global_.

string org::xmlBlaster::util::qos::storage::QueuePropertyBase::getPropertyPrefix (  ) 

Relating "connection", "history", "callback" etc.

Definition at line 605 of file QueuePropertyBase.cpp.

void org::xmlBlaster::util::qos::storage::QueuePropertyBase::setpropertyPrefix ( std::string &  prefix  ) 

string org::xmlBlaster::util::qos::storage::QueuePropertyBase::getPrefix (  ) 

The command line prefix to configure the queue or msgUnitStore.

Returns:
e.g. "persistence/msgUnitStore/" or "queue/history/"

Definition at line 619 of file QueuePropertyBase.cpp.

References getRootTagName().

std::string org::xmlBlaster::util::qos::storage::QueuePropertyBase::getPropName ( std::string &  token  ) 

Helper for logging output, creates the property key for configuration (the command line property).

Parameters:
prop e.g. "maxEntries"
Returns:
e.g. "-queue/history/maxEntries" or "-queue/history/maxEntriesCache"

string org::xmlBlaster::util::qos::storage::QueuePropertyBase::getRootTagName (  ) 

Reimplemented in org::xmlBlaster::util::qos::storage::MsgUnitStoreProperty.

Definition at line 636 of file QueuePropertyBase.cpp.

References rootTagName_.

Referenced by getPrefix().


Friends And Related Function Documentation

friend class QueuePropertyFactory [friend]

Definition at line 55 of file QueuePropertyBase.h.


Member Data Documentation

std::string org::xmlBlaster::util::qos::storage::QueuePropertyBase::ME [protected]

Definition at line 57 of file QueuePropertyBase.h.

org::xmlBlaster::util::Global& org::xmlBlaster::util::qos::storage::QueuePropertyBase::global_ [protected]

Definition at line 58 of file QueuePropertyBase.h.

Referenced by org::xmlBlaster::util::qos::storage::ClientQueueProperty::getCurrentAddress(), org::xmlBlaster::util::qos::storage::CbQueueProperty::getCurrentCallbackAddress(), and getGlobal().

org::xmlBlaster::util::I_Log& org::xmlBlaster::util::qos::storage::QueuePropertyBase::log_ [protected]

Definition at line 59 of file QueuePropertyBase.h.

std::string org::xmlBlaster::util::qos::storage::QueuePropertyBase::type_ [protected]

The queue plugin type "CACHE" "RAM" "JDBC".

Definition at line 62 of file QueuePropertyBase.h.

Referenced by copy(), and getType().

std::string org::xmlBlaster::util::qos::storage::QueuePropertyBase::version_ [protected]

The queue plugin version "1.0" or similar.

Definition at line 65 of file QueuePropertyBase.h.

Referenced by copy(), and getVersion().

long org::xmlBlaster::util::qos::storage::QueuePropertyBase::maxEntriesDefault_ [protected]

The max setting allowed for queue maxEntries is adjustable with property "queue/maxEntries=1000" (1000 messages is default).

Definition at line 68 of file QueuePropertyBase.h.

Referenced by copy().

long org::xmlBlaster::util::qos::storage::QueuePropertyBase::maxEntriesCacheDefault_ [protected]

The max setting allowed for queue maxEntriesCache is adjustable with property "queue/maxEntriesCache=1000" (1000 messages is default).

Definition at line 71 of file QueuePropertyBase.h.

Referenced by copy().

long org::xmlBlaster::util::qos::storage::QueuePropertyBase::maxBytesDefault_ [protected]

The max setting allowed for queue maxBytes in Bytes is adjustable with property "queue/maxBytes=4194304" (4 MBytes is default).

Definition at line 74 of file QueuePropertyBase.h.

Referenced by copy().

long org::xmlBlaster::util::qos::storage::QueuePropertyBase::maxBytesCacheDefault_ [protected]

The max setting allowed for queue maxBytesCache in Bytes is adjustable with property "queue/maxBytesCache=4000" (4 MBytes is default).

Definition at line 77 of file QueuePropertyBase.h.

Referenced by copy().

Timestamp org::xmlBlaster::util::qos::storage::QueuePropertyBase::minExpires_ [protected]

The min span of life is one second, changeable with property e.g.

"queue/expires.min=2000" milliseconds

Definition at line 80 of file QueuePropertyBase.h.

Referenced by setExpires().

Timestamp org::xmlBlaster::util::qos::storage::QueuePropertyBase::maxExpires_ [protected]

The max span of life of a queue is currently forever (=0), changeable with property e.g.

"queue/expires.max=3600000" milliseconds

Definition at line 83 of file QueuePropertyBase.h.

Referenced by copy(), and setExpires().

std::string org::xmlBlaster::util::qos::storage::QueuePropertyBase::relating_ [protected]

The unique protocol relating, e.g.

"IOR"

Definition at line 87 of file QueuePropertyBase.h.

Referenced by copy(), and getRelating().

Timestamp org::xmlBlaster::util::qos::storage::QueuePropertyBase::expires_ [protected]

Span of life of this queue in milliseconds.

Definition at line 89 of file QueuePropertyBase.h.

Referenced by copy(), getExpires(), and setExpires().

long org::xmlBlaster::util::qos::storage::QueuePropertyBase::maxEntries_ [protected]

The max.

capacity of the queue in number of entries

Definition at line 91 of file QueuePropertyBase.h.

Referenced by copy(), getMaxEntries(), and setMaxEntries().

long org::xmlBlaster::util::qos::storage::QueuePropertyBase::maxBytes_ [protected]

The max.

capacity of the queue in Bytes

Definition at line 93 of file QueuePropertyBase.h.

Referenced by copy(), getMaxBytes(), and setMaxBytes().

long org::xmlBlaster::util::qos::storage::QueuePropertyBase::maxEntriesCache_ [protected]

The max.

capacity of the cache of the queue in number of entries

Definition at line 95 of file QueuePropertyBase.h.

Referenced by copy(), getMaxEntriesCache(), and setMaxEntriesCache().

long org::xmlBlaster::util::qos::storage::QueuePropertyBase::storeSwapLevel_ [protected]

The settings for the storeSwapLevel.

Definition at line 98 of file QueuePropertyBase.h.

Referenced by copy(), getStoreSwapLevel(), and setStoreSwapLevel().

long org::xmlBlaster::util::qos::storage::QueuePropertyBase::storeSwapBytes_ [protected]

The settings for the storeSwapBytes.

Definition at line 101 of file QueuePropertyBase.h.

Referenced by copy(), getStoreSwapBytes(), and setStoreSwapBytes().

long org::xmlBlaster::util::qos::storage::QueuePropertyBase::reloadSwapLevel_ [protected]

The settings for the storeSwapLevel.

Definition at line 104 of file QueuePropertyBase.h.

Referenced by copy(), getReloadSwapLevel(), and setReloadSwapLevel().

long org::xmlBlaster::util::qos::storage::QueuePropertyBase::reloadSwapBytes_ [protected]

The settings for the storeSwapBytes.

Definition at line 107 of file QueuePropertyBase.h.

Referenced by copy(), getReloadSwapBytes(), and setReloadSwapBytes().

long org::xmlBlaster::util::qos::storage::QueuePropertyBase::maxBytesCache_ [protected]

The max.

capacity of the queue in Bytes for the cache

Definition at line 110 of file QueuePropertyBase.h.

Referenced by copy(), getMaxBytesCache(), and setMaxBytesCache().

std::string org::xmlBlaster::util::qos::storage::QueuePropertyBase::onOverflow_ [protected]

Error handling when queue is full: Constants.ONOVERFLOW_DEADMESSAGE | Constants.ONOVERFLOW_DISCARDOLDEST.

Definition at line 113 of file QueuePropertyBase.h.

Referenced by copy(), and getOnOverflow().

std::string org::xmlBlaster::util::qos::storage::QueuePropertyBase::onFailure_ [protected]

Error handling when callback failed (after all retries etc.

): Constants.ONOVERFLOW_DEADMESSAGE

Definition at line 116 of file QueuePropertyBase.h.

Referenced by copy(), and getOnFailure().

AddressVector org::xmlBlaster::util::qos::storage::QueuePropertyBase::addressArr_ [protected]

The corresponding callback address.

Definition at line 119 of file QueuePropertyBase.h.

Referenced by copy(), getAddresses(), org::xmlBlaster::util::qos::storage::CbQueueProperty::getCallbackAddresses(), org::xmlBlaster::util::qos::storage::ClientQueueProperty::getCurrentAddress(), org::xmlBlaster::util::qos::storage::CbQueueProperty::getCurrentCallbackAddress(), org::xmlBlaster::util::qos::storage::ClientQueueProperty::getSettings(), org::xmlBlaster::util::qos::storage::CbQueueProperty::getSettings(), org::xmlBlaster::util::qos::storage::ClientQueueProperty::setAddress(), org::xmlBlaster::util::qos::storage::ClientQueueProperty::setAddresses(), org::xmlBlaster::util::qos::storage::CbQueueProperty::setCallbackAddress(), org::xmlBlaster::util::qos::storage::CbQueueProperty::setCallbackAddresses(), and ~QueuePropertyBase().

std::string org::xmlBlaster::util::qos::storage::QueuePropertyBase::nodeId_ [protected]

To allow specific configuration parameters for specific cluster nodes.

Definition at line 122 of file QueuePropertyBase.h.

Referenced by copy().


Property Documentation

std::string org::xmlBlaster::util::qos::storage::QueuePropertyBase::Prefix_ [protected]

Relating "connection", "history", "callback" etc.

Definition at line 125 of file QueuePropertyBase.h.

std::string org::xmlBlaster::util::qos::storage::QueuePropertyBase::rootTagName_ [protected]

Definition at line 127 of file QueuePropertyBase.h.

Referenced by copy(), and getRootTagName().


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