com.scalagent.joram.mom.dest.ftp
Class FtpQueueImpl
java.lang.Object
org.objectweb.joram.mom.dest.DestinationImpl
org.objectweb.joram.mom.dest.QueueImpl
com.scalagent.joram.mom.dest.ftp.FtpQueueImpl
- All Implemented Interfaces:
- java.io.Serializable, DestinationImplMBean, QueueImplMBean
public class FtpQueueImpl
- extends QueueImpl
The FtpQueueImpl
class implements the MOM queue behaviour,
basically storing messages and delivering them upon clients requests.
- See Also:
- Serialized Form
Fields inherited from class org.objectweb.joram.mom.dest.DestinationImpl |
_rights, agent, clients, creationDate, dmqId, freeReading, freeWriting, nbMsgsDeliverSinceCreation, nbMsgsReceiveSinceCreation, nbMsgsSentToDMQSinceCreation, READ, READWRITE, WAKEUP_PERIOD, WRITE |
Constructor Summary |
FtpQueueImpl(AgentId adminId,
java.util.Properties prop)
Constructs a FtpQueueImpl instance. |
Methods inherited from class org.objectweb.joram.mom.dest.QueueImpl |
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, 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.DestinationImpl |
canBeDeleted, clientMessages, delete, deleteNot, forward, getCreationDate, getCreationTimeInMillis, getDestinationId, getDMQAgentId, getDMQId, getId, getJMXStatistics, getName, getNbMsgsDeliverSinceCreation, getNbMsgsSentToDMQSinceCreation, getPeriod, getRight, getRights, getRights, handleDeniedMessage, isAdministrator, isFreeReading, isFreeWriting, isLocal, isReader, isWriter, postProcess, processSetRight, replyToTopic, requestGroupNot, setAgent, setFreeReading, setFreeWriting, setPeriod, setRight, specialAdminProcess, specialAdminRequest, unknownAgent |
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.DestinationImplMBean |
delete, getCreationDate, getCreationTimeInMillis, getDestinationId, getDMQId, getName, getNbMsgsDeliverSinceCreation, getNbMsgsSentToDMQSinceCreation, getPeriod, getRight, getRights, isFreeReading, isFreeWriting, setFreeReading, setFreeWriting, setPeriod |
serialVersionUID
private static final long serialVersionUID
- define serialVersionUID for interoperability
- See Also:
- Constant Field Values
logger
public static org.objectweb.util.monolog.api.Logger logger
user
private java.lang.String user
pass
private java.lang.String pass
path
private java.lang.String path
transfer
private transient TransferItf transfer
dmq
private AgentId dmq
clientContext
private int clientContext
requestId
private int requestId
ftpImplName
public java.lang.String ftpImplName
transferTable
private java.util.Hashtable transferTable
FtpQueueImpl
public FtpQueueImpl(AgentId adminId,
java.util.Properties prop)
- Constructs a
FtpQueueImpl
instance.
- Parameters:
adminId
- Identifier of the administrator of the queue.prop
- The initial set of properties.
setProperties
protected void setProperties(java.util.Properties prop)
initialize
public void initialize(boolean firstTime)
- Initializes the destination.
- Overrides:
initialize
in class QueueImpl
- Parameters:
firstTime
- true when first called by the factory
toString
public java.lang.String toString()
- Description copied from class:
QueueImpl
- Returns a string representation of this destination.
- Specified by:
toString
in interface DestinationImplMBean
- Overrides:
toString
in class QueueImpl
ftpNot
public void ftpNot(FtpNot not)
preProcess
public ClientMessages preProcess(AgentId from,
ClientMessages not)
- Description copied from class:
DestinationImpl
- This method is needed to add processing before the standard handling. It
is used in subclass of
QueueImpl
and TopicImpl
.
The incoming messages can be modified or deleted during the processing.
- Overrides:
preProcess
in class DestinationImpl
- Parameters:
from
- The sender of the messagenot
- The incoming messages.
- Returns:
- The incoming messages after processing.
isFtpMsg
protected boolean isFtpMsg(Message message)
doProcessFtp
protected void doProcessFtp(ClientMessages not,
Message msg)
Copyright © 2010 ScalAgent D.T.. All Rights Reserved.