gtsoft/gtsoft-snail-job-server
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects 1 Releases Wiki Activity

feat(1.5.0-beta1-jdk8): 同步1.5.0-beta1代码，并兼容 jdk8

Browse Source
This commit is contained in:
dhb52 2025-04-26 22:35:55 +08:00
parent ab73443ee9
commit c991cb1e04
4 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
snail-job-client/snail-job-client-retry-core/src/main/java/com/aizuda/snailjob/client/core/dto/RequestTriggerRetryDTO.java
View File

@ -1,8 +1,9 @@
package com.aizuda.snailjob.client.core.dto;
import jakarta.validation.constraints.NotNull;
import lombok.Data;
import javax.validation.constraints.NotNull;
@Data
public class RequestTriggerRetryDTO {
@NotNull(message = "id cannot be null")

3
snail-job-client/snail-job-client-retry-core/src/main/java/com/aizuda/snailjob/client/core/dto/RequestUpdateRetryStatusDTO.java
View File

@ -1,8 +1,9 @@
package com.aizuda.snailjob.client.core.dto;
import jakarta.validation.constraints.NotNull;
import lombok.Data;
import javax.validation.constraints.NotNull;
@Data
public class RequestUpdateRetryStatusDTO {
@NotNull(message = "id cannot be null")

2
snail-job-client/snail-job-client-retry-core/src/main/java/com/aizuda/snailjob/client/core/intercepter/RetrySiteSnapshot.java
View File

@ -59,7 +59,7 @@ public class RetrySiteSnapshot {
private static final RetrySiteSnapshotContext<Long> ENTRY_METHOD_TIME = SnailRetrySpiLoader.loadRetrySiteSnapshotContext();
public static void suspend() {
SUSPEND.set(new HashMap<>(){{
SUSPEND.set(new HashMap<String, Object>(){{
put(RETRY_STAGE_KEY, RETRY_STAGE.get());
put(RETRY_STATUS_KEY, RETRY_STATUS.get());
put(RETRY_CLASS_METHOD_ENTRANCE_KEY, RETRY_CLASS_METHOD_ENTRANCE.get());

2
snail-job-client/snail-job-client-retry-core/src/main/java/com/aizuda/snailjob/client/core/strategy/RemoteRetryStrategies.java
View File

@ -86,7 +86,7 @@ public class RemoteRetryStrategies extends AbstractRetryStrategies {
@Override
protected RetryExecutorParameter<WaitStrategy, StopStrategy> getRetryExecutorParameter(RetryerInfo retryerInfo) {
return new RetryExecutorParameter<>() {
return new RetryExecutorParameter<WaitStrategy, StopStrategy>() {
@Override
public WaitStrategy backOff() {