Package org.alfresco.repo.transfer

Class RepoTransferReceiverImpl

    • Constructor Detail

      • RepoTransferReceiverImpl

        public RepoTransferReceiverImpl()

    • Method Detail

      • init

        public void init()

      • start

        public String start​(String fromRepositoryId,
                    boolean transferToSelf,
                    TransferVersion fromVersion)
        Description copied from interface: TransferReceiver
        Asks the receiver to setup a new transfer.
        Specified by:
        start in interface TransferReceiver
        Parameters:
        fromRepositoryId - the repositoryId of the sending system
        transferToSelf - are transfers to the same repository allowed?
        fromVersion - the version sending
        Returns:
        The identifier of the new transfer

      • end

        public void end​(String transferId)
        Description copied from interface: TransferReceiver
        Asks the receiver to end (and clean up) the specified transfer
        Specified by:
        end in interface TransferReceiver
        Parameters:
        transferId - The transfer to end

      • saveSnapshot

        public void saveSnapshot​(String transferId,
                         InputStream openStream)
                  throws TransferException
        Description copied from interface: TransferReceiver
        Store the specified snapshot file into the transfer staging area. The specified transfer must currently be the holder of the transfer lock, otherwise an exception is thrown. This operation does not close the supplied stream, so the caller must do it as appropriate. The caller should assume that the supplied stream has been fully read when this operation returns.
        Specified by:
        saveSnapshot in interface TransferReceiver
        Parameters:
        transferId - The identifier of the transfer with which this snapshot is associated
        openStream - The open stream that holds the snapshot file.
        Throws:
        TransferException - If an error occurs while saving the snapshot file.

      • setSearchService

        public void setSearchService​(SearchService searchService)
        Parameters:
        searchService - the searchService to set

      • setTransactionService

        public void setTransactionService​(TransactionService transactionService)
        Parameters:
        transactionService - the transactionService to set

      • setTenantService

        public void setTenantService​(TenantService tenantService)

      • setTransferLockFolderPath

        public void setTransferLockFolderPath​(String transferLockFolderPath)
        Parameters:
        transferLockFolderPath - the transferLockFolderPath to set

      • setTransferTempFolderPath

        public void setTransferTempFolderPath​(String transferTempFolderPath)
        Parameters:
        transferTempFolderPath - the transferTempFolderPath to set

      • setRootStagingDirectory

        public void setRootStagingDirectory​(String rootStagingDirectory)
        Parameters:
        rootStagingDirectory - the rootTransferFolder to set

      • setInboundTransferRecordsPath

        public void setInboundTransferRecordsPath​(String inboundTransferRecordsPath)
        Parameters:
        inboundTransferRecordsPath - the inboundTransferRecordsPath to set

      • setNodeService

        public void setNodeService​(NodeService nodeService)
        Parameters:
        nodeService - the nodeService to set

      • setManifestProcessorFactory

        public void setManifestProcessorFactory​(ManifestProcessorFactory manifestProcessorFactory)
        Parameters:
        manifestProcessorFactory - the manifestProcessorFactory to set

      • setBehaviourFilter

        public void setBehaviourFilter​(BehaviourFilter behaviourFilter)
        Parameters:
        behaviourFilter - the behaviourFilter to set

      • setProgressMonitor

        public void setProgressMonitor​(TransferProgressMonitor progressMonitor)
        Parameters:
        progressMonitor - the progressMonitor to set

      • setActionService

        public void setActionService​(ActionService actionService)

      • setRuleService

        public void setRuleService​(RuleService ruleService)
        Set the ruleService
        Parameters:
        ruleService - the ruleService to set

      • getRuleService

        public RuleService getRuleService()
        Get the rule service
        Returns:
        the rule service

      • setNamespaceService

        public void setNamespaceService​(NamespaceService namespaceService)

      • setPolicyComponent

        public void setPolicyComponent​(PolicyComponent policyComponent)

      • onCreateChildAssociation

        public void onCreateChildAssociation​(ChildAssociationRef childAssocRef,
                                     boolean isNewNode)
        When a new node is created as a child of a Transferred or Alien node then the new node needs to be marked as an alien.

        Then the tree needs to be walked upwards to mark all parent transferred nodes as alien.

        Specified by:
        onCreateChildAssociation in interface NodeServicePolicies.OnCreateChildAssociationPolicy
        Parameters:
        childAssocRef - the child association that has been created
        isNewNode - true if the node is new or false if the node is being linked in

      • beforeDeleteNode

        public void beforeDeleteNode​(NodeRef deletedNodeRef)
        When an alien node is deleted the it may be the last alien invader

        Walk the tree checking the invasion status!

        Specified by:
        beforeDeleteNode in interface NodeServicePolicies.BeforeDeleteNodePolicy
        Parameters:
        deletedNodeRef - the node reference

      • onRestoreNode

        public void onRestoreNode​(ChildAssociationRef childAssocRef)
        When a transferred node is restored it may be a new invader or it may no longer be an invader.

        Walk the tree checking the invasion status!

        Specified by:
        onRestoreNode in interface NodeServicePolicies.OnRestoreNodePolicy
        Parameters:
        childAssocRef - the newly created child association reference

      • onMoveNode

        public void onMoveNode​(ChildAssociationRef oldChildAssocRef,
                       ChildAssociationRef newChildAssocRef)
        When an alien node is moved it may un-invade its old location and invade a new location. The node may also cease to be alien.
        Specified by:
        onMoveNode in interface NodeServicePolicies.OnMoveNodePolicy
        Parameters:
        oldChildAssocRef - the child association reference prior to the move
        newChildAssocRef - the child association reference after the move

      • setDescriptorService

        public void setDescriptorService​(DescriptorService descriptorService)

      • setAlienProcessor

        public void setAlienProcessor​(AlienProcessor alienProcessor)

      • setJobLockService

        public void setJobLockService​(JobLockService jobLockService)

      • setLockRetryCount

        public void setLockRetryCount​(int lockRetryCount)

      • getLockRetryCount

        public int getLockRetryCount()

      • setLockRetryWait

        public void setLockRetryWait​(long lockRetryWait)

      • getLockRetryWait

        public long getLockRetryWait()

      • setLockTimeOut

        public void setLockTimeOut​(long lockTimeOut)

      • getLockTimeOut

        public long getLockTimeOut()

      • setLockRefreshTime

        public void setLockRefreshTime​(long lockRefreshTime)

      • getLockRefreshTime

        public long getLockRefreshTime()

      • setTransferVersionChecker

        public void setTransferVersionChecker​(TransferVersionChecker transferVersionChecker)