班级成绩图表分析

luohairen

2024-11-14 247cb86585a1d1894596ed18a6c93efecb992946

 src/main/java/com/ycl/jxkg/rabbitmq/product/Producer.java

@@ -34,11 +34,16 @@
        Message message = MessageBuilder.withBody(jsonMsg.getBytes()).andProperties(messageProperties).build();
        // 设置消息的关联数据，以便发送确认回调、未路由成功消息的处理
        MyCorrelationData msgCorrelationData = new MyCorrelationData(examId + "", RabbitMqMsgTypeEnum.EXAM);
        rabbitTemplate.convertAndSend("examExchange", "exam", message, msgCorrelationData);
        rabbitTemplate.convertAndSend("jxkgExchange", "exam", message, msgCorrelationData);
    }

    public void meetMsg(Integer examId, String jsonMsg, Long delayTime) {
        rabbitTemplate.convertAndSend("examExchange","meet", "你好，RabbitMQ");
    public void meetMsg(Integer meetId, String jsonMsg, Long delayTime) {
        MessageProperties messageProperties = new MessageProperties();
        messageProperties.setExpiration(delayTime + "");
        Message message = MessageBuilder.withBody(jsonMsg.getBytes()).andProperties(messageProperties).build();
        // 设置消息的关联数据，以便发送确认回调、未路由成功消息的处理
        MyCorrelationData msgCorrelationData = new MyCorrelationData(meetId + "", RabbitMqMsgTypeEnum.MEET);
        rabbitTemplate.convertAndSend("jxkgExchange", "meet", message, msgCorrelationData);
    }

}