diff --git a/pom.xml b/pom.xml
index f49c271..982c3fa 100644
--- a/pom.xml
+++ b/pom.xml
@@ -44,17 +44,17 @@
com.aizuda
easy-retry-client-starter
- 3.2.0
+ 3.3.0-SNAPSHOT
com.aizuda
easy-retry-client-core
- 3.2.0
+ 3.3.0-SNAPSHOT
com.aizuda
easy-retry-client-job-core
- 3.2.0
+ 3.3.0-SNAPSHOT
org.freemarker
diff --git a/src/main/java/com/example/easy/retry/job/TestWorkflowAnnoJobExecutor.java b/src/main/java/com/example/easy/retry/job/TestWorkflowAnnoJobExecutor.java
index 27384ae..73ac177 100644
--- a/src/main/java/com/example/easy/retry/job/TestWorkflowAnnoJobExecutor.java
+++ b/src/main/java/com/example/easy/retry/job/TestWorkflowAnnoJobExecutor.java
@@ -18,9 +18,9 @@ import org.springframework.stereotype.Component;
public class TestWorkflowAnnoJobExecutor {
public ExecuteResult jobExecute(JobArgs jobArgs) throws InterruptedException {
- for (int i = 0; i < 30; i++) {
- EasyRetryLog.REMOTE.info("任务执行开始. [{}]", i + "" + JsonUtil.toJsonString(jobArgs));
- }
+// for (int i = 0; i < 30; i++) {
+// EasyRetryLog.REMOTE.info("任务执行开始. [{}]", i + "" + JsonUtil.toJsonString(jobArgs));
+// }
FailOrderPo failOrderPo = new FailOrderPo();
failOrderPo.setOrderId("xiaowoniu");
return ExecuteResult.success(failOrderPo);
diff --git a/src/main/java/com/example/easy/retry/listener/EasyRetryChannelReconnectListener.java b/src/main/java/com/example/easy/retry/listener/EasyRetryChannelReconnectListener.java
index ac13845..ac1261e 100644
--- a/src/main/java/com/example/easy/retry/listener/EasyRetryChannelReconnectListener.java
+++ b/src/main/java/com/example/easy/retry/listener/EasyRetryChannelReconnectListener.java
@@ -1,6 +1,6 @@
package com.example.easy.retry.listener;
-import com.aizuda.easy.retry.client.common.event.ChannelReconnectEvent;
+import com.aizuda.easy.retry.client.common.event.SnailChannelReconnectEvent;
import com.aizuda.easy.retry.common.log.EasyRetryLog;
import org.springframework.context.ApplicationListener;
import org.springframework.stereotype.Component;
@@ -11,9 +11,9 @@ import org.springframework.stereotype.Component;
* @since 3.1.0
*/
@Component
-public class EasyRetryChannelReconnectListener implements ApplicationListener {
+public class EasyRetryChannelReconnectListener implements ApplicationListener {
@Override
- public void onApplicationEvent(ChannelReconnectEvent event) {
+ public void onApplicationEvent(SnailChannelReconnectEvent event) {
EasyRetryLog.LOCAL.info("这个一个重连事件");
}
}
diff --git a/src/main/java/com/example/easy/retry/listener/EasyRetryClosedListener.java b/src/main/java/com/example/easy/retry/listener/EasyRetryClosedListener.java
index b928744..8ba596e 100644
--- a/src/main/java/com/example/easy/retry/listener/EasyRetryClosedListener.java
+++ b/src/main/java/com/example/easy/retry/listener/EasyRetryClosedListener.java
@@ -1,7 +1,6 @@
package com.example.easy.retry.listener;
-import com.aizuda.easy.retry.client.common.event.EasyRetryClosedEvent;
-import com.aizuda.easy.retry.client.common.event.EasyRetryStartedEvent;
+import com.aizuda.easy.retry.client.common.event.SnailClientClosedEvent;
import com.aizuda.easy.retry.common.log.EasyRetryLog;
import org.springframework.context.ApplicationListener;
import org.springframework.stereotype.Component;
@@ -12,9 +11,9 @@ import org.springframework.stereotype.Component;
* @since 3.1.0
*/
@Component
-public class EasyRetryClosedListener implements ApplicationListener {
+public class EasyRetryClosedListener implements ApplicationListener {
@Override
- public void onApplicationEvent(EasyRetryClosedEvent event) {
+ public void onApplicationEvent(SnailClientClosedEvent event) {
EasyRetryLog.LOCAL.info("这是一个EasyRetry关闭完成事件");
}
}
diff --git a/src/main/java/com/example/easy/retry/listener/EasyRetryClosingListener.java b/src/main/java/com/example/easy/retry/listener/EasyRetryClosingListener.java
index bfe361f..f551d2a 100644
--- a/src/main/java/com/example/easy/retry/listener/EasyRetryClosingListener.java
+++ b/src/main/java/com/example/easy/retry/listener/EasyRetryClosingListener.java
@@ -1,7 +1,6 @@
package com.example.easy.retry.listener;
-import com.aizuda.easy.retry.client.common.event.EasyRetryClosingEvent;
-import com.aizuda.easy.retry.client.common.event.EasyRetryStartedEvent;
+import com.aizuda.easy.retry.client.common.event.SnailClientClosingEvent;
import com.aizuda.easy.retry.common.log.EasyRetryLog;
import org.springframework.context.ApplicationListener;
import org.springframework.stereotype.Component;
@@ -12,9 +11,9 @@ import org.springframework.stereotype.Component;
* @since 3.1.0
*/
@Component
-public class EasyRetryClosingListener implements ApplicationListener {
+public class EasyRetryClosingListener implements ApplicationListener {
@Override
- public void onApplicationEvent(EasyRetryClosingEvent event) {
+ public void onApplicationEvent(SnailClientClosingEvent event) {
EasyRetryLog.LOCAL.info("这是一个EasyRetry开始关闭事件");
}
}
diff --git a/src/main/java/com/example/easy/retry/listener/EasyRetryStartedListener.java b/src/main/java/com/example/easy/retry/listener/EasyRetryStartedListener.java
index 174c922..e91807a 100644
--- a/src/main/java/com/example/easy/retry/listener/EasyRetryStartedListener.java
+++ b/src/main/java/com/example/easy/retry/listener/EasyRetryStartedListener.java
@@ -1,7 +1,6 @@
package com.example.easy.retry.listener;
-import com.aizuda.easy.retry.client.common.event.EasyRetryStartedEvent;
-import com.aizuda.easy.retry.client.common.event.EasyRetryStartingEvent;
+import com.aizuda.easy.retry.client.common.event.SnailClientStartedEvent;
import com.aizuda.easy.retry.common.log.EasyRetryLog;
import org.springframework.context.ApplicationListener;
import org.springframework.stereotype.Component;
@@ -12,9 +11,9 @@ import org.springframework.stereotype.Component;
* @since 3.1.0
*/
@Component
-public class EasyRetryStartedListener implements ApplicationListener {
+public class EasyRetryStartedListener implements ApplicationListener {
@Override
- public void onApplicationEvent(EasyRetryStartedEvent event) {
+ public void onApplicationEvent(SnailClientStartedEvent event) {
EasyRetryLog.LOCAL.info("这是一个EasyRetry启动完成事件");
}
}
diff --git a/src/main/java/com/example/easy/retry/listener/EasyRetryStartingListener.java b/src/main/java/com/example/easy/retry/listener/EasyRetryStartingListener.java
index 53b1cd9..f2b504f 100644
--- a/src/main/java/com/example/easy/retry/listener/EasyRetryStartingListener.java
+++ b/src/main/java/com/example/easy/retry/listener/EasyRetryStartingListener.java
@@ -1,7 +1,6 @@
package com.example.easy.retry.listener;
-import com.aizuda.easy.retry.client.common.event.ChannelReconnectEvent;
-import com.aizuda.easy.retry.client.common.event.EasyRetryStartingEvent;
+import com.aizuda.easy.retry.client.common.event.SnailClientStartingEvent;
import com.aizuda.easy.retry.common.log.EasyRetryLog;
import org.springframework.context.ApplicationListener;
import org.springframework.stereotype.Component;
@@ -12,9 +11,9 @@ import org.springframework.stereotype.Component;
* @since 3.1.0
*/
@Component
-public class EasyRetryStartingListener implements ApplicationListener {
+public class EasyRetryStartingListener implements ApplicationListener {
@Override
- public void onApplicationEvent(EasyRetryStartingEvent event) {
+ public void onApplicationEvent(SnailClientStartingEvent event) {
EasyRetryLog.LOCAL.info("这是一个EasyRetry启动事件");
}
}
diff --git a/src/main/resources/application.yml b/src/main/resources/application.yml
index 0d881f9..2fe94c8 100644
--- a/src/main/resources/application.yml
+++ b/src/main/resources/application.yml
@@ -38,9 +38,9 @@ mybatis-plus:
logging:
config: classpath:logback-boot.xml
-easy-retry:
+snail-job:
server:
host: 127.0.0.1
port: 1788
namespace: 764d604ec6fc45f68cd92514c40e9e1a
- token: ER_cKqBTPzCsWA3VyuCfFoccmuIEGXjr5KT
+ token: ER_Wyz3dmsdbDOkDujOTSSoBjGQP1BMsVnj
diff --git a/src/main/resources/logback-boot.xml b/src/main/resources/logback-boot.xml
index 990914a..f32035a 100644
--- a/src/main/resources/logback-boot.xml
+++ b/src/main/resources/logback-boot.xml
@@ -78,8 +78,8 @@
-
-
+
+
@@ -88,6 +88,6 @@
-
+