SUPPORT-8597: check for av error
This commit is contained in:
parent
5209098ac5
commit
536f210a73
1 changed files with 4 additions and 1 deletions
|
|
@ -116,8 +116,11 @@ public class FileUploadService {
|
||||||
downloadRequest.fileInfo().setFileUrl(null);
|
downloadRequest.fileInfo().setFileUrl(null);
|
||||||
FileStatus fileStatus = isAvError ? FileStatus.FILE_STATUS_11 : FileStatus.FILE_STATUS_02;
|
FileStatus fileStatus = isAvError ? FileStatus.FILE_STATUS_11 : FileStatus.FILE_STATUS_02;
|
||||||
downloadRequest.fileInfo().setFileStatus(fileStatus);
|
downloadRequest.fileInfo().setFileStatus(fileStatus);
|
||||||
|
|
||||||
|
if (!isAvError) {
|
||||||
sendMessage(outErrorTopic.name(), downloadRequest, messageId, kafkaTemplate);
|
sendMessage(outErrorTopic.name(), downloadRequest, messageId, kafkaTemplate);
|
||||||
}
|
}
|
||||||
|
}
|
||||||
else {
|
else {
|
||||||
String fileRef = s3Service.putFile(filePath, fileUrl.fileName());
|
String fileRef = s3Service.putFile(filePath, fileUrl.fileName());
|
||||||
|
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue