Package org.objectweb.joram.mom.dest

Class AliasInQueue

java.lang.Object

fr.dyade.aaa.agent.Agent

org.objectweb.joram.mom.dest.Destination

org.objectweb.joram.mom.dest.Queue

org.objectweb.joram.mom.dest.AliasInQueue

All Implemented Interfaces:

AgentMBean, Encodable, Serializable, DestinationMBean, QueueMBean

public class AliasInQueue
extends Queue

The AliasInQueue class forwards messages to a destination in an other Joram server using the destination ID.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.objectweb.joram.mom.dest.Queue

Queue.QueueFactory

Field Summary

Fields

Modifier and Type	Field	Description
private int	currentDestination
private static boolean	DEBUG
private ArrayList<AgentId>	destinations
private static Logger	logger
private ArrayList<Long>	metrics
private long	minMetrics
private ArrayList<Long>	newmetrics
private ArrayList<Long>	oldmetrics
private static long	pendingMessagesThreshold
private int	receivedMetrics
static String	REMOTE_AGENT_OPTION
private static long	serialVersionUID	define serialVersionUID for interoperability
private long	weightLeft
private ArrayList<Long>	weights

Fields inherited from class org.objectweb.joram.mom.dest.Queue

ARRIVAL_STATE_PREFIX, arrivalState, cload, defaultDMQId, defaultRedeliveryDelay, defaultThreshold, delayed, DELIVERY_TABLE_PREFIX, DELIVERY_TIMEOUT, deliveryTable, hcons, hprod, LENIENT_REDELIVERY_DELAY, LENIENT_UNDELIVERABLE, logmsg, messages, msgTxPrefix, msgTxPrefixLength, nbExpirations, nbMaxMsg, nbMsgsDeniedSinceCreation, pload, receiving, requests

Fields inherited from class org.objectweb.joram.mom.dest.Destination

clients, dmqId, freeReading, freeWriting, nbMsgsDeliverSinceCreation, nbMsgsSentToDMQSinceCreation, READ, READWRITE, strbuf, strictCounters, task, temporary, WRITE

Fields inherited from class fr.dyade.aaa.agent.Agent

agentProfiling, emptyString, fixed, logmon

Fields inherited from interface fr.dyade.aaa.common.encoding.Encodable

BOOLEAN_ENCODED_SIZE, BYTE_ENCODED_SIZE, DOUBLE_ENCODED_SIZE, FLOAT_ENCODED_SIZE, INT_ENCODED_SIZE, LONG_ENCODED_SIZE, SHORT_ENCODED_SIZE

Constructor Summary

Constructors

Constructor	Description
AliasInQueue()	The maximum time the notification can wait in the network before expiration.

Method Summary

Modifier and Type	Method	Description
protected void	doUnknownAgent(UnknownAgent uA)	Method specifically processing an UnknownAgent instance.
int	getEncodableClassId()	Enables the sub classes not to implement this method.
void	handleAdminRequestNot(AgentId from, FwdAdminRequestNot not)
protected void	handleExpiredNot(AgentId from, ExpiredNot not)
protected void	handlePongNot(AgentId from, PongNot not)
ClientMessages	preProcess(AgentId from, ClientMessages cm)	This method is needed to add processing before the standard handling.
protected void	processSetRight(AgentId user, int right)	set user right.
void	react(AgentId from, Notification not)	Distributes the received notifications to the appropriate reactions.
private void	sendNot(Notification not)
void	setProperties(Properties properties, boolean firstTime)	Configures an AliasInQueue instance.
String	toString()	Returns a string representation of this destination.
void	wakeUpNot(WakeUpNot not)	wake up, and cleans the queue.

Methods inherited from class org.objectweb.joram.mom.dest.Queue

abortReceiveRequest, acknowledgeRequest, addClientMessages, addDeliveryTimeMessage, addMessage, agentSave, browseRequest, checkDelivery, cleanPendingMessage, cleanPendingMessage, cleanWaitingRequest, cleanWaitingRequest, clear, decode, deliverMessages, denyRequest, doAdminSyncNotification, doClientMessages, doDeleteNot, doRightRequest, encode, exportMessages, finalize, getClientMessages, getConsumerLoad, getDefaultDMQId, getDefaultRedeliveryDelay, getDefaultThreshold, getDelayedMessage, getDelayedMessageCount, getDelayedMessages, getDeliveredMessageCount, getDeliveryDelay, getEncodedSize, getMessage, getMessages, getMessagesView, getMsgTxPrefix, getNbMaxMsg, getNbMsgsDeliverSinceCreation, getNbMsgsDeniedSinceCreation, getNbMsgsReceiveSinceCreation, getPendingMessageCount, getProducerLoad, getQueueMessage, getRedeliveryDelay, getStats, getThreshold, getType, getWaitingRequestCount, initialize, isPause, isSyncExceptionOnFullDest, isUndeliverable, isValidJMXAttribute, messageDelivered, messageRemoved, processDeliveryTime, receiveRequest, setDefaultRedeliveryDelay, setDeliveryDelay, setMsgTxName, setNbMaxMsg, setPause, setRedeliveryDelay, setSyncExceptionOnFullDest, setThreshold, storeMessage

Methods inherited from class org.objectweb.joram.mom.dest.Destination

