private Marker marker;\r
\r
@StepEntry\r
- public Object[] execute(ArchiveItem archiveItem, Media mediaCubeMedia, String transcoderAddress, String transcoderTemplateName,\r
- String globalHiresSourcePath, String localLowresTargetPath, boolean deleteSource, IJobEngine jobEngine, IJobRuntime jobRuntime) throws Exception {\r
+ public Object[] execute(ArchiveItem archiveItem, Media mediaCubeMedia, String transcoderAddress,\r
+ String transcoderTemplateName, String globalHiresSourcePath, String localLowresTargetPath,\r
+ boolean deleteSource, IJobEngine jobEngine, IJobRuntime jobRuntime) throws Exception {\r
\r
this.marker = jobRuntime.getSessionMarker();\r
this.manager = jobEngine.getItemManager();\r
String sourceFileName = sourceMediaFile.getName();\r
Timecode timecode = new Timecode(mediaCubeMedia.getLength(), Type.PAL);\r
\r
- String details = String.format("%s (%s, %d bytes)", sourceFileName, timecode.toString(), sourceMediaFile.length());\r
+ String details = String.format("%s (%s, %d bytes)", sourceFileName, timecode.toString(),\r
+ sourceMediaFile.length());\r
\r
StoreUri storeUri = store.getTargetStoreUri(RemoteStoreProtocol.LOCAL);\r
if (storeUri == null)\r
String targetFileName = FilenameUtils.removeExtension(sourceFileName) + MP4EXT;\r
targetPath = Paths.get(localLowresTargetPath, targetFileName);\r
if (!targetPath.toFile().exists()) {\r
- // jobRuntime.setDescription(String.format("%s: %s", jobRuntime.getDescription(), details));\r
+ // jobRuntime.setDescription(String.format("%s: %s",\r
+ // jobRuntime.getDescription(), details));\r
jobRuntime.setDescription(String.format("%s transzkódolása", details));\r
String sourceFile = Paths.get(globalHiresSourcePath, sourceFileName).toString();\r
IFFAStransAPI api = new FFAStransAPI(transcoderAddress, p -> {\r
api.monitor(POLL_INTERVALL);\r
}\r
\r
- //a sikeres transzkod utan nem mindig van ott egybol a fajl\r
+ // a sikeres transzkod utan nem mindig van ott egybol a fajl\r
long started = System.currentTimeMillis();\r
while (!targetPath.toFile().exists()) {\r
long current = System.currentTimeMillis();\r
- //max 5 perc varakozas\r
+ // max 5 perc varakozas\r
if (current - started > 5 * 60 * 1000)\r
throw new Exception("Transcode job target file access timed out");\r
Thread.sleep(POLL_INTERVALL);\r
String transcodedFileName = transcodedFilePath.getFileName().toString();\r
String targetPath = null;\r
if (transcodedFileName.indexOf(".") > 2) {\r
- Path subdir = Paths.get(transcodedFileName.substring(0, 1), transcodedFileName.substring(1, 2), transcodedFileName.substring(2, 3));\r
+ Path subdir = Paths.get(transcodedFileName.substring(0, 1), transcodedFileName.substring(1, 2),\r
+ transcodedFileName.substring(2, 3));\r
EscortFiles.ensureUNCFolder(webPath, subdir.toString());\r
targetPath = Paths.get(subdir.toString(), transcodedFileName).toString();\r
} else {\r
manager.createMediaFile(targetPath, fileType, store, mediaCubeMedia).add();\r
} catch (IOException e) {\r
logger.catching(e);\r
- logger.error(marker, "A '{}' állomány mozgatása a '{}' helyre nem sikerült.", transcodedFilePath, lowresPath);\r
+ logger.error(marker, "A(z) '{}' állomány mozgatása a '{}' helyre nem sikerült.", transcodedFilePath,\r
+ lowresPath);\r
throw e;\r
}\r
}\r