org.objectweb.joram.mom.dest
Class LoadingFactor
java.lang.Object
org.objectweb.joram.mom.dest.LoadingFactor
- Serializable
public class LoadingFactor
extends java.lang.Object
implements Serializable
autoEvalThreshold
public boolean autoEvalThreshold
automatic eval threshold
clusterQueueImpl
public ClusterQueueImpl clusterQueueImpl
reference to clusterQueueImpl
consumThreshold
public int consumThreshold
consumer threshold
producThreshold
public int producThreshold
producer threshold
validityPeriod
public long validityPeriod
validity period
LoadingFactor
public LoadingFactor(ClusterQueueImpl clusterQueueImpl,
int producThreshold,
int consumThreshold,
boolean autoEvalThreshold,
long validityPeriod)
evalRateOfFlow
public float evalRateOfFlow(int pendingMessages,
int pendingRequests)
eval the rate of flow (means).
if rateOfFlow > 1 the queue are more pending requests
than pending messages.
else if rateOfFlow <321 the queue are more pending messages
than pending requests.
This value is set in all QueueClusterNot notification.
factorCheck
public void factorCheck(Hashtable clusters,
int pendingMessages,
int pendingRequests)
this method eval the rate of flow and activity.
if necessary send "give or hope" messages, and
update threshol.
getRateOfFlow
public float getRateOfFlow()
isOverloaded
public boolean isOverloaded()
return true if cluster queue is overloaded.
depends on activity.
setRateOfFlow
public void setRateOfFlow(float rateOfFlow)
setWait
public void setWait()
toString
public String toString()
Copyright B) 2004 Scalagent - All rights reserved