Просмотр исходного кода

[修改][结算单][修改跳点率计算]

release_toaliyun_real
luozukai 6 лет назад
Родитель
Сommit
c5f11c66a2
2 измененных файлов: 14 добавлений и 14 удалений
  1. +1
    -1
      mallinkService/src/main/java/com/iformall/mq/MqBaseProducer.java
  2. +13
    -13
      mallinkService/src/main/java/com/iformall/mq/impl/RabbitMqMessageProducer.java

+ 1
- 1
mallinkService/src/main/java/com/iformall/mq/MqBaseProducer.java Просмотреть файл

@@ -3,7 +3,7 @@ package com.iformall.mq;
import com.iformall.domain.po.msg.BaseMsg;
import org.springframework.amqp.rabbit.core.RabbitTemplate;

public interface MqBaseProducer extends RabbitTemplate.ConfirmCallback{
public interface MqBaseProducer {

void sendMessage(BaseMsg record, String topic, String tags, String keys);
}

+ 13
- 13
mallinkService/src/main/java/com/iformall/mq/impl/RabbitMqMessageProducer.java Просмотреть файл

@@ -30,17 +30,17 @@ public class RabbitMqMessageProducer implements MqBaseProducer {
private WxMsgRecordMapper wxMsgRecordMapper;
@Autowired
private WxMsgRecordService wxMsgRecordService;
@Override
public void confirm(CorrelationData correlationData, boolean b, String s) {
log.info("------correlationData"+correlationData.toString());
System.out.println();
if(b){
System.out.println();
}else{
}
}
//
// @Override
// public void confirm(CorrelationData correlationData, boolean b, String s) {
// log.info("------correlationData"+correlationData.toString());
// System.out.println();
// if(b){
// System.out.println();
// }else{
//
// }
// }

@Override
public void sendMessage(BaseMsg data, String topic, String tags, String keys) {
@@ -48,8 +48,8 @@ public class RabbitMqMessageProducer implements MqBaseProducer {
data.setUuid(UUID.randomUUID().toString());
wxMsgRecordService.save(data);

CorrelationData correlationData = new CorrelationData("16746324");
rabbitTemplate.convertAndSend(topic, JsonUtil.obj2Json(data),correlationData);
//CorrelationData correlationData = new CorrelationData("16746324");
rabbitTemplate.convertAndSend(topic, JsonUtil.obj2Json(data));

// data.setMsgStatus(EnumMsgRecordStatus.SEND_SUCC.getCode());
// wxMsgRecordMapper.update(data);


Загрузка…
Отмена
Сохранить