Commit 2b226efb authored by unset's avatar unset

会员分成记录信息

parent cbef3cd9
...@@ -31,6 +31,7 @@ public class MemberShareMQHandler { ...@@ -31,6 +31,7 @@ public class MemberShareMQHandler {
@RabbitListener(queues = MEMBER_SHARE_QUEUE) @RabbitListener(queues = MEMBER_SHARE_QUEUE)
public void integralHandler(Message message, @Headers Map<String, Object> headers, Channel channel) { public void integralHandler(Message message, @Headers Map<String, Object> headers, Channel channel) {
try { try {
Thread.sleep(2000);
String msg = new String(message.getBody(), "UTF-8"); String msg = new String(message.getBody(), "UTF-8");
log.info("接收到的消息-----msg===="+msg); log.info("接收到的消息-----msg===="+msg);
OrderMemberDetail orderMemberDetail = JSONUtil.toBean(msg, OrderMemberDetail.class); OrderMemberDetail orderMemberDetail = JSONUtil.toBean(msg, OrderMemberDetail.class);
......
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