package jnpf.dmsMapper;
|
|
import jnpf.dmsEntity.fenfa.DmsBupinghengRetry;
|
import org.apache.ibatis.annotations.Param;
|
import java.util.List;
|
|
public interface DmsBupinghengRetryMapper {
|
List<DmsBupinghengRetry> selectPending(@Param("batchSize") int batchSize, @Param("maxAttempts") int maxAttempts);
|
int claim(@Param("task") DmsBupinghengRetry task, @Param("token") String token,
|
@Param("maxAttempts") int maxAttempts);
|
DmsBupinghengRetry selectClaim(@Param("task") DmsBupinghengRetry task, @Param("token") String token);
|
int finish(@Param("task") DmsBupinghengRetry task, @Param("token") String token,
|
@Param("stop") boolean stop, @Param("error") String error, @Param("delaySeconds") int delaySeconds);
|
}
|
