13693261870
2022-09-20 a666b5f9741ef9b21f547d3b2141752a0383c70c
src/java/org/apereo/cas/web/landtool/rabbitmq/RadarRabbitMqTemplate.java
ÎļþÃû´Ó src/java/org/apereo/cas/web/landtool/rabbitmq/RadarRabbitMQTemplate.java ÐÞ¸Ä
@@ -2,7 +2,7 @@
import javax.annotation.PostConstruct;
import org.apereo.cas.web.landtool.rabbitmq.config.RabbitMQProperties;
import org.apereo.cas.web.landtool.rabbitmq.config.RabbitMqProperties;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.amqp.core.Message;
@@ -17,13 +17,13 @@
 *   2019-07-05
 */
@Component
public class RadarRabbitMQTemplate implements RabbitTemplate.ConfirmCallback, ReturnCallback{
   private static final Logger LOGGER = LoggerFactory.getLogger(RadarRabbitMQTemplate.class);
public class RadarRabbitMqTemplate implements RabbitTemplate.ConfirmCallback, ReturnCallback{
   private static final Logger LOGGER = LoggerFactory.getLogger(RadarRabbitMqTemplate.class);
   
   @Autowired
    private RabbitTemplate rabbitTemplate;
   @Autowired
   private RabbitMQProperties sysConfig;
   private RabbitMqProperties sysConfig;
   
   @PostConstruct
    public void init() {
@@ -47,12 +47,21 @@
        
    }
    //发送消息,不需要实现任何接口,供外部调用。
    /**
     * å‘送消息,不需要实现任何接口,供外部调用。
     * @param routingKey
     * @param msg
     */
    public void send(String routingKey,String msg){
        rabbitTemplate.convertAndSend(sysConfig.getRmqExchangeName(),routingKey,msg);
    }
    
    //发送消息,不需要实现任何接口,供外部调用。
    /**
     * å‘送消息,不需要实现任何接口,供外部调用。
     * @param exchangeName
     * @param routingKey
     * @param msg
     */
    public void send(String exchangeName,String routingKey,String msg){
        rabbitTemplate.convertAndSend(exchangeName, routingKey, msg);
    }