Introduce PersistInterruptedException.

1 files changed, 4 insertions, 0 deletions

diff --git a/src/main/java/com/amazon/carbonado/spi/ExceptionTransformer.java b/src/main/java/com/amazon/carbonado/spi/ExceptionTransformer.java
index 2064e68..e660162 100644
--- a/src/main/java/com/amazon/carbonado/spi/ExceptionTransformer.java
+++ b/src/main/java/com/amazon/carbonado/spi/ExceptionTransformer.java
@@ -24,6 +24,7 @@ import java.nio.channels.ClosedByInterruptException;
 import com.amazon.carbonado.FetchException;

 import com.amazon.carbonado.FetchInterruptedException;

 import com.amazon.carbonado.PersistException;

+import com.amazon.carbonado.PersistInterruptedException;

 import com.amazon.carbonado.RepositoryException;

 

 /**

@@ -158,6 +159,9 @@ public class ExceptionTransformer {
         if (e instanceof PersistException) {

             return (PersistException) e;

         }

+        if (e instanceof InterruptedIOException) {

+            return new PersistInterruptedException(e);

+        }

         if (e instanceof FetchException) {

             return ((FetchException) e).toPersistException();

         }