Skip to content

M
mall-server
Commit 24d53c4f authored by wulixian's avatar wulixian
Browse files
Options

Merge branch 'dev' into 'test'

重试时间加长为20s See merge request !14
parents 2f1a8a3a 5e3fa076
Show 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 @ 24d53c4f
...@@ -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 @ 24d53c4f
...@@ -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