private static final String appendExtension = ".mxf";\r
\r
@StepEntry\r
- public Object[] execute(BasicDBList vicFiles, String escortStoreName, String targetStoreName, String targetProtocol) throws Exception {\r
+ public Object[] execute(BasicDBList vicFiles, String escortStoreName, String targetStoreName, String targetProtocol)\r
+ throws Exception {\r
StoreUri escortStoreUri = null;\r
StoreUri targetStoreUri = null;\r
try {\r
getJobRuntime().setRelated(targetStoreName + " restore");\r
\r
escortStoreUri = getManager().getStoreUri(escortStoreName, RemoteStoreProtocol.LOCAL);\r
- targetStoreUri = getManager().getStoreUri(targetStoreName, Enum.valueOf(RemoteStoreProtocol.class, targetProtocol));\r
+ targetStoreUri = getManager().getStoreUri(targetStoreName,\r
+ Enum.valueOf(RemoteStoreProtocol.class, targetProtocol));\r
StoreUri sourceStoreUri = getManager().getStoreUri("TSM", RemoteStoreProtocol.TSM);\r
List<HarrisRecord> records = null;\r
for (Object vicFile : vicFiles) {\r
Path vicFilePath = Paths.get(String.valueOf(vicFile));\r
\r
if (!vicFilePath.toFile().exists()) {\r
- logger.warn("File not exists: {}", vicFilePath);\r
+ logger.warn("File does not exist: {}", vicFilePath);\r
continue;\r
}\r
\r
return null;\r
}\r
\r
- private boolean processRecord(HarrisRecord record, String targetStoreName, StoreUri sourceStoreUri, StoreUri targetStoreUri, StoreUri escortStoreUri)\r
- throws Exception {\r
+ private boolean processRecord(HarrisRecord record, String targetStoreName, StoreUri sourceStoreUri,\r
+ StoreUri targetStoreUri, StoreUri escortStoreUri) throws Exception {\r
\r
String fileName = record.getFileName();\r
String outputPath = Paths.get(escortStoreUri.toString(true)).toString();\r
\r
String escortFileName = targetStoreName + "." + fileName;\r
\r
- //ha mar letezik, nem toltjuk fel ujra (a vic fajlbol kezzel torlik valamikor...)\r
+ // ha mar letezik, nem toltjuk fel ujra (a vic fajlbol kezzel torlik\r
+ // valamikor...)\r
try {\r
if (EscortFiles.isMetadataExists(outputPath, escortFileName)) {\r
logger.debug(getMarker(), "Status file already exists {}", escortFileName);\r
return true;\r
}\r
\r
- //nincs bent MC-ben\r
+ // nincs bent MC-ben\r
Media media = getManager().getMedia(record.getFileName());\r
if (media == null) {\r
logger.error(getSessionMarker(), "File is not available in archive {}", record.getFileName());\r
return true;\r
}\r
\r
- // if (existsOnNexio(record, targetStoreName, targetStoreUri)) {\r
- // logger.info(getMarker(), "File {} already exists on {}", record.getFileName(), targetStoreName);\r
- // return false;\r
- // }\r
+ // if (existsOnNexio(record, targetStoreName, targetStoreUri)) {\r
+ // logger.info(getMarker(), "File {} already exists on {}",\r
+ // record.getFileName(), targetStoreName);\r
+ // return false;\r
+ // }\r
\r
- DownloadableMedia downloadable = DownloadableMedia.create(media.getTitle(), fileName, media.getModified(), media.getCreated(), media.getLength(), 0L,\r
- sourceStoreUri.getId(), targetStoreUri.getId(), media.getId());\r
+ DownloadableMedia downloadable = DownloadableMedia.create(media.getTitle(), fileName, media.getModified(),\r
+ media.getCreated(), media.getLength(), 0L, sourceStoreUri.getId(), targetStoreUri.getId(),\r
+ media.getId());\r
\r
- //alapbol magasabb (1-99)\r
+ // alapbol magasabb (1-99)\r
downloadable.put("priority", 50);\r
downloadable.put("isNexio", true);\r
\r