xmlBlaster 2.1.0 API

org.xmlBlaster.util.qos.storage
Class CbQueueProperty

java.lang.Object
  extended by org.xmlBlaster.util.qos.storage.QueuePropertyBase
      extended by 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

Field Summary
private static java.util.logging.Logger log
           
 
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
 
Constructor Summary
CbQueueProperty(Global glob, java.lang.String relating, java.lang.String nodeId)
           
 
Method Summary
 CallbackAddress[] getCallbackAddresses()
           
 CallbackAddress getCurrentCallbackAddress()
           
 java.lang.String getSettings()
          Show some important settings for logging
 boolean isSessionRelated()
           
 boolean isSubjectRelated()
           
static void main(java.lang.String[] args)
          For testing: java org.xmlBlaster.engine.helper.CbQueueProperty
 boolean onOverflowDeadMessage()
           
 void setCallbackAddress(CallbackAddress address)
          Currently only one address is allowed, failover addresses will be implemented in a future version
 void setCallbackAddresses(CallbackAddress[] addresses)
           
 void setRelating(java.lang.String relating)
           
 
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, toXml, toXml, usage, usage
 
Methods inherited from class java.lang.Object
equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

log

private static java.util.logging.Logger log
Constructor Detail

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)
Method Detail

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

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


xmlBlaster 2.1.0 API

Copyright © 1999-2011 The xmlBlaster.org contributers.