File tree Expand file tree Collapse file tree 1 file changed +4
-4
lines changed
platform-api/src/main/java/com/flow/platform/api/consumer Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Original file line number Diff line number Diff line change 2323import com .flow .platform .core .queue .PlatformQueue ;
2424import com .flow .platform .core .queue .PriorityMessage ;
2525import com .flow .platform .core .queue .QueueListener ;
26+ import com .flow .platform .core .util .ThreadUtil ;
2627import com .flow .platform .util .Logger ;
2728import javax .annotation .PostConstruct ;
2829import org .springframework .beans .factory .annotation .Autowired ;
@@ -80,10 +81,9 @@ private void detectRetryTimes(CmdCallbackQueueItem item) {
8081 }
8182
8283 private void reEnqueueJobCallback (CmdCallbackQueueItem item , long wait , int priority ) {
83- try {
84- Thread .sleep (wait );
85- } catch (Throwable ignore ) {
86- }
84+
85+ // sleep seconds
86+ ThreadUtil .sleep (wait );
8787
8888 // set retry times
8989 item .setRetryTimes (item .getRetryTimes () - 1 );
You can’t perform that action at this time.
0 commit comments