wt.replication.receiver
Class StandardReplicationRecvService

java.lang.Object
  wt.services.StandardManager
      wt.replication.receiver.StandardReplicationRecvService

All Implemented Interfaces:

Manager, NetFactor, ReplicationRecvService, ReplicationRecvServiceSrv, Serializable

public class StandardReplicationRecvService

extends StandardManager

implements ReplicationRecvService, ReplicationRecvServiceSrv, Serializable

Use the newStandardReplicationRecvService static factory method(s), not the StandardReplicationRecvService constructor, to construct instances of this class. Instances must be constructed using the static factory(s), in order to ensure proper initialization of the instance.

Supported API: false

Extendable: false

See Also:

Serialized Form

Nested Class Summary

private static class	StandardReplicationRecvService.BooledAppData Deprecated.
private class	StandardReplicationRecvService.WTUnitReceiverEventListener Deprecated.

Field Summary

private static boolean	AUTO_PULL Deprecated.
private static String	CLASSNAME Deprecated.
private static boolean	createNewNumber Deprecated.
private static String	embLogDir Deprecated.
private static boolean	PERFORMANCE Deprecated.
private static boolean	REPL_READ_ONLY Deprecated.
private static String	RESOURCE Deprecated.
private static boolean	SCHEDULE_ITEM_ENABLED Deprecated.
private static boolean	SHOW_LOCAL_SITE Deprecated.
private static String	SUBSCRIBER_ROLE Deprecated.
private static boolean	TEAMTEMPLATE_FILTER_ENABLED Deprecated.
private static Hashtable	teamTemplatePathCache Deprecated.
private static wt.replication.test.TestTime	tt Deprecated.
private static String	UNIT_RECEIVE_LIFECYCLE_STATE Deprecated.
private static String	UNIT_RECEIVE_LIFECYCLE_TEMPLATE Deprecated.
private static boolean	VERBOSE Deprecated.

Fields inherited from class wt.services.StandardManager

Fields inherited from interface wt.services.Manager

MANAGER_SERVICE, STARTUP_AUTOMATIC, STARTUP_MANUAL, STATUS_EMERGENCY_SHUTDOWN, STATUS_EMERGENCY_SHUTTING_DOWN, STATUS_SHUTDOWN, STATUS_SHUTDOWN_ERRORS, STATUS_SHUTDOWN_FAILURE, STATUS_SHUTTING_DOWN, STATUS_STARTED, STATUS_STARTED_ERRORS, STATUS_STARTING_UP, STATUS_STARTUP_FAILURE

Constructor Summary

StandardReplicationRecvService()
Deprecated.

Method Summary

private static boolean	checkPrincipalMatch(WTPrincipal candidate, WTPrincipal target) Deprecated.
private static Ufid	constructUfidFromString(String sUfid) Deprecated.
protected void	dispatchVetoableEvent(String eventType, WTUnit unit) Deprecated.
static void	embHandleReceivedIS(ObjectReference unitRef, String fileName, String description, String uploadedFromPath, Ufid ufid, InputStream contentIS) Deprecated.
private static void	embLogDirInitialize(WTProperties props) Deprecated.
void	embUploadUnit(String embFolder, String fullTeamTemplateName) Deprecated.
private static void	embWriteLogHeader(EMBReceiverLog embLog, WTUnit wtUnit, Site cameFrom, String embFolder) Deprecated.
static UnitReceiveRecord	enableScheduleItem(WTUnit unit) Deprecated. This method is called by the workflow processes to allow the currently active receive operation for the replication unit to proceed.
private static Enumeration	findEmbEntryInfo(WTUnit wtUnit, String embFolder, EMBReceiverLog embLog) Deprecated.
private static Enumeration	findManifestInfo(WTUnit wtUnit) Deprecated.
private static WTPrincipal	findPrincipal(String remoteUrl) Deprecated.
private static Vector	findQualifiedTeamTemplates(WTPrincipal principal, boolean toFilter) Deprecated.
private static Vector	findQualifiedTeamTemplatesByCreatorRole(WTPrincipal principal, boolean toFilter) Deprecated.
private static Vector	findQualifiedTeamTemplatesByRole(WTPrincipal principal, boolean toFilter, String roleStr) Deprecated. Finds Team Templates which qualifies according to the expected role.
private static String	findUnitFolder(String fullTeamTemplateName) Deprecated.
private static StandardReplicationRecvService.BooledAppData	getAppDataBy(WTUnit wtUnit, StreamIdentity sid) Deprecated.
String	getConceptualClassname() Deprecated.
private static WTReplicationException	handleDownloadException(WTUnit wtUnit, Throwable e, String key, Object[] errorInfo) Deprecated.
static void	handleReceivedIS(ObjectReference unitRef, String fileName, String description, String uploadedFromPath, Ufid ufid, InputStream contentIS) Deprecated.
static StandardReplicationRecvService	newStandardReplicationRecvService() Deprecated.
protected void	performStartupProcess() Deprecated.
void	registerEvents(ManagerService manager) Deprecated.
static ShippingItem	responseTeamTemplateRequest(String rmtUrl) Deprecated.
private static ActionShippingItem	returnHttpReceipt(ObjectReference sendRecRef, String localUrl, Throwable e) Deprecated.
private static ShippingItem	returnReceipt(ObjectReference ref, String localUrl, Throwable thr, boolean isEMBPipe) Deprecated.
private static ShippingItem	returnTeamTemplates(Vector teamTemplateList, Throwable e) Deprecated.
static void	scheduleReceiveOperation(WTUnit wtUnit, Timestamp startTime, String description, String transType, String embFolder, Locale locale) Deprecated.
private static void	scheduleUpload(WTUnit wtUnit, Site cameFrom, Timestamp ts, String embFolder, String transType) Deprecated.
static void	sendTeamTemplateDueSiteTeamTemplateChange(ObjectReference siteRef) Deprecated.
private static void	testReceivedAppData(ApplicationData appData, String outputFileName) Deprecated.
static void	uploadContent(UnitReceiveRecord urr, String transType, String embFolder, Locale locale) Deprecated.
static ShippingItem	uploadUnit(String rmtNum, String rmtName, String fullTeamTemplateName, Boolean isOnSchedule, Timestamp timeStamp, String rmtURL, ObjectReference sendRecRef, InputStream is) Deprecated.
private static ShippingItem	uploadUnitImpl(String unitNumber, String unitName, String fullTeamTemplateName, Boolean isOnSchedule, Timestamp timeStamp, String rmtURL, ObjectReference sendRecRef, String description, String embFolder, String transType, InputStream is) Deprecated.

