|
@@ -240,7 +240,10 @@ public class ApplyTaskCacheService implements CacheConstants {
|
|
|
|
|
|
RBlockingQueue<ApplyRecordCacheBean> queue = redisClient.getRedissonClient()
|
|
|
.getBlockingQueue(QUEUE_STUDENT_APPLY_RECORD);
|
|
|
+
|
|
|
boolean success = queue.offer(value);
|
|
|
+ log.info("{}_{}_{}_{} offerQueue:{}", value.getStudentId(), value.getExamSiteId(),
|
|
|
+ value.getTimePeriodId(), value.getCancel(), success);
|
|
|
if (!success) {
|
|
|
throw new RuntimeException("推送至考生预约记录队列失败");
|
|
|
}
|