dragon
/
dragon-car
5
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

增加业务1

master
冯凯 2023-12-07 08:55:55 +08:00
parent d6b59915be
commit 4a5d2a5746
1 changed files with 7 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
dragon-car-service/src/main/java/com/dragon/car/service/rabbit/ListenFaultCode.java
View File

@ -1,11 +1,13 @@
package com.dragon.car.service.rabbit; package com.dragon.car.service.rabbit;
import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.JSONObject;
import com.dragon.car.service.service.FaultService;
import com.rabbitmq.client.Channel; import com.rabbitmq.client.Channel;
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.annotation.Queue; import org.springframework.amqp.rabbit.annotation.Queue;
import org.springframework.amqp.rabbit.annotation.RabbitListener; import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
import java.io.IOException; import java.io.IOException;
@ -21,10 +23,14 @@ import java.util.HashMap;
@Log4j2 @Log4j2
public class ListenFaultCode { public class ListenFaultCode {
@Autowired
private FaultService faultService;
@RabbitListener(queuesToDeclare = {@Queue(value = "fault_Dqueue")}) @RabbitListener(queuesToDeclare = {@Queue(value = "fault_Dqueue")})
public void consumerSubscribe(String mesg, Message message, Channel channel) { public void consumerSubscribe(String mesg, Message message, Channel channel) {
log.info("收到消息【{}】", JSONObject.parseObject(mesg, HashMap.class)); HashMap hashMap = JSONObject.parseObject(mesg, HashMap.class);
log.info("收到消息【{}】", hashMap);
try { try {
faultService.insertFaultRecord(hashMap);
channel.basicAck(message.getMessageProperties().getDeliveryTag(), false); channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
} catch (IOException e) { } catch (IOException e) {
throw new RuntimeException(e); throw new RuntimeException(e);