mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta/WillMsgClient.java [78:84]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                setCategory(CATEGORY_WILL_MSG).
                build();

        metaRpcClient.getCliClientService().getRpcClient().invokeAsync(metaRpcClient.getLeader(groupId).getEndpoint(), request, (result, err) -> {
            if (err == null) {
                Response rsp = (Response) result;
                if (!rsp.getSuccess()) {
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta/WillMsgClient.java [160:166]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                setCategory(CATEGORY_WILL_MSG).
                build();

        metaRpcClient.getCliClientService().getRpcClient().invokeAsync(metaRpcClient.getLeader(groupId).getEndpoint(), request, (result, err) -> {
            if (err == null) {
                Response rsp = (Response) result;
                if (!rsp.getSuccess()) {
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -