tags

src/main/java/com/smcic/api/tags/job/UserTagsConsumer.java

@@ -48,8 +48,8 @@ public class UserTagsConsumer {
         List<Recommend.TableContentDTO> tableContent = new ArrayList<>();
 
         while (true){
+            UserTagsDTO userTags = userTagsQueue.poll();
             try {
-                UserTagsDTO userTags = userTagsQueue.poll();
                 if (null != userTags){
                     log.info("接收到数据{}", userTags);
 
@@ -90,7 +90,6 @@ public class UserTagsConsumer {
                         tableContent.clear();
                     });
 
-
                 }
             }catch (Exception e){
                 log.info("队列处理异常", e);