From a666b5f9741ef9b21f547d3b2141752a0383c70c Mon Sep 17 00:00:00 2001
From: 13693261870 <252740454@qq.com>
Date: 星期二, 20 九月 2022 17:07:38 +0800
Subject: [PATCH] 1、修改登录页面 2、修改阿里代码规范问题
---
src/java/org/apereo/cas/web/landtool/rabbitmq/config/RabbitConfig.java | 49 ++++++-------------------------------------------
1 files changed, 6 insertions(+), 43 deletions(-)
diff --git a/src/java/org/apereo/cas/web/landtool/rabbitmq/config/RabbitConfig.java b/src/java/org/apereo/cas/web/landtool/rabbitmq/config/RabbitConfig.java
index 68a56e7..852d279 100644
--- a/src/java/org/apereo/cas/web/landtool/rabbitmq/config/RabbitConfig.java
+++ b/src/java/org/apereo/cas/web/landtool/rabbitmq/config/RabbitConfig.java
@@ -1,12 +1,6 @@
package org.apereo.cas.web.landtool.rabbitmq.config;
-import org.springframework.amqp.core.Binding;
-import org.springframework.amqp.core.BindingBuilder;
-import org.springframework.amqp.core.Queue;
import org.springframework.amqp.core.TopicExchange;
-import org.springframework.amqp.rabbit.connection.CachingConnectionFactory;
-import org.springframework.amqp.rabbit.connection.ConnectionFactory;
-import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
@@ -18,45 +12,14 @@
@Configuration
public class RabbitConfig {
@Autowired
- private RabbitMQProperties rabbitConfig;
-
-// @Bean
-// public ConnectionFactory connectionFactory() {
-// CachingConnectionFactory connectionFactory = new CachingConnectionFactory();
-// connectionFactory.setAddresses("192.168.0.19:5672");
-// connectionFactory.setUsername("landtool");
-// connectionFactory.setPassword("lt");
-// connectionFactory.setVirtualHost("/radar");
-// connectionFactory.setPublisherConfirms(true);
-// return connectionFactory;
-// }
-//
-// @Bean
-// public RabbitTemplate rabbitTemplate() {
-// RabbitTemplate template = new RabbitTemplate(connectionFactory());
-// return template;
-// }
-
-// //澹版槑闃熷垪
-// @Bean
-// public Queue queueMessage() {
-// return new Queue("topic.message");
-// }
-
- //澹版槑浜や簰鍣�
+ private RabbitMqProperties rabbitConfig;
+
+ /**
+ * 澹版槑浜や簰鍣�
+ * @return
+ */
@Bean
TopicExchange topicExchange() {
return new TopicExchange(rabbitConfig.getRmqExchangeName(),false,false);
}
-
-// /**
-// * 灏嗛槦鍒梩opic.message涓巈xchange缁戝畾锛宐inding_key涓簍opic.message,灏辨槸瀹屽叏鍖归厤
-// * @param queueMessage
-// * @param exchange
-// * @return
-// */
-// @Bean
-// Binding bindingExchangeMessage(Queue queueMessage, TopicExchange exchange) {
-// return BindingBuilder.bind(queueMessage).to(exchange).with("topic.#");
-// }
}
--
Gitblit v1.9.3