From 356b3cc5a82f533cf9941928a85399b8a43eebf6 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: Fri, 19 May 2023 18:15:54 +0800
Subject: [PATCH] =?UTF-8?q?=E9=80=9A=E7=9F=A5=E6=8A=A5=E8=AD=A6?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/mashibing/Hippo4jClientStarterApp.java    |  2 --
 .../config/RabbitMQThreadPoolConfig.java          |  4 +++-
 .../com/mashibing/controller/TestController.java  | 15 +++++++++++++++
 src/main/java/com/mashibing/mq/TestListener.java  |  1 +
 src/main/resources/application.yml                |  2 +-
 5 files changed, 20 insertions(+), 4 deletions(-)

diff --git a/src/main/java/com/mashibing/Hippo4jClientStarterApp.java b/src/main/java/com/mashibing/Hippo4jClientStarterApp.java
index 5606697..fb49b26 100644
--- a/src/main/java/com/mashibing/Hippo4jClientStarterApp.java
+++ b/src/main/java/com/mashibing/Hippo4jClientStarterApp.java
@@ -11,9 +11,7 @@ import org.springframework.boot.autoconfigure.SpringBootApplication;
 @SpringBootApplication
 @EnableDynamicThreadPool
 public class Hippo4jClientStarterApp {
-
     public static void main(String[] args) {
         SpringApplication.run(Hippo4jClientStarterApp.class,args);
     }
-
 }
diff --git a/src/main/java/com/mashibing/config/RabbitMQThreadPoolConfig.java b/src/main/java/com/mashibing/config/RabbitMQThreadPoolConfig.java
index d714cf0..c43bda1 100644
--- a/src/main/java/com/mashibing/config/RabbitMQThreadPoolConfig.java
+++ b/src/main/java/com/mashibing/config/RabbitMQThreadPoolConfig.java
@@ -35,10 +35,12 @@ public class RabbitMQThreadPoolConfig {
      * @return
      */
     @Bean
-    public AbstractRabbitListenerContainerFactory<?> defaultContainerFactory(ThreadPoolTaskExecutor rabbitThreadPool,AbstractConnectionFactory connectionFactory){
+    public AbstractRabbitListenerContainerFactory<?> defaultContainerFactory(ThreadPoolTaskExecutor rabbitThreadPool,
+                                                                             AbstractConnectionFactory connectionFactory){
         DirectRabbitListenerContainerFactory factory = new DirectRabbitListenerContainerFactory();
         factory.setConnectionFactory(connectionFactory);
         connectionFactory.setExecutor(rabbitThreadPool);
         return factory;
     }
+
 }
diff --git a/src/main/java/com/mashibing/controller/TestController.java b/src/main/java/com/mashibing/controller/TestController.java
index 8dddd16..cf409bf 100644
--- a/src/main/java/com/mashibing/controller/TestController.java
+++ b/src/main/java/com/mashibing/controller/TestController.java
@@ -13,6 +13,7 @@ import java.util.concurrent.ThreadPoolExecutor;
 @RestController
 public class TestController {
 
+
     @Resource
     private ThreadPoolExecutor testThreadPool;
 
@@ -28,4 +29,18 @@ public class TestController {
         return "ok";
     }
 
+    @GetMapping("/alarm")
+    public String alarm() {
+        testThreadPool.execute(() -> {
+            System.out.println("start");
+            try {
+                Thread.sleep(2000);
+            } catch (InterruptedException e) {
+                e.printStackTrace();
+            }
+            System.out.println("end");
+        });
+        return "ok!";
+    }
+
 }
diff --git a/src/main/java/com/mashibing/mq/TestListener.java b/src/main/java/com/mashibing/mq/TestListener.java
index af86d51..6fe3087 100644
--- a/src/main/java/com/mashibing/mq/TestListener.java
+++ b/src/main/java/com/mashibing/mq/TestListener.java
@@ -1,5 +1,6 @@
 package com.mashibing.mq;
 
+import com.mashibing.controller.TestController;
 import org.springframework.amqp.rabbit.annotation.RabbitListener;
 import org.springframework.stereotype.Component;
 
diff --git a/src/main/resources/application.yml b/src/main/resources/application.yml
index fd134f8..ea5d2df 100644
--- a/src/main/resources/application.yml
+++ b/src/main/resources/application.yml
@@ -1,6 +1,6 @@
 spring:
   profiles:
-    active:
+    active: dev
   application:
     name: hippo4j-client
   dynamic: