From bd885c7015446c6c0495d3299ef64068a4c9b30e Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期三, 16 十月 2024 15:00:34 +0800
Subject: [PATCH] CMQ改造为rabbitmq
---
service-push/src/main/java/com/ks/push/PushApplication.java | 11 ++++++++---
1 files changed, 8 insertions(+), 3 deletions(-)
diff --git a/service-push/src/main/java/com/ks/push/PushApplication.java b/service-push/src/main/java/com/ks/push/PushApplication.java
index 1c667a0..a375f21 100644
--- a/service-push/src/main/java/com/ks/push/PushApplication.java
+++ b/service-push/src/main/java/com/ks/push/PushApplication.java
@@ -6,15 +6,15 @@
import org.slf4j.LoggerFactory;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
-import org.springframework.boot.builder.SpringApplicationBuilder;
-import org.springframework.boot.web.servlet.support.SpringBootServletInitializer;
+import org.springframework.context.ApplicationListener;
+import org.springframework.context.event.ContextRefreshedEvent;
import org.springframework.transaction.annotation.EnableTransactionManagement;
@SpringBootApplication
@EnableTransactionManagement
@MapperScan(basePackages = "com.ks.push.mapper")
@EnableDubbo(scanBasePackages = "com.ks.push.service.remote")
-public class PushApplication {
+public class PushApplication implements ApplicationListener<ContextRefreshedEvent> {
private final static Logger logger = LoggerFactory.getLogger(PushApplication.class);
public static void main(String[] args) {
@@ -22,4 +22,9 @@
logger.info("搴旂敤鍚姩鎴愬姛");
}
+
+ @Override
+ public void onApplicationEvent(ContextRefreshedEvent contextRefreshedEvent) {
+ logger.info("瀹瑰櫒鍔犺浇瀹屾瘯");
+ }
}
--
Gitblit v1.8.0