modify exception

yunheli · yunheli · commit 2260f2f5f46c · 2017-11-17T16:27:09.000+08:00
diff --git a/platform-api/src/main/java/com/flow/platform/api/consumer/CmdCallbackQueueConsumer.java b/platform-api/src/main/java/com/flow/platform/api/consumer/CmdCallbackQueueConsumer.java
@@ -18,6 +18,7 @@
 
 import com.flow.platform.api.domain.CmdCallbackQueueItem;
 import com.flow.platform.api.service.job.JobService;
+import com.flow.platform.core.exception.FlowException;
 import com.flow.platform.core.exception.NotFoundException;
 import com.flow.platform.core.queue.PlatformQueue;
 import com.flow.platform.core.queue.PriorityMessage;
@@ -77,7 +78,7 @@ public void onQueueItem(PriorityMessage message) {
 
     private void detectRetryTimes(CmdCallbackQueueItem item) {
         if (item.getRetryTimes() > RETRY_TIMES) {
-            throw new NotFoundException(String.format("retry times has reach the limit"));
+            throw new FlowException(String.format("retry times has reach the limit"));
         }
     }
 

Original file line number	Diff line number	Diff line change
`@@ -18,6 +18,7 @@`
`18`	`18`
`19`	`19`	`import com.flow.platform.api.domain.CmdCallbackQueueItem;`
`20`	`20`	`import com.flow.platform.api.service.job.JobService;`
	`21`	`+import com.flow.platform.core.exception.FlowException;`
`21`	`22`	`import com.flow.platform.core.exception.NotFoundException;`
`22`	`23`	`import com.flow.platform.core.queue.PlatformQueue;`
`23`	`24`	`import com.flow.platform.core.queue.PriorityMessage;`
`@@ -77,7 +78,7 @@ public void onQueueItem(PriorityMessage message) {`
`77`	`78`
`78`	`79`	`private void detectRetryTimes(CmdCallbackQueueItem item) {`
`79`	`80`	`if (item.getRetryTimes() > RETRY_TIMES) {`
`80`		`- throw new NotFoundException(String.format("retry times has reach the limit"));`
	`81`	`+ throw new FlowException(String.format("retry times has reach the limit"));`
`81`	`82`	`}`
`82`	`83`	`}`
`83`	`84`