|
|
@@ -3,7 +3,6 @@ package com.uas.search.jms;
|
|
|
import com.uas.search.annotation.NotEmpty;
|
|
|
import org.springframework.data.jpa.repository.JpaRepository;
|
|
|
import org.springframework.data.jpa.repository.JpaSpecificationExecutor;
|
|
|
-import org.springframework.data.jpa.repository.Modifying;
|
|
|
import org.springframework.data.jpa.repository.Query;
|
|
|
import org.springframework.data.jpa.repository.query.Procedure;
|
|
|
import org.springframework.stereotype.Repository;
|
|
|
@@ -26,7 +25,7 @@ public interface LuceneMessageDao
|
|
|
* @param size 指定数目
|
|
|
* @return 数据
|
|
|
*/
|
|
|
- @Query(value = "select * from lucene$message where me_retry_count < 5 order by me_priority desc, me_create_time limit ?1, ?2", nativeQuery = true)
|
|
|
+ @Query(value = "select * from lucene$message where me_retry_count < 5 order by me_priority desc, me_id limit ?1, ?2", nativeQuery = true)
|
|
|
List<LuceneMessage> findList(@NotEmpty("start") Integer start, @NotEmpty("size") Integer size);
|
|
|
|
|
|
/**
|