com.scalagent.joram.mom.dest.ftp
Class FtpQueue
java.lang.Object
fr.dyade.aaa.agent.Agent
org.objectweb.joram.mom.dest.Destination
org.objectweb.joram.mom.dest.Queue
com.scalagent.joram.mom.dest.ftp.FtpQueue
- All Implemented Interfaces:
- AgentMBean, BagSerializer, java.io.Serializable, DestinationMBean, QueueMBean
public class FtpQueue
- extends Queue
The FtpQueue
class implements the MOM queue behaviour,
basically storing messages and delivering them upon clients requests.
- See Also:
- Serialized Form
Field Summary |
java.lang.String |
ftpImplName
|
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, readBag, receiveRequest, setMsgTxName, setNbMaxMsg, setThreshold, storeMessage, storeMessageHeader, wakeUpNot, writeBag |
Methods inherited from class org.objectweb.joram.mom.dest.Destination |
agentFinalize, 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, updateProperties |
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
ftpImplName
public java.lang.String ftpImplName
FtpQueue
public FtpQueue()
setProperties
public void setProperties(java.util.Properties prop)
throws RequestException
- Configures a
FtpQueue
instance.
- Overrides:
setProperties
in class Destination
- Parameters:
prop
- The initial set of properties.
- Throws:
RequestException
initialize
public void initialize(boolean firstTime)
- Initializes the destination.
- Overrides:
initialize
in class Queue
- Parameters:
firstTime
- true when first called by the factory
react
public void react(AgentId from,
Notification not)
throws java.lang.Exception
- Description copied from class:
Queue
- Distributes the received notifications to the appropriate reactions.
- Overrides:
react
in class Queue
- Parameters:
from
- agent sending notificationnot
- notification to react to
- Throws:
java.lang.Exception
- unspecialized exception
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.
preProcess
public ClientMessages preProcess(AgentId from,
ClientMessages not)
- 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 messagenot
- The incoming messages.
- Returns:
- The incoming messages after processing.
isFtpMsg
protected boolean isFtpMsg(Message message)
Copyright © 2011 ScalAgent D.T.. All Rights Reserved.