| | |
| | | package com.iailab.module.shasteel.mq.consumer; |
| | | |
| | | import com.alibaba.fastjson.JSON; |
| | | import com.alibaba.fastjson.JSONObject; |
| | | import com.iailab.framework.common.util.date.DateUtils; |
| | | import com.iailab.module.model.api.mcs.McsApi; |
| | |
| | | import org.springframework.util.CollectionUtils; |
| | | |
| | | import javax.annotation.Resource; |
| | | import java.util.HashMap; |
| | | import java.util.List; |
| | | import java.util.Map; |
| | | import java.util.UUID; |
| | |
| | | @Component |
| | | public class ModelPredictFinish2Consumer { |
| | | |
| | | |
| | | @Resource |
| | | private McsApi mcsApi; |
| | | |
| | |
| | | * |
| | | * @param message |
| | | */ |
| | | @RabbitListener(queues = QueuePredictFinishConfig.QUEUE_NAME) |
| | | @RabbitListener(queues = QueuePredictFinishConfig.QUEUE_NAME2) |
| | | public void listen(Message message) { |
| | | String routingKey = message.getMessageProperties().getReceivedRoutingKey(); |
| | | log.info("routingKey:" + routingKey); |