zouxuan 5 년 전
부모
커밋
f328ed0916
2개의 변경된 파일3개의 추가작업 그리고 3개의 파일을 삭제
  1. 1 1
      mec-im/src/main/java/com/ym/job/ScheduleManager.java
  2. 2 2
      mec-im/src/main/java/com/ym/service/Impl/RoomServiceImpl.java

+ 1 - 1
mec-im/src/main/java/com/ym/job/ScheduleManager.java

@@ -86,8 +86,8 @@ public class ScheduleManager implements SchedulingConfigurer {
             @Override
             public void run() {
                 ScheduledTask task = roomCacheTasks.remove(roomId);
-                task.cancel();
                 roomService.destroyRoom(roomId);
+                task.cancel();
             }
         }, roomProperties.getRoomTtl() * 10, roomProperties.getRoomTtl(), null));
         roomCacheTasks.put(roomId, task);

+ 2 - 2
mec-im/src/main/java/com/ym/service/Impl/RoomServiceImpl.java

@@ -118,8 +118,8 @@ public class RoomServiceImpl implements RoomService {
                 log.error("joinRoom IM error: roomId={}, {}", roomId, resultInfo.getErrorMessage());
                 throw new ApiException(ErrorEnum.ERR_CREATE_ROOM_ERROR, resultInfo.getErrorMessage());
             } else {
-                destroyRoom(roomId);
-//                scheduleManager.addExpiredTask(this, roomId);
+//                destroyRoom(roomId);
+                scheduleManager.addExpiredTask(this, roomId);
             }
         } else {
             display = roomList.get(0).getDisplay();