/* VLAB - Data Transfer Service */ /* ARGS[0] - Service Location for Source File */ /* E.g. http://trex.ucs.indiana.edu:5000/axis/services/WSSConnector?wsdl */ /* ARGS[1] - Source File Location (Complete Path) */ /* E.g. file:///home/hgadgil/manna.tar.gz */ /* ARGS[2] - Service Location for Destination File */ /* E.g. http://gf7.ucs.indiana.edu:5000/axis/services/WSSConnector?wsdl */ /* ARGS[3] - Destination File Location (Complete Path) */ /* E.g. file:///home/hgadgil/CPYmanna.tar.gz */ dataSrcLoc = ARGS[0]; src = ARGS[1]; dataDestLoc = ARGS[2]; dest = ARGS[3]; contextKey = "context://vlab/" + SCRIPT_SESSION_ID; WSContext.put(contextKey, "Executing"); tempTopic = "topic:///VLab/DataXFer/" + SCRIPT_SESSION_ID; xferService = "vlab.FileTransferService.FileXferService"; srcHandler = new WSProxyResource(xferService, dataSrcLoc); srcHandler.setInput(src); srcHandler.setOutput(tempTopic); destHandler = new WSProxyResource(xferService, dataDestLoc); destHandler.setInput(tempTopic); destHandler.setOutput(dest); f = new Flow(); f.addComponents(destHandler); f.addStartActivities(srcHandler); f.start("1"); f.waitUntilFlowCompletes(); Sys.println("File Transfer Complete !!"); WSContext.put(contextKey, "DONE");