@@ -189,22 +189,22 @@ public class FileUploadServiceImpl implements FileUploadService {
|
|||||||
CompletableFuture.runAsync(() -> cleanupSessionFiles(session));
|
CompletableFuture.runAsync(() -> cleanupSessionFiles(session));
|
||||||
}
|
}
|
||||||
|
|
||||||
@Async("fileUploadTaskExecutor")
|
// @Async("fileUploadTaskExecutor")
|
||||||
@Transactional
|
// @Transactional
|
||||||
public void assembleFileAsync(FileUploadSession session) throws DuplicateImageException {
|
// public void assembleFileAsync(FileUploadSession session) throws DuplicateImageException {
|
||||||
try {
|
// try {
|
||||||
assembleFile(session);
|
// assembleFile(session);
|
||||||
log.info("File assembly completed successfully for session: {}",
|
// log.info("File assembly completed successfully for session: {}",
|
||||||
session.getUploadId());
|
// session.getUploadId());
|
||||||
} catch (DuplicateImageException e) {
|
// } catch (DuplicateImageException e) {
|
||||||
throw new DuplicateImageException("DUBL", e.duplicateFileId(), e.userId());
|
// throw new DuplicateImageException("DUBL", e.duplicateFileId(), e.userId());
|
||||||
} catch (Exception e) {
|
// } catch (Exception e) {
|
||||||
log.error("Failed to assemble file for session {}: {}",
|
// log.error("Failed to assemble file for session {}: {}",
|
||||||
session.getUploadId(), e.getMessage(), e);
|
// session.getUploadId(), e.getMessage(), e);
|
||||||
|
//
|
||||||
handleAssemblyFailure(session, e);
|
// handleAssemblyFailure(session, e);
|
||||||
}
|
// }
|
||||||
}
|
// }
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
@Transactional
|
@Transactional
|
||||||
|
|||||||
Reference in New Issue
Block a user