|
|
@@ -3,8 +3,8 @@ package com.bex.staking.mq;
|
|
|
import com.bex.staking.constant.StakingConstants;
|
|
|
import com.bex.staking.entity.StakingAssetEvent;
|
|
|
import com.bex.staking.enums.AssetEventStatus;
|
|
|
-import com.fasterxml.jackson.core.JsonProcessingException;
|
|
|
-import com.fasterxml.jackson.databind.ObjectMapper;
|
|
|
+import tools.jackson.core.JacksonException;
|
|
|
+import tools.jackson.databind.ObjectMapper;
|
|
|
import java.util.List;
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
import org.apache.rocketmq.client.producer.SendResult;
|
|
|
@@ -108,7 +108,7 @@ public class AssetEventProducerImpl implements AssetEventProducer {
|
|
|
String payload;
|
|
|
try {
|
|
|
payload = objectMapper.writeValueAsString(AssetEventMessage.from(event));
|
|
|
- } catch (JsonProcessingException e) {
|
|
|
+ } catch (JacksonException e) {
|
|
|
// 序列化失败:保留 PENDING 待下次重发,不应发生(DTO 字段均为基本类型 / 字符串)
|
|
|
log.error("资产事件派发:消息体序列化失败, eventNo={}", event.getEventNo(), e);
|
|
|
return false;
|