org.xmlBlaster.util.qos.storage
Class ClientQueueProperty

java.lang.Object
  org.xmlBlaster.util.qos.storage.QueuePropertyBase
      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, toString, toXml, toXml, usage, usage

Methods inherited from class java.lang.Object

equals, finalize, getClass, hashCode, notify, notifyAll, 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