提交 0bda4002 authored 作者: 艾庆国's avatar 艾庆国

车辆预警

上级 8fe636df
...@@ -4,7 +4,7 @@ import com.alibaba.fastjson.JSON; ...@@ -4,7 +4,7 @@ import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.TypeReference; import com.alibaba.fastjson.TypeReference;
import com.clx.performance.common.MqDelay; import com.clx.performance.common.MqDelay;
import com.clx.performance.common.MqWrapper; import com.clx.performance.common.MqWrapper;
import com.clx.performance.constant.RabbitKeySettlementConstants; import com.clx.performance.constant.RabbitKeyVehicleWarnConstants;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.core.Message; import org.springframework.amqp.core.Message;
import org.springframework.amqp.core.MessageBuilder; import org.springframework.amqp.core.MessageBuilder;
...@@ -25,7 +25,7 @@ public class VehicleWarnDelayListener { ...@@ -25,7 +25,7 @@ public class VehicleWarnDelayListener {
@Autowired @Autowired
private RabbitTemplate rabbitTemplate; private RabbitTemplate rabbitTemplate;
@RabbitListener(queues = RabbitKeySettlementConstants.DEFAULT_DEAD_QUEUE) @RabbitListener(queues = RabbitKeyVehicleWarnConstants.DEFAULT_DEAD_QUEUE)
public void process(Message message) { public void process(Message message) {
try{ try{
log.info("车辆预警-延迟, message:{}", message); log.info("车辆预警-延迟, message:{}", message);
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论