agentFinalize, agentInitialize, clientMessages, delete, deleteNot, forward, getCreationDate, getCreationTimeInMillis, getDestinationId, getDMQAgentId, getDMQId, getJMXStatistics, getNbMsgsSentToDMQSinceCreation, getPeriod, getRight, getRights, getRights, handleDeniedMessage, interceptorsAvailable, isAdministrator, isFreeReading, isFreeWriting, isLocal, isReader, isWriter, postProcess, processAdminCommand, processInterceptors, processPause, processStartHandler, processStopHandler, replyToTopic, requestGroupNot, setAdminId, setFreeReading, setFreeWriting, setPeriod, setRight, unknownAgent

Methods inherited from class fr.dyade.aaa.agent.Agent

delete, delete, deploy, deploy, getAgentId, getCommitTime, getId, getLogTopic, getName, getReactNb, getReactTime, hasName, incWorkInProgress, isAgentProfiling, isDeployed, isFixed, isUpdated, load, needToBeCommited, resetCommitTime, resetReactTime, resetTimer, save, sendTo, sendTo, sendTo, setAgentProfiling, setName, setNoSave, setSave

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface fr.dyade.aaa.agent.AgentMBean

getAgentId, getCommitTime, getReactNb, getReactTime, isAgentProfiling, isFixed, resetCommitTime, resetReactTime, resetTimer, setAgentProfiling

Methods inherited from interface org.objectweb.joram.mom.dest.DestinationMBean

delete, getCreationDate, getCreationTimeInMillis, getDestinationId, getDMQId, getName, getNbMsgsSentToDMQSinceCreation, getPeriod, getRight, getRights, isFreeReading, isFreeWriting, setFreeReading, setFreeWriting, setPeriod

Field Detail

serialVersionUID

private static final long serialVersionUID

define serialVersionUID for interoperability

See Also:

Constant Field Values

logger

private static final Logger logger

DEBUG

private static final boolean DEBUG

REMOTE_AGENT_OPTION

public static final String REMOTE_AGENT_OPTION

See Also:

Constant Field Values

destinations

private ArrayList<AgentId> destinations

oldmetrics

private ArrayList<Long> oldmetrics

newmetrics

private ArrayList<Long> newmetrics

metrics

private ArrayList<Long> metrics

weights

private ArrayList<Long> weights

currentDestination

private int currentDestination

receivedMetrics

private int receivedMetrics

minMetrics

private long minMetrics

weightLeft

private long weightLeft

pendingMessagesThreshold

private static long pendingMessagesThreshold

Constructor Detail

AliasInQueue

public AliasInQueue()

The maximum time the notification can wait in the network before expiration.

Method Detail

setProperties

public void setProperties(Properties properties,
                          boolean firstTime)
                   throws Exception

Configures an AliasInQueue instance.

Overrides:

setProperties in class Queue

Parameters:

properties - The initial set of properties.

Throws:

Exception

preProcess

public ClientMessages preProcess(AgentId from,
                                 ClientMessages cm)

Description copied from class: Destination

This method is needed to add processing before the standard handling. It is used in subclass of Queue and Topic. The incoming messages can be modified or deleted during the processing.

Overrides:

preProcess in class Destination

Parameters:

from - The sender of the message

cm - The incoming messages.

Returns:

The incoming messages after processing.

react

public void react(AgentId from,
                  Notification not)
           throws Exception

Description copied from class: Queue

Distributes the received notifications to the appropriate reactions.

Overrides:

react in class Queue

Parameters:

from - agent sending notification

not - notification to react to

Throws:

Exception - unspecialized exception

handleExpiredNot

protected void handleExpiredNot(AgentId from,
                                ExpiredNot not)

Overrides:

handleExpiredNot in class Queue

doUnknownAgent

protected void doUnknownAgent(UnknownAgent uA)

Description copied from class: Queue

Method specifically processing an UnknownAgent instance.

The specific processing is done when a QueueMsgReply was sent to a requester which does not exist anymore. In that case, the messages sent to this requester and not yet acknowledged are marked as "denied" for delivery to an other requester, and a new delivery sequence is launched. Messages considered as undeliverable are removed and sent to the DMQ.

Overrides:

doUnknownAgent in class Queue

toString

public String toString()

Description copied from class: Queue

Returns a string representation of this destination.

Specified by:

toString in interface AgentMBean

Specified by:

toString in interface DestinationMBean

Overrides:

toString in class Queue

Returns:

a string representation of this destination.

processSetRight

protected void processSetRight(AgentId user,
                               int right)
                        throws RequestException

Description copied from class: Destination

set user right.

Overrides:

processSetRight in class Destination

Throws:

RequestException

handleAdminRequestNot

public void handleAdminRequestNot(AgentId from,
                                  FwdAdminRequestNot not)

Overrides:

handleAdminRequestNot in class Queue

See Also:

Destination.handleAdminRequestNot(fr.dyade.aaa.agent.AgentId, org.objectweb.joram.mom.notifications.FwdAdminRequestNot)

sendNot

private void sendNot(Notification not)

wakeUpNot

public void wakeUpNot(WakeUpNot not)

Description copied from class: Queue

wake up, and cleans the queue.

Overrides:

wakeUpNot in class Queue

handlePongNot

protected void handlePongNot(AgentId from,
                             PongNot not)

getEncodableClassId

public int getEncodableClassId()

Description copied from class: Agent

Enables the sub classes not to implement this method.

Specified by:

getEncodableClassId in interface Encodable

Overrides:

getEncodableClassId in class Queue

Returns:

-1