环境信息
- EMQ X 版本:4.3.1
- 操作系统及版本:centos7
- 其他
问题描述
钩子代码:直接将返回值设置成 STOP_AND_RETURN
,但还是可以发布和订阅 topic
代码如下:
@Override
public void onClientCheckAcl(ClientCheckAclRequest request, StreamObserver<ValuedResponse> responseObserver) {
log.info("onClientCheckAcl:{}", gson.toJson(request));
ValuedResponse reply ;
log.info("没有权限onClientCheckAcl");
reply = ValuedResponse.newBuilder().setBoolResult(false).setType(ValuedResponse.ResponsedType.STOP_AND_RETURN).build();
responseObserver.onNext(reply);
responseObserver.onCompleted();
}
谢谢!