xmlBlaster 2.1.0 API

org.xmlBlaster.util.qos.storage
Class ClientQueueProperty

java.lang.Object
  extended by org.xmlBlaster.util.qos.storage.QueuePropertyBase
      extended by org.xmlBlaster.util.qos.storage.ClientQueueProperty
All Implemented Interfaces:
java.lang.Cloneable

public class ClientQueueProperty
extends QueuePropertyBase

Helper class holding the client side queue properties.

See ConnectQos for XML sysntax.

See Also:
ConnectQos

Field Summary
private  java.lang.String defaultType
           
private static java.lang.String ME
           
 
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
ClientQueueProperty(Global glob, java.lang.String nodeId)
           
 
Method Summary
 void addAddress(Address address)
           
 boolean contains(Address other)
          Does the given address belong to this setup?
 AddressBase[] getAddresses()
           
 Address getCurrentAddress()
           
private  java.lang.String getDefaultType()
          Try to find the default protocol address as configured for clients
 java.lang.String getSettings()
          Show some important settings for logging
static void main(java.lang.String[] args)
          For testing: java org.xmlBlaster.util.qos.storage.ClientQueueProperty
 void setAddress(Address address)
          Currently only one address is allowed, failover addresses will be implemented in a future version
 void setAddresses(Address[] addresses)
           
 
Methods inherited from class org.xmlBlaster.util.qos.storage.QueuePropertyBase
checkConsistency, clone, 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, setRelating, 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

ME

private static final java.lang.String ME
See Also:
Constant Field Values

defaultType

private java.lang.String defaultType
Constructor Detail

ClientQueueProperty

public ClientQueueProperty(Global glob,
                           java.lang.String nodeId)
Parameters:
nodeId - If not null, the command line properties will look for prop[nodeId] as well, e.g. -queue/maxEntries and -queue/connection/maxEntries[heron] will be searched
Method Detail

getSettings

public final java.lang.String getSettings()
Show some important settings for logging


setAddress

public void setAddress(Address address)
Currently only one address is allowed, failover addresses will be implemented in a future version


addAddress

public void addAddress(Address address)

setAddresses

public void setAddresses(Address[] addresses)

getAddresses

public AddressBase[] getAddresses()
Overrides:
getAddresses in class QueuePropertyBase
Returns:
Never null but the length may be 0

getCurrentAddress

public Address getCurrentAddress()
Returns:
null if none available

getDefaultType

private java.lang.String getDefaultType()
Try to find the default protocol address as configured for clients

Returns:
Never null

contains

public boolean contains(Address other)
Does the given address belong to this setup?


main

public static void main(java.lang.String[] args)
For testing: java org.xmlBlaster.util.qos.storage.ClientQueueProperty


xmlBlaster 2.1.0 API

Copyright © 1999-2011 The xmlBlaster.org contributers.