班级成绩图表分析

luohairen

2024-11-14 247cb86585a1d1894596ed18a6c93efecb992946

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

@@ -34,7 +34,7 @@
        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 meetId, String jsonMsg, Long delayTime) {
@@ -43,7 +43,7 @@
        Message message = MessageBuilder.withBody(jsonMsg.getBytes()).andProperties(messageProperties).build();
        // 设置消息的关联数据，以便发送确认回调、未路由成功消息的处理
        MyCorrelationData msgCorrelationData = new MyCorrelationData(meetId + "", RabbitMqMsgTypeEnum.MEET);
        rabbitTemplate.convertAndSend("meetExchange", "meet", message, msgCorrelationData);
        rabbitTemplate.convertAndSend("jxkgExchange", "meet", message, msgCorrelationData);
    }

}