Skip to content
Snippets Groups Projects
Commit b440a139 authored by anttil's avatar anttil
Browse files

BIS-506 / SP-830: ZipArchiver should create notification if archiving fails

SVN: 29671
parent d2f86886
No related branches found
No related tags found
No related merge requests found
...@@ -236,7 +236,7 @@ public abstract class AbstractArchiverProcessingPlugin extends AbstractDatastore ...@@ -236,7 +236,7 @@ public abstract class AbstractArchiverProcessingPlugin extends AbstractDatastore
return new GroupedDatasets(upToDateInArchive, differentInArchive); return new GroupedDatasets(upToDateInArchive, differentInArchive);
} }
private List<DatasetDescription> getDataSetsFailedToBeArchived( private List<DatasetDescription> getDataSetsFailedToBeArchived(
List<DatasetDescription> datasets, DatasetProcessingStatuses statuses) List<DatasetDescription> datasets, DatasetProcessingStatuses statuses)
{ {
...@@ -336,7 +336,7 @@ public abstract class AbstractArchiverProcessingPlugin extends AbstractDatastore ...@@ -336,7 +336,7 @@ public abstract class AbstractArchiverProcessingPlugin extends AbstractDatastore
DatasetProcessingStatuses status = doDeleteFromArchive(datasets); DatasetProcessingStatuses status = doDeleteFromArchive(datasets);
return status != null ? status.getProcessingStatus() : null; return status != null ? status.getProcessingStatus() : null;
} }
protected DatasetProcessingStatuses deletePermanentlyFromArchive(List<? extends IDatasetLocation> dataSets) protected DatasetProcessingStatuses deletePermanentlyFromArchive(List<? extends IDatasetLocation> dataSets)
{ {
return doDeleteFromArchive(dataSets); return doDeleteFromArchive(dataSets);
...@@ -417,7 +417,7 @@ public abstract class AbstractArchiverProcessingPlugin extends AbstractDatastore ...@@ -417,7 +417,7 @@ public abstract class AbstractArchiverProcessingPlugin extends AbstractDatastore
String logMessage = createLogMessage(datasetCode, status, operationDescription); String logMessage = createLogMessage(datasetCode, status, operationDescription);
if (status.isError()) if (status.isError())
{ {
operationLog.error(logMessage); notifyLog.error(logMessage);
failedDatasetCodes.add(datasetCode); failedDatasetCodes.add(datasetCode);
} else } else
{ {
...@@ -554,12 +554,12 @@ public abstract class AbstractArchiverProcessingPlugin extends AbstractDatastore ...@@ -554,12 +554,12 @@ public abstract class AbstractArchiverProcessingPlugin extends AbstractDatastore
{ {
this.statusUpdater = statusUpdater; this.statusUpdater = statusUpdater;
} }
protected void setShareIdManager(IShareIdManager shareIdManager) protected void setShareIdManager(IShareIdManager shareIdManager)
{ {
this.shareIdManager = shareIdManager; this.shareIdManager = shareIdManager;
} }
protected void setService(IEncapsulatedOpenBISService service) protected void setService(IEncapsulatedOpenBISService service)
{ {
this.service = service; this.service = service;
......
...@@ -40,6 +40,9 @@ public abstract class AbstractDatastorePlugin implements Serializable ...@@ -40,6 +40,9 @@ public abstract class AbstractDatastorePlugin implements Serializable
static protected final Logger operationLog = LogFactory.getLogger(LogCategory.OPERATION, static protected final Logger operationLog = LogFactory.getLogger(LogCategory.OPERATION,
AbstractDatastorePlugin.class); AbstractDatastorePlugin.class);
static protected final Logger notifyLog = LogFactory.getLogger(LogCategory.NOTIFY,
AbstractDatastorePlugin.class);
private static final String SUB_DIRECTORY_NAME = "sub-directory-name"; private static final String SUB_DIRECTORY_NAME = "sub-directory-name";
private static final long serialVersionUID = 1L; private static final long serialVersionUID = 1L;
......
...@@ -169,13 +169,18 @@ public class DistributedPackagingDataSetFileOperationsManager implements IDataSe ...@@ -169,13 +169,18 @@ public class DistributedPackagingDataSetFileOperationsManager implements IDataSe
{ {
dataSetPackager.close(); dataSetPackager.close();
List<String> errors = if (Status.OK.equals(status))
verify(file, new ZipFileIntegrityVerifier());
if (errors.size() > 0)
{ {
throw new RuntimeException(errors.toString()); List<String> errors =
verify(file, new ZipFileIntegrityVerifier());
if (errors.size() > 0)
{
status = Status.createError(errors.toString());
throw new RuntimeException(errors.toString());
}
} }
operationLog.info("Data set '" + dataSetCode + "' archived: " + file); operationLog.info("Data set '" + dataSetCode + "' archived: " + file);
} catch (Exception ex) } catch (Exception ex)
{ {
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment