code

Author: lorenzo

src/main/java/com/reedelk/file/component/FileWrite.java

@@ -8,7 +8,7 @@
 import com.reedelk.runtime.api.component.OnResult;
 import com.reedelk.runtime.api.component.ProcessorAsync;
 import com.reedelk.runtime.api.converter.ConverterService;
-import com.reedelk.runtime.api.exception.ESBException;
+import com.reedelk.runtime.api.exception.PlatformException;
 import com.reedelk.runtime.api.flow.FlowContext;
 import com.reedelk.runtime.api.message.Message;
 import com.reedelk.runtime.api.message.content.TypedPublisher;
@@ -102,7 +102,7 @@ public void apply(FlowContext flowContext, Message message, OnResult callback) {
             }
 
         } else {
-            callback.onError(flowContext, new ESBException("Could not write file"));
+            callback.onError(flowContext, new PlatformException("Could not write file"));
         }
     }
 

src/main/java/com/reedelk/file/internal/commons/RetryCommand.java

@@ -2,7 +2,7 @@
 
 import com.reedelk.file.internal.commons.Messages.Misc;
 import com.reedelk.file.internal.exception.MaxRetriesExceeded;
-import com.reedelk.runtime.api.exception.ESBException;
+import com.reedelk.runtime.api.exception.PlatformException;
 
 import java.util.function.Supplier;
 
@@ -55,7 +55,7 @@ private void retry() {
 
             } catch (InterruptedException exception) {
 
-                throw new ESBException(exception);
+                throw new PlatformException(exception);
 
             } catch (Exception exception) {
 
@@ -73,7 +73,7 @@ private void retry() {
 
                 } else {
 
-                    throw new ESBException(exception);
+                    throw new PlatformException(exception);
 
                 }
             }

src/main/java/com/reedelk/file/internal/exception/FileDeleteException.java

@@ -1,8 +1,8 @@
 package com.reedelk.file.internal.exception;
 
-import com.reedelk.runtime.api.exception.ESBException;
+import com.reedelk.runtime.api.exception.PlatformException;
 
-public class FileDeleteException extends ESBException {
+public class FileDeleteException extends PlatformException {
 
     public FileDeleteException(String message, Throwable exception) {
         super(message, exception);

src/main/java/com/reedelk/file/internal/exception/FileReadException.java

@@ -1,8 +1,8 @@
 package com.reedelk.file.internal.exception;
 
-import com.reedelk.runtime.api.exception.ESBException;
+import com.reedelk.runtime.api.exception.PlatformException;
 
-public class FileReadException extends ESBException {
+public class FileReadException extends PlatformException {
 
     public FileReadException(String message, Throwable exception) {
         super(message, exception);

src/main/java/com/reedelk/file/internal/exception/FileWriteException.java

@@ -1,8 +1,8 @@
 package com.reedelk.file.internal.exception;
 
-import com.reedelk.runtime.api.exception.ESBException;
+import com.reedelk.runtime.api.exception.PlatformException;
 
-public class FileWriteException extends ESBException {
+public class FileWriteException extends PlatformException {
 
     public FileWriteException(String message, Throwable exception) {
         super(message, exception);

src/main/java/com/reedelk/file/internal/exception/MaxRetriesExceeded.java

@@ -1,8 +1,8 @@
 package com.reedelk.file.internal.exception;
 
-import com.reedelk.runtime.api.exception.ESBException;
+import com.reedelk.runtime.api.exception.PlatformException;
 
-public class MaxRetriesExceeded extends ESBException {
+public class MaxRetriesExceeded extends PlatformException {
 
     public MaxRetriesExceeded(String message) {
         super(message);

src/main/java/com/reedelk/file/internal/exception/NotValidFileException.java

@@ -1,8 +1,8 @@
 package com.reedelk.file.internal.exception;
 
-import com.reedelk.runtime.api.exception.ESBException;
+import com.reedelk.runtime.api.exception.PlatformException;
 
-public class NotValidFileException extends ESBException {
+public class NotValidFileException extends PlatformException {
 
     public NotValidFileException(String message) {
         super(message);