org.objectweb.joram.mom.dest
Class DistributionQueue

java.lang.Object
  extended by fr.dyade.aaa.agent.Agent
      extended by org.objectweb.joram.mom.dest.Destination
          extended by org.objectweb.joram.mom.dest.Queue
              extended by org.objectweb.joram.mom.dest.DistributionQueue
All Implemented Interfaces:
AgentMBean, BagSerializer, java.io.Serializable, DestinationMBean, QueueMBean

public class DistributionQueue
extends Queue

The DistributionQueue class implements the MOM distribution queue behavior, delivering messages via the DistributionModule.

See Also:
Serialized Form

Field Summary
static org.objectweb.util.monolog.api.Logger logger
           
 
Fields inherited from class org.objectweb.joram.mom.dest.Queue
arrivalsCounter, consumers, contexts, deliveredMsgs, messages, nbMaxMsg, receiving, requests
 
Fields inherited from class org.objectweb.joram.mom.dest.Destination
_rights, clients, creationDate, dmqId, freeReading, freeWriting, nbMsgsDeliverSinceCreation, nbMsgsReceiveSinceCreation, nbMsgsSentToDMQSinceCreation, READ, READWRITE, task, WAKEUP_PERIOD, WRITE
 
Fields inherited from class fr.dyade.aaa.agent.Agent
emptyString, fixed, logmon
 
Constructor Summary
DistributionQueue()
           
 
Method Summary
 void agentFinalize(boolean lastTime)
          Finalizes the agent before it is garbaged.
 void initialize(boolean firstTime)
          Initializes the destination.
 ClientMessages preProcess(AgentId from, ClientMessages cm)
          This method is needed to add processing before the standard handling.
 void setProperties(java.util.Properties properties)
          Configures a DistributionQueue instance.
 java.lang.String toString()
          Returns a string representation of this destination.
 void updateProperties(java.util.Properties prop)
          Update properties configuration, they are processed by the distribution module
 
Methods inherited from class org.objectweb.joram.mom.dest.Queue
abortReceiveRequest, acknowledgeRequest, addClientMessages, addMessage, browseRequest, checkDelivery, cleanPendingMessage, cleanPendingMessage, cleanWaitingRequest, cleanWaitingRequest, deliverMessages, denyRequest, doClientMessages, doDeleteNot, doRightRequest, doUnknownAgent, getClientMessages, getDefaultDMQId, getDefaultThreshold, getDeliveredMessageCount, getMessage, getMessages, getMessagesView, getMsgTxPrefix, getNbMaxMsg, getNbMsgsReceiveSinceCreation, getPendingMessageCount, getQueueMessage, getThreshold, getType, getWaitingRequestCount, handleAdminRequestNot, handleExpiredNot, isUndeliverable, isValidJMXAttribute, messageDelivered, messageRemoved, react, readBag, receiveRequest, setMsgTxName, setNbMaxMsg, setThreshold, storeMessage, storeMessageHeader, wakeUpNot, writeBag
 
Methods inherited from class org.objectweb.joram.mom.dest.Destination
agentInitialize, clientMessages, delete, deleteNot, forward, getCreationDate, getCreationTimeInMillis, getDestinationId, getDMQAgentId, getDMQId, getJMXStatistics, getMBeanName, getNbMsgsDeliverSinceCreation, getNbMsgsSentToDMQSinceCreation, getPeriod, getRight, getRights, getRights, handleDeniedMessage, interceptorsAvailable, isAdministrator, isFreeReading, isFreeWriting, isLocal, isReader, isWriter, postProcess, processAdminCommand, processInterceptors, processSetRight, 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, isDeployed, isFixed, needToBeCommited, save, sendTo, sendTo, sendTo, setName, setNoSave, setSave
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 
Methods inherited from interface org.objectweb.joram.mom.dest.DestinationMBean
delete, getCreationDate, getCreationTimeInMillis, getDestinationId, getDMQId, getName, getNbMsgsDeliverSinceCreation, getNbMsgsSentToDMQSinceCreation, getPeriod, getRight, getRights, isFreeReading, isFreeWriting, setFreeReading, setFreeWriting, setPeriod
 
Methods inherited from interface fr.dyade.aaa.agent.AgentMBean
getAgentId, getCommitTime, getReactNb, getReactTime, isFixed
 

Field Detail

logger

public static org.objectweb.util.monolog.api.Logger logger
Constructor Detail

DistributionQueue

public DistributionQueue()
Method Detail

setProperties

public void setProperties(java.util.Properties properties)
                   throws RequestException
Configures a DistributionQueue instance.

Overrides:
setProperties in class Destination
Parameters:
properties - The initial set of properties.
Throws:
RequestException

initialize

public void initialize(boolean firstTime)
Description copied from class: Queue
Initializes the destination.

Overrides:
initialize in class Queue
Parameters:
firstTime - true when first called by the factory

agentFinalize

public void agentFinalize(boolean lastTime)
Description copied from class: Destination
Finalizes the agent before it is garbaged.

Overrides:
agentFinalize in class Destination
Parameters:
lastTime - true when last called by the factory on agent deletion.

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.
See Also:
DistributionModule.processMessages(ClientMessages), Destination.preProcess(AgentId, ClientMessages)

toString

public java.lang.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 agent.

updateProperties

public void updateProperties(java.util.Properties prop)
                      throws java.lang.Exception
Update properties configuration, they are processed by the distribution module

Overrides:
updateProperties in class Destination
Parameters:
prop - properties to update.
Throws:
java.lang.Exception


Copyright © 2011 ScalAgent D.T.. All Rights Reserved.