Skip to content

O
order-group
Commit e4bd032b by 周晓航
Options

修改参数

parent 28823be8
Showing with 2 additions and 1 deletions
call-back-service/src/main/java/cn/freemud/amp/service/SendMQConfirmCallback.java
package cn.freemud.amp.service; package cn.freemud.amp.service;
import cn.freemud.amqp.FastJsonMessageConverter; import cn.freemud.amqp.FastJsonMessageConverter;
import com.alibaba.fastjson.JSON;
import lombok.extern.log4j.Log4j2; import lombok.extern.log4j.Log4j2;
import org.springframework.amqp.core.Message; import org.springframework.amqp.core.Message;
import org.springframework.amqp.rabbit.connection.ConnectionFactory; import org.springframework.amqp.rabbit.connection.ConnectionFactory;
...@@ -40,7 +41,7 @@ public class SendMQConfirmCallback { ...@@ -40,7 +41,7 @@ public class SendMQConfirmCallback {
public void convertAndSend(String exchange, String queueName, final Object object) { public void convertAndSend(String exchange, String queueName, final Object object) {
CorrelationData data = new CorrelationData(); CorrelationData data = new CorrelationData();
data.setId("fisherman_" + System.currentTimeMillis()); data.setId(JSON.toJSONString(data));
this.rabbitTemplate.convertAndSend(exchange, queueName, object, data); this.rabbitTemplate.convertAndSend(exchange, queueName, object, data);
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment