ソースを参照

update rabbit listener

tangss 7 年 前
コミット
00e9e2ddf7

+ 1 - 1
mooctest-site-server/src/main/java/cn/iselab/mooctest/site/Application.java

@@ -113,7 +113,7 @@ public class Application {
 
         // To disabled web environment, change `true` to `false`
         application.setWebEnvironment(true);
-        application.addListeners(new ApplicationStartup());
+//        application.addListeners(new ApplicationStartup());
         application.run(args);
     }
 

+ 1 - 1
mooctest-site-server/src/main/java/cn/iselab/mooctest/site/common/mqListener/AsyncToolMessageReceiver.java

@@ -36,11 +36,11 @@ public class AsyncToolMessageReceiver {
         JSONObject jResult = JSONObject.fromObject(sResult.toString());
         String jobId = jResult.getString("jobId");
         int returnCode = jResult.getInt("returnCode");
-        String resultDetail = asyncScheduleService.getJobResult(jobId).getResult();
 
         int jobStatus = returnCode==ReturnCodeConstants.SUCCESS? AsyncJobStatus.SUCCESS:AsyncJobStatus.FAIL;
 
         try{
+            String resultDetail = asyncScheduleService.getJobResult(jobId).getResult();
             asyncScheduleService.processJobResult(jobId, resultDetail, returnCode);
             LOG.info("receiver:"+ sResult);
         } catch (Exception e) {