2.7.18

shikeyin

2024-01-11 65da8373531677b1c37a98f53eaa30c892f35e5a

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
package com.iplatform.tcp.lb;
 
import com.walker.push.rocketmq.tcp.MqResponse;
 
import java.util.Map;
 
public class MqResponseUtils {
 
    public static final MqResponse acquireMqResponse(Map<String, Object> map){
        int retryTimes = Integer.parseInt(map.get("retryTimes").toString());
        MqResponse mqResponse = new MqResponse();
        mqResponse.setRetryTimes(retryTimes);
        mqResponse.setKey(map.get("key").toString());
        mqResponse.setSource(map.get("source").toString());
        mqResponse.setTopic(map.get("topic") != null? map.get("topic").toString() : "");
        return mqResponse;
    }
}