public class FtpQueue extends Queue
FtpQueue
class implements the MOM queue behaviour,
basically storing messages and delivering them upon clients requests.Queue.QueueFactory
Modifier and Type | Field and Description |
---|---|
private int |
clientContext |
private AgentId |
dmq |
String |
ftpImplName |
static org.objectweb.util.monolog.api.Logger |
logger |
private String |
pass |
private String |
path |
private int |
requestId |
private static long |
serialVersionUID
define serialVersionUID for interoperability
|
private TransferItf |
transfer |
private Hashtable |
transferTable |
private String |
user |
arrivalsCounter, consumers, contexts, deliveredMsgs, deliveryScheduler, messages, nbMaxMsg, receiving, requests
_rights, clients, creationDate, dmqId, freeReading, freeWriting, nbMsgsDeliverSinceCreation, nbMsgsReceiveSinceCreation, nbMsgsSentToDMQSinceCreation, READ, READWRITE, task, WAKEUP_PERIOD, WRITE
agentProfiling, emptyString, fixed, logmon
BOOLEAN_ENCODED_SIZE, BYTE_ENCODED_SIZE, DOUBLE_ENCODED_SIZE, FLOAT_ENCODED_SIZE, INT_ENCODED_SIZE, LONG_ENCODED_SIZE, SHORT_ENCODED_SIZE
Constructor and Description |
---|
FtpQueue() |
Modifier and Type | Method and Description |
---|---|
private void |
doProcessFtp(ClientMessages not,
Message msg) |
private void |
ftpNot(FtpNot not) |
int |
getEncodableClassId()
Enables the sub classes not to implement this method.
|
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(Properties prop,
boolean firstTime)
Configures a
FtpQueue instance. |
String |
toString()
Returns a string representation of this destination.
|
abortReceiveRequest, acknowledgeRequest, addClientMessages, addMessage, browseRequest, checkDelivery, cleanPendingMessage, cleanPendingMessage, cleanWaitingRequest, cleanWaitingRequest, decode, deliverMessages, denyRequest, doClientMessages, doDeleteNot, doRightRequest, doUnknownAgent, encode, finalize, getClientMessages, getConsumerLoad, getDefaultDMQId, getDefaultThreshold, getDeliveredMessageCount, getEncodedSize, getMessage, getMessages, getMessagesView, getMsgTxPrefix, getNbMaxMsg, getNbMsgsReceiveSinceCreation, getPendingMessageCount, getProducerLoad, getQueueMessage, getStats, getThreshold, getTxName, getType, getWaitingRequestCount, handleAdminRequestNot, handleExpiredNot, isSyncExceptionOnFullDest, isUndeliverable, isValidJMXAttribute, messageDelivered, messageRemoved, receiveRequest, removeMessages, setMsgTxName, setNbMaxMsg, setSyncExceptionOnFullDest, setThreshold, storeMessage, storeMessageHeader, wakeUpNot
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
delete, delete, deploy, deploy, getAgentId, getCommitTime, getId, getLogTopic, getName, getReactNb, getReactTime, hasName, isAgentProfiling, isDeployed, isFixed, isUpdated, needToBeCommited, resetCommitTime, resetReactTime, resetTimer, save, sendTo, sendTo, sendTo, setAgentProfiling, setName, setNoSave, setSave
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
delete, getCreationDate, getCreationTimeInMillis, getDestinationId, getDMQId, getName, getNbMsgsDeliverSinceCreation, getNbMsgsSentToDMQSinceCreation, getPeriod, getRight, getRights, isFreeReading, isFreeWriting, setFreeReading, setFreeWriting, setPeriod
getAgentId, getCommitTime, getReactNb, getReactTime, isAgentProfiling, isFixed, resetCommitTime, resetReactTime, resetTimer, setAgentProfiling
private static final long serialVersionUID
public static org.objectweb.util.monolog.api.Logger logger
private String user
private String pass
private String path
private transient TransferItf transfer
private AgentId dmq
private int clientContext
private int requestId
public String ftpImplName
private Hashtable transferTable
public void setProperties(Properties prop, boolean firstTime) throws Exception
FtpQueue
instance.setProperties
in class Destination
prop
- The initial set of properties.Exception
public void initialize(boolean firstTime)
initialize
in class Queue
firstTime
- true when first called by the factorypublic void react(AgentId from, Notification not) throws Exception
Queue
public String toString()
Queue
toString
in interface AgentMBean
toString
in interface DestinationMBean
toString
in class Queue
private void ftpNot(FtpNot not)
public ClientMessages preProcess(AgentId from, ClientMessages not)
Destination
Queue
and Topic
.
The incoming messages can be modified or deleted during the processing.preProcess
in class Destination
from
- The sender of the messagenot
- The incoming messages.protected boolean isFtpMsg(Message message)
private void doProcessFtp(ClientMessages not, Message msg)
public int getEncodableClassId()
Agent
getEncodableClassId
in interface Encodable
getEncodableClassId
in class Queue
Copyright © 2013 ScalAgent D.T.. All Rights Reserved.