删除 updateRetryCount 方法

src/main/java/com/uas/search/jms/JmsListener.java

@@ -137,12 +137,13 @@ public class JmsListener {
     /**
      * 对得到的队列消息进行解析，之后根据解析出来的对象，对lucene索引进行添加、更新或删除操作
      *
-     * @param luceneMessage
+     * @param luceneMessage 消息
      */
     private void process(LuceneMessage luceneMessage) {
         logger.info(luceneMessage.toString());
         Long id = luceneMessage.getId();
-        luceneMessageDao.updateRetryCount(id);
+        luceneMessage.setRetryCount(luceneMessage.getRetryCount() + 1);
+        luceneMessageDao.save(luceneMessage);
         ParsedQueueMessage parsedQueueMessage = queueMessageParser.parse(luceneMessage.getTableName(), luceneMessage.getDataId(), luceneMessage.getMethodType(), luceneMessage.getData());
         List<Object> maintainedObjects = indexService.maintainIndexes(parsedQueueMessage);
         logger.info("Maintained... " + maintainedObjects);

src/main/java/com/uas/search/jms/LuceneMessageDao.java

@@ -36,15 +36,6 @@ public interface LuceneMessageDao
     @Query(value = "select count(1) from lucene$message where me_retry_count < 5", nativeQuery = true)
     long count();
 
-    /**
-     * 尝试次数加 1
-     * @param id 消息 id
-     */
-    @Transactional
-    @Modifying(clearAutomatically = true)
-    @Query(value = "update lucene$message set me_retry_count = me_retry_count + 1 where me_id = ?1", nativeQuery = true)
-    void updateRetryCount(@NotEmpty("id") Long id);
-
     /**
      * 出队消息
      * @param id 消息 id