Skip to content

M
mall-server
Commit af17aa9d authored by wlx@33.cn's avatar wlx@33.cn
Browse files
Options

重试时间加长为20s

parent 7ed265e5
Hide whitespace changes
Inline Side-by-side
Showing with 8 additions and 2 deletions
mall-server-admin/src/main/java/com/fzm/mall/server/admin/mq/consumer/order_center/WithdrawConsumer.java
View file @ af17aa9d
...@@ -146,8 +146,11 @@ public class WithdrawConsumer { ...@@ -146,8 +146,11 @@ public class WithdrawConsumer {
String hash = getHash(tranDto); String hash = getHash(tranDto);
tranDto.setHash(hash); tranDto.setHash(hash);
} }
/**
* 重试时间加长为20s
*/
msgProducer.sendTTL(JSON.toJSONString(tranDto), QueueTTLTypeEnum.ORDER_REFUND_COINS_TTL, msgProducer.sendTTL(JSON.toJSONString(tranDto), QueueTTLTypeEnum.ORDER_REFUND_COINS_TTL,
5 * 1000); 20 * 1000);
} }
private String getHash(TranDto tranDto) { private String getHash(TranDto tranDto) {
......
mall-server-front/src/main/java/com/fzm/mall/server/front/mq/consumer/UserAssetTransferConsumer.java
View file @ af17aa9d
...@@ -170,8 +170,11 @@ public class UserAssetTransferConsumer { ...@@ -170,8 +170,11 @@ public class UserAssetTransferConsumer {
String hash = getHash(tranDto); String hash = getHash(tranDto);
tranDto.setHash(hash); tranDto.setHash(hash);
} }
/**
* 重试时间加长为20s
*/
msgProducer.sendTTL(JSON.toJSONString(tranDto), QueueTTLTypeEnum.MALL_USER_ASSET_TRANSFER_TTL, msgProducer.sendTTL(JSON.toJSONString(tranDto), QueueTTLTypeEnum.MALL_USER_ASSET_TRANSFER_TTL,
5 * 1000); 20 * 1000);
} }
private String getHash(TranDto tranDto) { private String getHash(TranDto tranDto) {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment