diff --git a/pom.xml b/pom.xml
index 13cceb1..32fad28 100644
--- a/pom.xml
+++ b/pom.xml
@@ -38,17 +38,17 @@
com.aizuda
easy-retry-client-starter
- 3.1.0
+ 3.1.1
com.aizuda
easy-retry-client-core
- 3.1.0
+ 3.1.1
com.aizuda
easy-retry-client-job-core
- 3.1.0
+ 3.1.1
org.freemarker
diff --git a/src/main/java/com/example/easy/retry/listener/EasyRetryChannelReconnectListener.java b/src/main/java/com/example/easy/retry/listener/EasyRetryChannelReconnectListener.java
new file mode 100644
index 0000000..ac13845
--- /dev/null
+++ b/src/main/java/com/example/easy/retry/listener/EasyRetryChannelReconnectListener.java
@@ -0,0 +1,19 @@
+package com.example.easy.retry.listener;
+
+import com.aizuda.easy.retry.client.common.event.ChannelReconnectEvent;
+import com.aizuda.easy.retry.common.log.EasyRetryLog;
+import org.springframework.context.ApplicationListener;
+import org.springframework.stereotype.Component;
+
+/**
+ * @author xiaowoniu
+ * @date 2024-03-14 21:58:18
+ * @since 3.1.0
+ */
+@Component
+public class EasyRetryChannelReconnectListener implements ApplicationListener {
+ @Override
+ public void onApplicationEvent(ChannelReconnectEvent 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
new file mode 100644
index 0000000..b928744
--- /dev/null
+++ b/src/main/java/com/example/easy/retry/listener/EasyRetryClosedListener.java
@@ -0,0 +1,20 @@
+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.common.log.EasyRetryLog;
+import org.springframework.context.ApplicationListener;
+import org.springframework.stereotype.Component;
+
+/**
+ * @author xiaowoniu
+ * @date 2024-03-14 22:00:58
+ * @since 3.1.0
+ */
+@Component
+public class EasyRetryClosedListener implements ApplicationListener {
+ @Override
+ public void onApplicationEvent(EasyRetryClosedEvent 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
new file mode 100644
index 0000000..bfe361f
--- /dev/null
+++ b/src/main/java/com/example/easy/retry/listener/EasyRetryClosingListener.java
@@ -0,0 +1,20 @@
+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.common.log.EasyRetryLog;
+import org.springframework.context.ApplicationListener;
+import org.springframework.stereotype.Component;
+
+/**
+ * @author xiaowoniu
+ * @date 2024-03-14 22:00:58
+ * @since 3.1.0
+ */
+@Component
+public class EasyRetryClosingListener implements ApplicationListener {
+ @Override
+ public void onApplicationEvent(EasyRetryClosingEvent 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
new file mode 100644
index 0000000..174c922
--- /dev/null
+++ b/src/main/java/com/example/easy/retry/listener/EasyRetryStartedListener.java
@@ -0,0 +1,20 @@
+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.common.log.EasyRetryLog;
+import org.springframework.context.ApplicationListener;
+import org.springframework.stereotype.Component;
+
+/**
+ * @author xiaowoniu
+ * @date 2024-03-14 22:00:58
+ * @since 3.1.0
+ */
+@Component
+public class EasyRetryStartedListener implements ApplicationListener {
+ @Override
+ public void onApplicationEvent(EasyRetryStartedEvent 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
new file mode 100644
index 0000000..53b1cd9
--- /dev/null
+++ b/src/main/java/com/example/easy/retry/listener/EasyRetryStartingListener.java
@@ -0,0 +1,20 @@
+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.common.log.EasyRetryLog;
+import org.springframework.context.ApplicationListener;
+import org.springframework.stereotype.Component;
+
+/**
+ * @author xiaowoniu
+ * @date 2024-03-14 22:00:58
+ * @since 3.1.0
+ */
+@Component
+public class EasyRetryStartingListener implements ApplicationListener {
+ @Override
+ public void onApplicationEvent(EasyRetryStartingEvent event) {
+ EasyRetryLog.LOCAL.info("这是一个EasyRetry启动事件");
+ }
+}