org.objectweb.joram.mom.dest
Class DistributionQueue
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.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.Destination |
_rights, clients, creationDate, dmqId, freeReading, freeWriting, nbMsgsDeliverSinceCreation, nbMsgsReceiveSinceCreation, nbMsgsSentToDMQSinceCreation, READ, READWRITE, task, WAKEUP_PERIOD, WRITE |
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 |
logger
public static org.objectweb.util.monolog.api.Logger logger
DistributionQueue
public DistributionQueue()
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 messagecm
- 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.