Public Member Functions | ||||
QueuePropertyBase (org::xmlBlaster::util::Global &global, std::string &nodeId) | ||||
| ||||
QueuePropertyBase (QueuePropertyBase &prop) | ||||
QueuePropertyBase & | operator= (QueuePropertyBase &prop) | |||
virtual | ~QueuePropertyBase () | |||
void | setRelating (std::string &relating) | |||
| ||||
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::Global & | getGlobal () | |||
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::Global & | global_ | |||
org::xmlBlaster::util::I_Log & | log_ | |||
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 |
Definition at line 53 of file QueuePropertyBase.h.
org::xmlBlaster::util::qos::storage::QueuePropertyBase::QueuePropertyBase | ( | org::xmlBlaster::util::Global & | global, | |
std::string & | nodeId | |||
) |
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 | ) |
org::xmlBlaster::util::qos::storage::QueuePropertyBase::~QueuePropertyBase | ( | ) | [virtual] |
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 | ) |
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.
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.
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.
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.
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.
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.
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 | ) |
string org::xmlBlaster::util::qos::storage::QueuePropertyBase::getVersion | ( | ) |
The plugin version.
Definition at line 285 of file QueuePropertyBase.cpp.
References version_.
void org::xmlBlaster::util::qos::storage::QueuePropertyBase::setVersion | ( | std::string & | version | ) |
long org::xmlBlaster::util::qos::storage::QueuePropertyBase::getMaxEntriesCache | ( | ) |
Max number of messages for the cache of this queue.
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.
maxEntries |
Definition at line 315 of file QueuePropertyBase.cpp.
References maxEntriesCache_.
long org::xmlBlaster::util::qos::storage::QueuePropertyBase::getMaxBytes | ( | ) |
Max message queue size.
Definition at line 326 of file QueuePropertyBase.cpp.
References maxBytes_.
void org::xmlBlaster::util::qos::storage::QueuePropertyBase::setMaxBytes | ( | long | maxBytes | ) |
Max message queue size.
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.
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).
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).
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).
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).
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).
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).
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).
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).
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.
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.
onOverflow | The callback onOverflow, e.g. "et@mars.univers" |
string org::xmlBlaster::util::qos::storage::QueuePropertyBase::getOnOverflow | ( | ) |
Returns the onOverflow.
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.
onFailure | The callback onFailure, e.g. "et@mars.univers" |
string org::xmlBlaster::util::qos::storage::QueuePropertyBase::getOnFailure | ( | ) |
Returns the onFailure.
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.
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.
extraOffset | indenting of tags for nice output |
Referenced by org::xmlBlaster::test::TestConnectQos::testQueueProperty().
Global & org::xmlBlaster::util::qos::storage::QueuePropertyBase::getGlobal | ( | ) |
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.
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).
prop | e.g. "maxEntries" |
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().
friend class QueuePropertyFactory [friend] |
Definition at line 55 of file QueuePropertyBase.h.
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] |
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().
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().
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().
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().
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().
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().
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().
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().
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().
The settings for the storeSwapLevel.
Definition at line 98 of file QueuePropertyBase.h.
Referenced by copy(), getStoreSwapLevel(), and setStoreSwapLevel().
The settings for the storeSwapBytes.
Definition at line 101 of file QueuePropertyBase.h.
Referenced by copy(), getStoreSwapBytes(), and setStoreSwapBytes().
The settings for the storeSwapLevel.
Definition at line 104 of file QueuePropertyBase.h.
Referenced by copy(), getReloadSwapLevel(), and setReloadSwapLevel().
The settings for the storeSwapBytes.
Definition at line 107 of file QueuePropertyBase.h.
Referenced by copy(), getReloadSwapBytes(), and setReloadSwapBytes().
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().
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().
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] |