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

java.lang.Object
  extended by org.objectweb.joram.mom.dest.DestinationImpl
      extended by org.objectweb.joram.mom.dest.QueueImpl
          extended by 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

Field Summary
private  int clientContext
           
private  AgentId dmq
           
 java.lang.String ftpImplName
           
static org.objectweb.util.monolog.api.Logger logger
           
private  java.lang.String pass
           
private  java.lang.String path
           
private  int requestId
           
private static long serialVersionUID
          define serialVersionUID for interoperability
private  TransferItf transfer
           
private  java.util.Hashtable transferTable
           
private  java.lang.String user
           
 
Fields inherited from class org.objectweb.joram.mom.dest.QueueImpl
arrivalsCounter, consumers, contexts, deliveredMsgs, messages, nbMaxMsg, receiving, requests
 
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.
 
Method Summary
protected  void doProcessFtp(ClientMessages not, Message msg)
           
 void ftpNot(FtpNot not)
           
 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.
protected  void setProperties(java.util.Properties prop)
           
 java.lang.String toString()
          Returns a string representation of this destination.
 
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
 

Field Detail

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
Constructor Detail

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.
Method Detail

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 message
not - 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.