org.alfresco.repo.transfer.fsr

Class FileTransferReceiver

java.lang.Object

org.alfresco.repo.transfer.fsr.FileTransferReceiver

All Implemented Interfaces:

org.alfresco.service.cmr.transfer.TransferReceiver

public class FileTransferReceiver
extends Object
implements org.alfresco.service.cmr.transfer.TransferReceiver

Constructor Summary

Constructors

Constructor and Description
FileTransferReceiver()

Method Summary

Methods

Modifier and Type	Method and Description
void	cancel(String transferId)
org.alfresco.repo.transfer.fsr.FileTransferReceiver.Lock	checkLock(String transferId)
void	commit(String transferId)
void	commitAsync(String transferId)
void	end(String transferId)
void	generateRequsite(String transferId, OutputStream requsiteStream)
Map<String,File>	getContents()
DbHelper	getDbHelper()
String	getDefaultReceivingroot()
org.alfresco.repo.lock.JobLockService	getJobLockService()
long	getLockRefreshTime()
int	getLockRetryCount()
long	getLockRetryWait()
long	getLockTimeOut()
org.alfresco.repo.transfer.ManifestProcessorFactory	getManifestProcessorFactory()
org.alfresco.repo.transfer.TransferProgressMonitor	getProgressMonitor()
String	getRootStagingDirectory()
protected File	getSnapshotFile(String transferId)
File	getStagingFolder(String transferId)
org.alfresco.service.cmr.transfer.TransferProgress	getStatus(String transferId)
org.alfresco.service.cmr.repository.NodeRef	getTempFolder(String transferId)
InputStream	getTransferReport(String transferId)
String	getTransferRootNode()
org.alfresco.service.cmr.transfer.TransferVersion	getVersion()
boolean	isContentNewOrModified(String nodeRef, String contentUrl)
void	prepare(String transferId)
void	saveContent(String transferId, String contentFileId, InputStream contentStream)
void	saveSnapshot(String transferId, InputStream openStream)
void	setDefaultReceivingroot(String defaultReceivingroot)
void	setDescriptorDAO(org.alfresco.repo.descriptor.DescriptorDAO descriptorDAO)
void	setFileTransferInfoDAO(FileTransferInfoDAO fileTransferInfoDAO)
void	setJobLockService(org.alfresco.repo.lock.JobLockService jobLockService)
void	setLockRefreshTime(long lockRefreshTime)
void	setLockRetryCount(int lockRetryCount)
void	setLockRetryWait(long lockRetryWait)
void	setLockTimeOut(long lockTimeOut)
void	setManifestProcessorFactory(org.alfresco.repo.transfer.ManifestProcessorFactory manifestProcessorFactory)
void	setProgressMonitor(org.alfresco.repo.transfer.TransferProgressMonitor progressMonitor)
void	setRootStagingDirectory(String rootStagingDirectory)
void	setTransactionService(org.alfresco.service.transaction.TransactionService transactionService)
void	setTransferRootNode(String rootFileSystem)
String	start(String fromRepositoryId, boolean transferToSelf, org.alfresco.service.cmr.transfer.TransferVersion fromVersion)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

FileTransferReceiver

public FileTransferReceiver()

Method Detail

cancel

public void cancel(String transferId)
            throws org.alfresco.service.cmr.transfer.TransferException

Specified by:

cancel in interface org.alfresco.service.cmr.transfer.TransferReceiver

Throws:

org.alfresco.service.cmr.transfer.TransferException

commit

public void commit(String transferId)
            throws org.alfresco.service.cmr.transfer.TransferException

Specified by:

commit in interface org.alfresco.service.cmr.transfer.TransferReceiver

Throws:

org.alfresco.service.cmr.transfer.TransferException

commitAsync

public void commitAsync(String transferId)
                 throws org.alfresco.service.cmr.transfer.TransferException

Specified by:

commitAsync in interface org.alfresco.service.cmr.transfer.TransferReceiver

Throws:

org.alfresco.service.cmr.transfer.TransferException

end

public void end(String transferId)

Specified by:

end in interface org.alfresco.service.cmr.transfer.TransferReceiver

generateRequsite

public void generateRequsite(String transferId,
                    OutputStream requsiteStream)
                      throws org.alfresco.service.cmr.transfer.TransferException

Specified by:

generateRequsite in interface org.alfresco.service.cmr.transfer.TransferReceiver

Throws:

org.alfresco.service.cmr.transfer.TransferException

getProgressMonitor

public org.alfresco.repo.transfer.TransferProgressMonitor getProgressMonitor()

Specified by:

getProgressMonitor in interface org.alfresco.service.cmr.transfer.TransferReceiver

getStagingFolder

public File getStagingFolder(String transferId)

