|
|||||||||
| 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 DeploymentReceiverTransportpublic void run()
run in interface java.lang.RunnableRunnable.run()
public void setApplicationContext(org.springframework.context.ApplicationContext applicationContext)
throws org.springframework.beans.BeansException
setApplicationContext in interface org.springframework.context.ApplicationContextAwareorg.springframework.beans.BeansExceptionpublic java.util.List getTransformers()
public void setTransformers(java.util.List transformers)
public void registerTarget(java.lang.String name,
DeploymentTarget target)
registerTarget in interface DeploymentTargetRegistryname - the name of the targettarget - the implementation of the targetpublic void unregisterTarget(java.lang.String name)
unregisterTarget in interface DeploymentTargetRegistryname - 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 DeploymentReceiverServicetargetName - 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 DeploymentReceiverServicepublic void prepare(java.lang.String ticket)
DeploymentReceiverService
prepare in interface DeploymentReceiverServiceticket - The transaction ticket.public void commit(java.lang.String ticket)
DeploymentReceiverService
commit in interface DeploymentReceiverServiceticket - 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 DeploymentReceiverServiceguid - 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 DeploymentReceiverServicecreate - - 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 DeploymentReceiverTransportpublic 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 | ||||||||