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: