From ed884333b631a2c5b6689fc935d619f2705df9dd Mon Sep 17 00:00:00 2001 From: byteblogs168 <598092184@qq.com> Date: Sun, 17 Mar 2024 21:42:35 +0800 Subject: [PATCH] =?UTF-8?q?pom:=203.1.1=20=E5=8D=87=E7=BA=A7=E7=89=88?= =?UTF-8?q?=E6=9C=AC?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- pom.xml | 6 +++--- .../EasyRetryChannelReconnectListener.java | 19 ++++++++++++++++++ .../listener/EasyRetryClosedListener.java | 20 +++++++++++++++++++ .../listener/EasyRetryClosingListener.java | 20 +++++++++++++++++++ .../listener/EasyRetryStartedListener.java | 20 +++++++++++++++++++ .../listener/EasyRetryStartingListener.java | 20 +++++++++++++++++++ 6 files changed, 102 insertions(+), 3 deletions(-) create mode 100644 src/main/java/com/example/easy/retry/listener/EasyRetryChannelReconnectListener.java create mode 100644 src/main/java/com/example/easy/retry/listener/EasyRetryClosedListener.java create mode 100644 src/main/java/com/example/easy/retry/listener/EasyRetryClosingListener.java create mode 100644 src/main/java/com/example/easy/retry/listener/EasyRetryStartedListener.java create mode 100644 src/main/java/com/example/easy/retry/listener/EasyRetryStartingListener.java 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启动事件"); + } +}