org.objectweb.joram.mom.dest.LoadingFactor Class Reference

Collaboration diagram for org.objectweb.joram.mom.dest.LoadingFactor:

[legend]List of all members.

Public Member Functions
	LoadingFactor (ClusterQueueImpl clusterQueueImpl, int producThreshold, int consumThreshold, boolean autoEvalThreshold, long validityPeriod)
void	setRateOfFlow (float rateOfFlow)
float	getRateOfFlow ()
void	setWait ()
float	evalRateOfFlow (int pendingMessages, int pendingRequests)
void	factorCheck (Hashtable clusters, int pendingMessages, int pendingRequests)
boolean	isOverloaded ()
String	toString ()
Public Attributes
ClusterQueueImpl	clusterQueueImpl
int	producThreshold = -1
int	consumThreshold = -1
boolean	autoEvalThreshold = false
long	validityPeriod = -1

---

Detailed Description

Definition at line 38 of file LoadingFactor.java.

---

Member Function Documentation

float org.objectweb.joram.mom.dest.LoadingFactor.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 < 1 the queue are more pending messages than pending requests. This value is set in all QueueClusterNot notification.

Parameters:

	pendingMessages
	pendingRequests

Returns:

Definition at line 206 of file LoadingFactor.java.

Referenced by org.objectweb.joram.mom.dest.LoadingFactor.factorCheck(), org.objectweb.joram.mom.dest.ClusterQueueImpl.lBMessageHope(), and org.objectweb.joram.mom.dest.ClusterQueueImpl.postProcess().

void org.objectweb.joram.mom.dest.LoadingFactor.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.

Parameters:

	clusters
	pendingMessages
	pendingRequests

Definition at line 243 of file LoadingFactor.java.

References org.objectweb.joram.mom.dest.LoadingFactor.evalRateOfFlow(), org.objectweb.joram.mom.dest.LoadingFactor.isOverloaded(), and org.objectweb.joram.mom.dest.LoadingFactor.validityPeriod.

Referenced by org.objectweb.joram.mom.dest.ClusterQueueImpl.postProcess(), org.objectweb.joram.mom.dest.ClusterQueueImpl.receiveRequest(), and org.objectweb.joram.mom.dest.ClusterQueueImpl.wakeUpNot().

Here is the call graph for this function:

boolean org.objectweb.joram.mom.dest.LoadingFactor.isOverloaded

(

)

true if cluster queue is overloaded. depends on activity.

Returns:

true if cluster queue is overloaded.

Definition at line 289 of file LoadingFactor.java.

Referenced by org.objectweb.joram.mom.dest.LoadingFactor.factorCheck().

---

Member Data Documentation

ClusterQueueImpl org.objectweb.joram.mom.dest.LoadingFactor.clusterQueueImpl

reference to clusterQueueImpl

Definition at line 85 of file LoadingFactor.java.

Referenced by org.objectweb.joram.mom.dest.LoadingFactor.LoadingFactor().

int org.objectweb.joram.mom.dest.LoadingFactor.producThreshold = -1

producer threshold

Definition at line 87 of file LoadingFactor.java.

Referenced by org.objectweb.joram.mom.dest.ClusterQueueImpl.postProcess(), and org.objectweb.joram.mom.dest.ClusterQueueImpl.setProducThreshold().

int org.objectweb.joram.mom.dest.LoadingFactor.consumThreshold = -1

consumer threshold

Definition at line 89 of file LoadingFactor.java.

Referenced by org.objectweb.joram.mom.dest.ClusterQueueImpl.receiveRequest(), org.objectweb.joram.mom.dest.ClusterQueueImpl.setConsumThreshold(), and org.objectweb.joram.mom.dest.LoadingFactor.toString().

boolean org.objectweb.joram.mom.dest.LoadingFactor.autoEvalThreshold = false

automatic eval threshold

Definition at line 91 of file LoadingFactor.java.

Referenced by org.objectweb.joram.mom.dest.ClusterQueueImpl.setAutoEvalThreshold(), and org.objectweb.joram.mom.dest.LoadingFactor.toString().

long org.objectweb.joram.mom.dest.LoadingFactor.validityPeriod = -1

validity period

Definition at line 93 of file LoadingFactor.java.

Referenced by org.objectweb.joram.mom.dest.LoadingFactor.factorCheck(), org.objectweb.joram.mom.dest.LoadingFactor.setWait(), and org.objectweb.joram.mom.dest.ClusterQueueImpl.setWaitAfterClusterReq().

---

The documentation for this class was generated from the following file:

• org/objectweb/joram/mom/dest/LoadingFactor.java

---