Methods inherited from class wt.services.StandardManager

emergencyShutdown, emergencyShutdownComplete, emergencyShuttingDown, getClassInfo, getManagerService, getManagerStatus, getName, getStartupType, init, initialize, initialize, isStarted, newStandardManager, newStandardManager, performEmergencyShutdownProcess, performShutdownProcess, setManagerService, shutdown, shutdownFailure, shutdownSuccess, shuttingDown, started, startedErrors, startingUp, startup, startupFailure, toString

Methods inherited from class java.lang.Object

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

Field Detail

RESOURCE

private static final String RESOURCE

Deprecated.

See Also:

Constant Field Values

CLASSNAME

private static final String CLASSNAME

Deprecated.

VERBOSE

private static boolean VERBOSE

Deprecated.

createNewNumber

private static boolean createNewNumber

Deprecated.

embLogDir

private static String embLogDir

Deprecated.

SCHEDULE_ITEM_ENABLED

private static boolean SCHEDULE_ITEM_ENABLED

Deprecated.

teamTemplatePathCache

private static Hashtable teamTemplatePathCache

Deprecated.

SHOW_LOCAL_SITE

private static boolean SHOW_LOCAL_SITE

Deprecated.

PERFORMANCE

private static boolean PERFORMANCE

Deprecated.

tt

private static wt.replication.test.TestTime tt

Deprecated.

AUTO_PULL

private static boolean AUTO_PULL

Deprecated.

REPL_READ_ONLY

private static boolean REPL_READ_ONLY

Deprecated.

TEAMTEMPLATE_FILTER_ENABLED

private static boolean TEAMTEMPLATE_FILTER_ENABLED

Deprecated.

UNIT_RECEIVE_LIFECYCLE_TEMPLATE

private static String UNIT_RECEIVE_LIFECYCLE_TEMPLATE

Deprecated.

UNIT_RECEIVE_LIFECYCLE_STATE

private static String UNIT_RECEIVE_LIFECYCLE_STATE

Deprecated.

SUBSCRIBER_ROLE

private static final String SUBSCRIBER_ROLE

Deprecated.

See Also:

Constant Field Values

Constructor Detail

StandardReplicationRecvService

public StandardReplicationRecvService()

Deprecated.

Method Detail

getConceptualClassname

public String getConceptualClassname()

Deprecated.

Returns the conceptual (modeled) name for the class.

Supported API: false

Specified by:

getConceptualClassname in interface NetFactor

Overrides:

getConceptualClassname in class StandardManager

Returns:

String

newStandardReplicationRecvService

public static StandardReplicationRecvService newStandardReplicationRecvService()
                                                                        throws WTException

