org.xmlBlaster.util.qos.storage
Class CbQueueProperty
java.lang.Object
org.xmlBlaster.util.qos.storage.QueuePropertyBase
org.xmlBlaster.util.qos.storage.CbQueueProperty
- All Implemented Interfaces:
- java.lang.Cloneable
public class CbQueueProperty
- extends QueuePropertyBase
Helper class holding callback queue properties.
See ConnectQos for XML sysntax.
- See Also:
ConnectQos
Fields inherited from class org.xmlBlaster.util.qos.storage.QueuePropertyBase |
addressArr, c, debug, DEFAULT_bytesCacheDefault, DEFAULT_bytesDefault, DEFAULT_maxEntries, DEFAULT_maxEntriesCacheDefault, DEFAULT_onFailure, DEFAULT_onOverflow, DEFAULT_reloadSwapBytesRatio, DEFAULT_reloadSwapLevelRatio, DEFAULT_storeSwapBytesRatio, DEFAULT_storeSwapLevelRatio, DEFAULT_type, DEFAULT_version, EMPTY_ADDRESS_ARR, glob, maxBytes, maxBytesCache, maxBytesDefault, maxEntries, maxEntriesCache, maxEntriesCacheDefault, nodeId, onFailure, onOverflow, relating, reloadSwapBytes, reloadSwapLevel, storeSwapBytes, storeSwapLevel, type, version |
Methods inherited from class org.xmlBlaster.util.qos.storage.QueuePropertyBase |
checkConsistency, clone, getAddresses, getDebug, getGlobal, getMaxBytes, getMaxBytesCache, getMaxBytesCacheProp, getMaxBytesProp, getMaxEntries, getMaxEntriesCache, getMaxEntriesCacheProp, getMaxEntriesProp, getOnFailure, getOnOverflow, getPrefix, getPropertyPrefix, getPropName, getRelating, getReloadSwapBytes, getReloadSwapLevel, getRootTagName, getStoreSwapBytes, getStoreSwapLevel, getType, getTypeVersion, getVersion, initialize, isEmbedded, onFailureDeadMessage, setDebug, setEmbedded, setMaxBytes, setMaxBytesCache, setMaxEntries, setMaxEntriesCache, setOnFailure, setOnOverflow, setReloadSwapBytes, setReloadSwapLevel, setStoreSwapBytes, setStoreSwapLevel, setType, setVersion, startElement, toString, toXml, toXml, usage, usage |
Methods inherited from class java.lang.Object |
equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
log
private static java.util.logging.Logger log
hasCallbackAddress
private boolean hasCallbackAddress
CbQueueProperty
public CbQueueProperty(Global glob,
java.lang.String relating,
java.lang.String nodeId)
- Parameters:
relating
- To what is this queue related: Constants.RELATING_CALLBACK | Constants.RELATING_SUBJECT- See Also:
QueuePropertyBase.QueuePropertyBase(Global, String)
getSettings
public final java.lang.String getSettings()
- Show some important settings for logging
setRelating
public final void setRelating(java.lang.String relating)
- Overrides:
setRelating
in class QueuePropertyBase
- Parameters:
relating
- To what is this queue related: Constants.RELATING_CALLBACK | Constants.RELATING_SUBJECT
isSubjectRelated
public final boolean isSubjectRelated()
isSessionRelated
public final boolean isSessionRelated()
onOverflowDeadMessage
public final boolean onOverflowDeadMessage()
setCallbackAddress
public void setCallbackAddress(CallbackAddress address)
- Currently only one address is allowed, failover addresses will be implemented in a future version
setCallbackAddresses
public void setCallbackAddresses(CallbackAddress[] addresses)
getCallbackAddresses
public CallbackAddress[] getCallbackAddresses()
- Returns:
- array with size 0 if none available
hasCallbackAddress
public boolean hasCallbackAddress()
getCurrentCallbackAddress
public CallbackAddress getCurrentCallbackAddress()
- Returns:
- Never null, a default is created if none is available.
main
public static void main(java.lang.String[] args)
- For testing: java org.xmlBlaster.engine.helper.CbQueueProperty
Copyright © 1999-2014 The xmlBlaster.org contributers.