Specified by:

getStagingFolder in interface org.alfresco.service.cmr.transfer.TransferReceiver

getStatus

public org.alfresco.service.cmr.transfer.TransferProgress getStatus(String transferId)
                                                             throws org.alfresco.service.cmr.transfer.TransferException

Specified by:

getStatus in interface org.alfresco.service.cmr.transfer.TransferReceiver

Throws:

org.alfresco.service.cmr.transfer.TransferException

getTempFolder

public org.alfresco.service.cmr.repository.NodeRef getTempFolder(String transferId)

Specified by:

getTempFolder in interface org.alfresco.service.cmr.transfer.TransferReceiver

getTransferReport

public InputStream getTransferReport(String transferId)

Specified by:

getTransferReport in interface org.alfresco.service.cmr.transfer.TransferReceiver

getVersion

public org.alfresco.service.cmr.transfer.TransferVersion getVersion()

Specified by:

getVersion in interface org.alfresco.service.cmr.transfer.TransferReceiver

prepare

public void prepare(String transferId)
             throws org.alfresco.service.cmr.transfer.TransferException

Specified by:

prepare in interface org.alfresco.service.cmr.transfer.TransferReceiver

Throws:

org.alfresco.service.cmr.transfer.TransferException

saveContent

public void saveContent(String transferId,
               String contentFileId,
               InputStream contentStream)
                 throws org.alfresco.service.cmr.transfer.TransferException

Specified by:

saveContent in interface org.alfresco.service.cmr.transfer.TransferReceiver

Throws:

org.alfresco.service.cmr.transfer.TransferException

checkLock

public org.alfresco.repo.transfer.fsr.FileTransferReceiver.Lock checkLock(String transferId)
                                                                   throws org.alfresco.service.cmr.transfer.TransferException

Throws:

org.alfresco.service.cmr.transfer.TransferException

saveSnapshot

public void saveSnapshot(String transferId,
                InputStream openStream)
                  throws org.alfresco.service.cmr.transfer.TransferException

Specified by:

saveSnapshot in interface org.alfresco.service.cmr.transfer.TransferReceiver

Throws:

org.alfresco.service.cmr.transfer.TransferException

start

public String start(String fromRepositoryId,
           boolean transferToSelf,
           org.alfresco.service.cmr.transfer.TransferVersion fromVersion)

Specified by:

start in interface org.alfresco.service.cmr.transfer.TransferReceiver

setJobLockService

public void setJobLockService(org.alfresco.repo.lock.JobLockService jobLockService)

getJobLockService

public org.alfresco.repo.lock.JobLockService getJobLockService()

setLockRefreshTime

public void setLockRefreshTime(long lockRefreshTime)

getLockRefreshTime

public long getLockRefreshTime()

isContentNewOrModified

public boolean isContentNewOrModified(String nodeRef,
                             String contentUrl)

getSnapshotFile

protected File getSnapshotFile(String transferId)

getLockRetryWait

public long getLockRetryWait()

setLockRetryWait

public void setLockRetryWait(long lockRetryWait)

getLockRetryCount

public int getLockRetryCount()

setLockRetryCount

public void setLockRetryCount(int lockRetryCount)

getLockTimeOut

public long getLockTimeOut()

setLockTimeOut

public void setLockTimeOut(long lockTimeOut)

setTransactionService

public void setTransactionService(org.alfresco.service.transaction.TransactionService transactionService)

getRootStagingDirectory

public String getRootStagingDirectory()

setRootStagingDirectory

public void setRootStagingDirectory(String rootStagingDirectory)

getManifestProcessorFactory

public org.alfresco.repo.transfer.ManifestProcessorFactory getManifestProcessorFactory()

setManifestProcessorFactory

public void setManifestProcessorFactory(org.alfresco.repo.transfer.ManifestProcessorFactory manifestProcessorFactory)

setProgressMonitor

public void setProgressMonitor(org.alfresco.repo.transfer.TransferProgressMonitor progressMonitor)

getDefaultReceivingroot

public String getDefaultReceivingroot()

setDefaultReceivingroot

public void setDefaultReceivingroot(String defaultReceivingroot)

getContents

public Map<String,File> getContents()

setTransferRootNode

public void setTransferRootNode(String rootFileSystem)

Specified by:

setTransferRootNode in interface org.alfresco.service.cmr.transfer.TransferReceiver

getTransferRootNode

public String getTransferRootNode()

setFileTransferInfoDAO

public void setFileTransferInfoDAO(FileTransferInfoDAO fileTransferInfoDAO)

setDescriptorDAO

public void setDescriptorDAO(org.alfresco.repo.descriptor.DescriptorDAO descriptorDAO)

getDbHelper

public DbHelper getDbHelper()