Deprecated.

Supported API: false

Returns:

StandardReplicationRecvService

Throws:

WTException

performStartupProcess

protected void performStartupProcess()
                              throws ManagerException

Deprecated.

Initialization tasks performed by the engine service. Includes queue activation and event subscription.

Supported API: false

Overrides:

performStartupProcess in class StandardManager

Throws:

ManagerException

uploadUnit

public static ShippingItem uploadUnit(String rmtNum,
                                      String rmtName,
                                      String fullTeamTemplateName,
                                      Boolean isOnSchedule,
                                      Timestamp timeStamp,
                                      String rmtURL,
                                      ObjectReference sendRecRef,
                                      InputStream is)
                               throws WTReplicationException

Deprecated.

This method will create a "copy" of a WTUnit object, and accept manifest passed from remote side. Return feedback to remote side.

Supported API: false

Parameters:

rmtNum -

rmtName -

fullTeamTemplateName -

isOnSchedule -

timeStamp -

rmtURL -

sendRecRef -

is -

Returns:

ShippingItem

Throws:

WTReplicationException

uploadContent

public static void uploadContent(UnitReceiveRecord urr,
                                 String transType,
                                 String embFolder,
                                 Locale locale)
                          throws WTReplicationException,
                                 WTException,
                                 WTPropertyVetoException

Deprecated.

This method will download content from Sender's side, and attach the received inputStream to the WTUnit object. The WTUnit object should contain all the information to perform the download. .

Supported API: false

Parameters:

urr -

transType -

embFolder -

locale -

Throws:

WTReplicationException

WTException

WTPropertyVetoException

handleReceivedIS

public static void handleReceivedIS(ObjectReference unitRef,
                                    String fileName,
                                    String description,
                                    String uploadedFromPath,
                                    Ufid ufid,
                                    InputStream contentIS)
                             throws WTReplicationException

Deprecated.

This method will execute the contentIS (InputStream) downloaded from remote side. This is the target method which should be set in the MethodInvocationDesc when ActionPullItem object is constructed to perform the downloads for HttpPipe and GZIPHttpPipe.

Supported API: false

Parameters:

unitRef -

fileName -

description -

uploadedFromPath -

ufid -

contentIS -

Throws:

WTReplicationException

embHandleReceivedIS

public static void embHandleReceivedIS(ObjectReference unitRef,
                                       String fileName,
                                       String description,
                                       String uploadedFromPath,
                                       Ufid ufid,
                                       InputStream contentIS)
                                throws WTReplicationException

Deprecated.

This method will execute the contentIS (InputStream) extracted from hard disk. This is the target method which should be set in the MethodInvocationDesc when ActionPullItem object is constructed to perform the downloads for EMBPipe.

Supported API: false

Parameters:

unitRef -

fileName -

description -

uploadedFromPath -

ufid -

contentIS -

Throws:

WTReplicationException

responseTeamTemplateRequest

public static ShippingItem responseTeamTemplateRequest(String rmtUrl)

Deprecated.

Returns all team templates associated with the rmtSite. The team templates match the WTPrincipal set for this remote site and are associated with SUBSCRIBER role.

Supported API: false

Parameters:

rmtUrl -

Returns:

ShippingItem

dispatchVetoableEvent

protected void dispatchVetoableEvent(String eventType,
                                     WTUnit unit)
                              throws WTException

Deprecated.

Supported API: false

Parameters:

eventType -

unit -

Throws:

WTException

registerEvents

public void registerEvents(ManagerService manager)

Deprecated.

Supported API: false

Specified by:

registerEvents in interface Manager

Overrides:

registerEvents in class StandardManager

Parameters:

manager -

embUploadUnit

public void embUploadUnit(String embFolder,
                          String fullTeamTemplateName)
                   throws WTReplicationException,
                          WTException

Deprecated.

This is the "starting" method for product replication through External Media Based (EMB) transport type. All information, which comes from Sender's side, is located under folder "embFolder", with one Exception: if "fulTeamTemplateName" is specified at Receiver's site, then it will overrides the one specified at Sender's site. Calling this method will assume on schedule immediately. If successfully called, it will be ready to run import.

Supported API: false

Specified by:

embUploadUnit in interface ReplicationRecvService

Parameters:

embFolder -

fullTeamTemplateName -

Throws:

WTReplicationException

WTException

returnHttpReceipt

private static ActionShippingItem returnHttpReceipt(ObjectReference sendRecRef,
                                                    String localUrl,
                                                    Throwable e)

Deprecated.

scheduleReceiveOperation

