websocket 整合

ruoyi-cai/src/main/java/com/ruoyi/cai/mq/CheckTimeOutMqConfig.java

@@ -4,6 +4,8 @@ import org.springframework.amqp.core.*;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 
+import java.util.HashMap;
+
 
 @Configuration
 public class CheckTimeOutMqConfig {
@@ -14,10 +16,13 @@ public class CheckTimeOutMqConfig {
 
     @Bean
     public CustomExchange delayedExchange() {
+        HashMap<String,Object> args = new HashMap<>();
+        args.put("x-delayed-type", "direct");
         return new CustomExchange(EXCHANGE_NAME,
                 "x-delayed-message", // 消息类型
                 true, // 是否持久化
-                false); // 是否自动删除
+                false,// 是否自动删除
+                args);
     }
 
     @Bean
@@ -29,7 +34,7 @@ public class CheckTimeOutMqConfig {
 
     @Bean
     public Binding delayedBinding(Queue delayedQueue,CustomExchange delayedExchange) {
-        return BindingBuilder.bind(delayedQueue).to(delayedExchange).with(ROUTING_KEY).noargs();
+        return BindingBuilder.bind(delayedQueue()).to(delayedExchange()).with(ROUTING_KEY).noargs();
     }
 
 }