1 files changed, 17 insertions, 0 deletions
diff --git a/datafile-app-server/src/main/java/org/onap/dcaegen2/collectors/datafile/exceptions/DatafileTaskException.java b/datafile-app-server/src/main/java/org/onap/dcaegen2/collectors/datafile/exceptions/DatafileTaskException.java
index 42308000..38f74ed1 100644
--- a/datafile-app-server/src/main/java/org/onap/dcaegen2/collectors/datafile/exceptions/DatafileTaskException.java
+++ b/datafile-app-server/src/main/java/org/onap/dcaegen2/collectors/datafile/exceptions/DatafileTaskException.java
@@ -21,12 +21,29 @@ package org.onap.dcaegen2.collectors.datafile.exceptions;
 public class DatafileTaskException extends Exception {
 
     private static final long serialVersionUID = 1L;
+    private final boolean isRetryable;
 
     public DatafileTaskException(String message) {
         super(message);
+        isRetryable = true;
+    }
+
+    public DatafileTaskException(String message, boolean retry) {
+        super(message);
+        isRetryable = retry;
     }
 
     public DatafileTaskException(String message, Exception originalException) {
         super(message, originalException);
+        isRetryable = true;
+    }
+
+    public DatafileTaskException(String message, Exception originalException, boolean retry) {
+        super(message, originalException);
+        isRetryable = retry;
+    }
+
+    public boolean isRetryable() {
+        return this.isRetryable;
     }
 }