public static void scheduleReceiveOperation(WTUnit wtUnit,
                                            Timestamp startTime,
                                            String description,
                                            String transType,
                                            String embFolder,
                                            Locale locale)
                                     throws WTException,
                                            WTPropertyVetoException

Deprecated.

Throws:

WTException

WTPropertyVetoException

scheduleUpload

private static void scheduleUpload(WTUnit wtUnit,
                                   Site cameFrom,
                                   Timestamp ts,
                                   String embFolder,
                                   String transType)
                            throws WTException,
                                   WTPropertyVetoException

Deprecated.

Throws:

WTException

WTPropertyVetoException

enableScheduleItem

public static UnitReceiveRecord enableScheduleItem(WTUnit unit)

Deprecated.

This method is called by the workflow processes to allow the currently active receive operation for the replication unit to proceed. The arguments and return type for this method should not be changed because that will break existing workflow templates.

Supported API: true

Parameters:

unit - The replication unit whose receive operation is to be enabled.

Returns:

The currently active UnitReceiveRecord that has been enabled

findManifestInfo

private static Enumeration findManifestInfo(WTUnit wtUnit)

Deprecated.

handleDownloadException

private static WTReplicationException handleDownloadException(WTUnit wtUnit,
                                                              Throwable e,
                                                              String key,
                                                              Object[] errorInfo)

Deprecated.

testReceivedAppData

private static void testReceivedAppData(ApplicationData appData,
                                        String outputFileName)

Deprecated.

sendTeamTemplateDueSiteTeamTemplateChange

public static void sendTeamTemplateDueSiteTeamTemplateChange(ObjectReference siteRef)

Deprecated.

getAppDataBy

private static StandardReplicationRecvService.BooledAppData getAppDataBy(WTUnit wtUnit,
                                                                         StreamIdentity sid)

Deprecated.

returnTeamTemplates

private static ShippingItem returnTeamTemplates(Vector teamTemplateList,
                                                Throwable e)

Deprecated.

uploadUnitImpl

private static ShippingItem uploadUnitImpl(String unitNumber,
                                           String unitName,
                                           String fullTeamTemplateName,
                                           Boolean isOnSchedule,
                                           Timestamp timeStamp,
                                           String rmtURL,
                                           ObjectReference sendRecRef,
                                           String description,
                                           String embFolder,
                                           String transType,
                                           InputStream is)
                                    throws WTReplicationException

Deprecated.

Throws:

WTReplicationException

returnReceipt

private static ShippingItem returnReceipt(ObjectReference ref,
                                          String localUrl,
                                          Throwable thr,
                                          boolean isEMBPipe)
                                   throws WTReplicationException

Deprecated.

Throws:

WTReplicationException

findEmbEntryInfo

private static Enumeration findEmbEntryInfo(WTUnit wtUnit,
                                            String embFolder,
                                            EMBReceiverLog embLog)
                                     throws WTReplicationException

Deprecated.

Throws:

WTReplicationException

embLogDirInitialize

private static void embLogDirInitialize(WTProperties props)

Deprecated.

embWriteLogHeader

private static void embWriteLogHeader(EMBReceiverLog embLog,
                                      WTUnit wtUnit,
                                      Site cameFrom,
                                      String embFolder)

Deprecated.

findPrincipal

private static WTPrincipal findPrincipal(String remoteUrl)

Deprecated.

checkPrincipalMatch

private static boolean checkPrincipalMatch(WTPrincipal candidate,
                                           WTPrincipal target)

Deprecated.

findQualifiedTeamTemplates

private static Vector findQualifiedTeamTemplates(WTPrincipal principal,
                                                 boolean toFilter)
                                          throws WTException

Deprecated.

Throws:

WTException

findQualifiedTeamTemplatesByRole

private static Vector findQualifiedTeamTemplatesByRole(WTPrincipal principal,
                                                       boolean toFilter,
                                                       String roleStr)
                                                throws WTException

Deprecated.

Finds Team Templates which qualifies according to the expected role.

Parameters:

principal -

toFilter - if true, it "filters" Team Templates according to role, if false, gets all enabled Team Templates

roleStr - role of desired Team Template. It must be provided in the full class form, ex: "wt.project.Role.SUBSCRIBER"

Returns:

Vector with strings of qualified Team Template names

Throws:

WTException

findQualifiedTeamTemplatesByCreatorRole

private static Vector findQualifiedTeamTemplatesByCreatorRole(WTPrincipal principal,
                                                              boolean toFilter)
                                                       throws WTException

Deprecated.

Throws:

WTException

findUnitFolder

private static String findUnitFolder(String fullTeamTemplateName)

Deprecated.

constructUfidFromString

private static Ufid constructUfidFromString(String sUfid)

Deprecated.