com.scalagent.joram.mom.dest.ftp
Class FtpQueue

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 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.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
FtpQueue()
           
 
Method Summary
 void initialize(boolean firstTime)
          Initializes the destination.
protected  boolean isFtpMsg(Message message)
           
 ClientMessages preProcess(AgentId from, ClientMessages not)
          This method is needed to add processing before the standard handling.
 void react(AgentId from, Notification not)
          Distributes the received notifications to the appropriate reactions.
 void setProperties(java.util.Properties prop)
          Configures a FtpQueue instance.
 java.lang.String toString()
          Returns a string representation of this destination.
 
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
 
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

ftpImplName

public java.lang.String ftpImplName
Constructor Detail

FtpQueue

public FtpQueue()
Method Detail

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 notification
not - 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 message
not - The incoming messages.
Returns:
The incoming messages after processing.

isFtpMsg

protected boolean isFtpMsg(Message message)


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