mirror of
https://github.com/Alfresco/alfresco-community-repo.git
synced 2025-08-07 17:49:17 +00:00
A tweak to the word "manifest" on the transfer service event model. Altered to "snapshot", since I can foresee a time when a proper manifest will also be needed.
git-svn-id: https://svn.alfresco.com/repos/alfresco-enterprise/alfresco/HEAD/root@19701 c4b6b30b-aa2e-2d43-bbcb-ca4b014f7261
This commit is contained in:
@@ -31,7 +31,7 @@ import org.alfresco.service.cmr.transfer.TransferEventEndState;
|
|||||||
import org.alfresco.service.cmr.transfer.TransferEventEnterState;
|
import org.alfresco.service.cmr.transfer.TransferEventEnterState;
|
||||||
import org.alfresco.service.cmr.transfer.TransferEventError;
|
import org.alfresco.service.cmr.transfer.TransferEventError;
|
||||||
import org.alfresco.service.cmr.transfer.TransferEventSendingContent;
|
import org.alfresco.service.cmr.transfer.TransferEventSendingContent;
|
||||||
import org.alfresco.service.cmr.transfer.TransferEventSendingManifest;
|
import org.alfresco.service.cmr.transfer.TransferEventSendingSnapshot;
|
||||||
import org.alfresco.service.cmr.transfer.TransferEventSuccess;
|
import org.alfresco.service.cmr.transfer.TransferEventSuccess;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@@ -145,15 +145,15 @@ public class TransferEventProcessor
|
|||||||
* @param range
|
* @param range
|
||||||
* @param position
|
* @param position
|
||||||
*/
|
*/
|
||||||
public void sendManifest(long range, long position)
|
public void sendSnapshot(long range, long position)
|
||||||
{
|
{
|
||||||
setState(TransferEvent.TransferState.SENDING_MANIFEST);
|
setState(TransferEvent.TransferState.SENDING_SNAPSHOT);
|
||||||
|
|
||||||
TransferEventSendingManifest event = new TransferEventSendingManifest();
|
TransferEventSendingSnapshot event = new TransferEventSendingSnapshot();
|
||||||
event.setTransferState(TransferEvent.TransferState.SENDING_MANIFEST);
|
event.setTransferState(TransferEvent.TransferState.SENDING_SNAPSHOT);
|
||||||
event.setRange(range);
|
event.setRange(range);
|
||||||
event.setPosition(position);
|
event.setPosition(position);
|
||||||
event.setMessage("sending manifest");
|
event.setMessage("sending snapshot");
|
||||||
queue.add(event);
|
queue.add(event);
|
||||||
notifyObservers();
|
notifyObservers();
|
||||||
}
|
}
|
||||||
|
@@ -606,7 +606,7 @@ public class TransferServiceImpl implements TransferService
|
|||||||
/**
|
/**
|
||||||
* send Manifest
|
* send Manifest
|
||||||
*/
|
*/
|
||||||
eventProcessor.sendManifest(1,1);
|
eventProcessor.sendSnapshot(1,1);
|
||||||
transmitter.sendManifest(transfer, snapshotFile);
|
transmitter.sendManifest(transfer, snapshotFile);
|
||||||
|
|
||||||
logger.debug("manifest sent");
|
logger.debug("manifest sent");
|
||||||
|
@@ -35,7 +35,7 @@ public interface TransferEvent
|
|||||||
/**
|
/**
|
||||||
* The transfer events will Start with a START event and finish with either SUCCESS or ERROR
|
* The transfer events will Start with a START event and finish with either SUCCESS or ERROR
|
||||||
*/
|
*/
|
||||||
enum TransferState { START, SENDING_MANIFEST, SENDING_CONTENT, PREPARING, COMMITTING, SUCCESS, ERROR };
|
enum TransferState { START, SENDING_SNAPSHOT, SENDING_CONTENT, PREPARING, COMMITTING, SUCCESS, ERROR };
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Get the state of this transfer
|
* Get the state of this transfer
|
||||||
|
@@ -21,14 +21,14 @@ package org.alfresco.service.cmr.transfer;
|
|||||||
import org.alfresco.repo.transfer.TransferEventImpl;
|
import org.alfresco.repo.transfer.TransferEventImpl;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Event for sending the transfer manifest.
|
* Event for sending the properties snapshot.
|
||||||
*
|
*
|
||||||
*/
|
*/
|
||||||
public class TransferEventSendingManifest extends TransferEventImpl implements RangedTransferEvent
|
public class TransferEventSendingSnapshot extends TransferEventImpl implements RangedTransferEvent
|
||||||
{
|
{
|
||||||
public String toString()
|
public String toString()
|
||||||
{
|
{
|
||||||
return "TransferEventSendingManifest: " + super.getPosition() + " of " + super.getRange();
|
return "TransferEventSendingSnapshot: " + super.getPosition() + " of " + super.getRange();
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
Reference in New Issue
Block a user