| | |
|---|
| | | rabbitTemplate.convertAndSend("examExchange", "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("meetExchange", "meet", message, msgCorrelationData); |
|---|
| | | } |
|---|
| | | |
|---|
| | | } |
|---|
