|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.alfresco.deployment.impl.server.DeploymentReceiverEngineImpl
public class DeploymentReceiverEngineImpl
This is the implementation of the Alfresco Deployment Receiver Engine The Deployment Receiver Engine manages the communications with a host instance of alfresco and then delegates the deployment to one of the deployment targets. It also manages some server based functionality to do with start up / shut down and housekeeping.
Constructor Summary | |
---|---|
DeploymentReceiverEngineImpl()
|
Method Summary | |
---|---|
void |
abort(java.lang.String ticket)
Signals that the deployment should be aborted and rolled back. |
DeploymentToken |
begin(java.lang.String targetName,
java.lang.String storeName,
int version,
java.lang.String user,
char[] password)
Start a deployment. |
void |
commit(java.lang.String ticket)
Signals that the deployment should commit. |
void |
createDirectory(java.lang.String ticket,
java.lang.String path,
java.lang.String guid,
java.util.Set aspects,
java.util.Map props)
Create a new directory. |
void |
delete(java.lang.String ticket,
java.lang.String path)
Delete a file or directory. |
void |
finishSend(java.lang.String ticket,
java.lang.String outputToken)
Tell the deployment receiver that a send is finished. |
DeploymentReceiverAuthenticator |
getAuthenticator()
|
DeploymentCommandQueue |
getCommandQueue()
|
java.util.Set |
getHousekeepers()
|
java.util.List |
getListing(java.lang.String ticket,
java.lang.String path)
Get a listing of a directory. |
long |
getPollDelay()
|
ReaderManagement |
getReaderManagement()
|
java.lang.String |
getSendToken(java.lang.String ticket,
boolean create,
java.lang.String path,
java.lang.String guid,
java.lang.String encoding,
java.lang.String mimeType,
java.util.Set aspects,
java.util.Map props)
Get an OutputStream token. |
java.util.Map |
getTargets()
Get the targets for this deployment engine. |
java.util.List |
getTransformers()
Get the content transformers for this transport - if the transport does not support content transformation then simply return null; |
void |
init()
|
boolean |
isDaemonThread()
|
void |
prepare(java.lang.String ticket)
Signals that the deployment should prepare |
void |
registerTarget(java.lang.String name,
DeploymentTarget target)
Register a new deployment target. |
void |
run()
This is the keep-alive thread of the FSR. |
java.io.OutputStream |
send(java.lang.String token,
boolean create,
java.lang.String path,
java.lang.String guid,
java.lang.String encoding,
java.lang.String mimeType,
java.util.Set aspects,
java.util.Map props)
Send a file to a path. |
void |
setApplicationContext(org.springframework.context.ApplicationContext applicationContext)
|
void |
setAuthenticator(DeploymentReceiverAuthenticator authenticator)
|
void |
setCommandQueue(DeploymentCommandQueue commandQueue)
|
void |
setDaemonThread(boolean isDemonThread)
|
void |
setHousekeepers(java.util.Set housekeepers)
|
void |
setPollDelay(long pollDelay)
|
void |
setReaderManagement(ReaderManagement readerManagement)
|
void |
setTransformers(java.util.List transformers)
|
void |
shutDown()
|
void |
shutDown(java.lang.String user,
char[] password)
Shut down the Deployment Receiver. |
void |
unregisterTarget(java.lang.String name)
Unregister a deployment target |
void |
updateDirectory(java.lang.String ticket,
java.lang.String path,
java.lang.String guid,
java.util.Set aspects,
java.util.Map properties)
Set the Guid (Version) on a directory. |
void |
write(java.lang.String ticket,
java.lang.String outputToken,
byte[] data,
int offset,
int count)
Write a block of bytes to a file that is being sent. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public DeploymentReceiverEngineImpl()
Method Detail |
---|
public void init()
public void shutDown()
public void shutDown(java.lang.String user, char[] password)
DeploymentReceiverTransport
shutDown
in interface DeploymentReceiverTransport
public void run()
run
in interface java.lang.Runnable
Runnable.run()
public void setApplicationContext(org.springframework.context.ApplicationContext applicationContext) throws org.springframework.beans.BeansException
setApplicationContext
in interface org.springframework.context.ApplicationContextAware
org.springframework.beans.BeansException
public java.util.List getTransformers()
public void setTransformers(java.util.List transformers)
public void registerTarget(java.lang.String name, DeploymentTarget target)
registerTarget
in interface DeploymentTargetRegistry
name
- the name of the targettarget
- the implementation of the targetpublic void unregisterTarget(java.lang.String name)
unregisterTarget
in interface DeploymentTargetRegistry
name
- the name of the targetpublic java.util.Map getTargets()
getTargets
in interface DeploymentTargetRegistry
public DeploymentToken begin(java.lang.String targetName, java.lang.String storeName, int version, java.lang.String user, char[] password)
DeploymentReceiverService
begin
in interface DeploymentReceiverService
targetName
- The target to deploy to. A target is simply a key
to a receiver side deployment configuration.storeName
- - the name of the store being deployed.version
- - the version being deployed.user
- The user name for authentication.password
- The password for the user.
public void abort(java.lang.String ticket)
DeploymentReceiverService
abort
in interface DeploymentReceiverService
public void prepare(java.lang.String ticket)
DeploymentReceiverService
prepare
in interface DeploymentReceiverService
ticket
- The transaction ticket.public void commit(java.lang.String ticket)
DeploymentReceiverService
commit
in interface DeploymentReceiverService
ticket
- The transaction ticket.public void delete(java.lang.String ticket, java.lang.String path)
DeploymentReceiverService
delete
in interface DeploymentReceiverService
public java.util.List getListing(java.lang.String ticket, java.lang.String path)
DeploymentReceiverService
getListing
in interface DeploymentReceiverService
public void createDirectory(java.lang.String ticket, java.lang.String path, java.lang.String guid, java.util.Set aspects, java.util.Map props)
DeploymentReceiverService
createDirectory
in interface DeploymentReceiverService
guid
- The GUID (Version) of the directory to be created.public void updateDirectory(java.lang.String ticket, java.lang.String path, java.lang.String guid, java.util.Set aspects, java.util.Map properties)
DeploymentReceiverService
updateDirectory
in interface DeploymentReceiverService
public java.io.OutputStream send(java.lang.String token, boolean create, java.lang.String path, java.lang.String guid, java.lang.String encoding, java.lang.String mimeType, java.util.Set aspects, java.util.Map props)
DeploymentReceiverService
send
in interface DeploymentReceiverService
create
- - true new fileaspects
- - full qualified names of the aspects that this file is associated with.
public java.lang.String getSendToken(java.lang.String ticket, boolean create, java.lang.String path, java.lang.String guid, java.lang.String encoding, java.lang.String mimeType, java.util.Set aspects, java.util.Map props)
DeploymentReceiverTransport
getSendToken
in interface DeploymentReceiverTransport
public void write(java.lang.String ticket, java.lang.String outputToken, byte[] data, int offset, int count)
DeploymentReceiverTransport
write
in interface DeploymentReceiverTransport
public void finishSend(java.lang.String ticket, java.lang.String outputToken)
DeploymentReceiverTransport
finishSend
in interface DeploymentReceiverTransport
public void setAuthenticator(DeploymentReceiverAuthenticator authenticator)
public DeploymentReceiverAuthenticator getAuthenticator()
public void setHousekeepers(java.util.Set housekeepers)
public java.util.Set getHousekeepers()
public void setPollDelay(long pollDelay)
public long getPollDelay()
public void setCommandQueue(DeploymentCommandQueue commandQueue)
public DeploymentCommandQueue getCommandQueue()
public void setReaderManagement(ReaderManagement readerManagement)
public ReaderManagement getReaderManagement()
public void setDaemonThread(boolean isDemonThread)
public boolean isDaemonThread()
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |