eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/processor/AbstractPublishBatchCloudEventProcessor.java [87:102]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public StatusCode aclCheck(CloudEvent cloudEvent) {
        try {
            if (eventMeshGrpcServer.getEventMeshGrpcConfiguration().isEventMeshServerSecurityEnable()) {
                String remoteAdd = EventMeshCloudEventUtils.getIp(cloudEvent);
                String user = EventMeshCloudEventUtils.getUserName(cloudEvent);
                String pass = EventMeshCloudEventUtils.getPassword(cloudEvent);
                String subsystem = EventMeshCloudEventUtils.getSys(cloudEvent);
                String topic = EventMeshCloudEventUtils.getSubject(cloudEvent);
                this.acl.doAclCheckInHttpSend(remoteAdd, user, pass, subsystem, topic, RequestCode.MSG_SEND_ASYNC.getRequestCode());
            }
        } catch (AclException e) {
            aclLogger.warn("Client has no permission,AbstructPublishCloudEventProcessor send failed", e);
            return StatusCode.EVENTMESH_ACL_ERR;
        }
        return StatusCode.SUCCESS;
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/processor/AbstractPublishCloudEventProcessor.java [86:101]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public StatusCode aclCheck(CloudEvent cloudEvent) {
        try {
            if (eventMeshGrpcServer.getEventMeshGrpcConfiguration().isEventMeshServerSecurityEnable()) {
                String remoteAdd = EventMeshCloudEventUtils.getIp(cloudEvent);
                String user = EventMeshCloudEventUtils.getUserName(cloudEvent);
                String pass = EventMeshCloudEventUtils.getPassword(cloudEvent);
                String subsystem = EventMeshCloudEventUtils.getSys(cloudEvent);
                String topic = EventMeshCloudEventUtils.getSubject(cloudEvent);
                this.acl.doAclCheckInHttpSend(remoteAdd, user, pass, subsystem, topic, RequestCode.MSG_SEND_ASYNC.getRequestCode());
            }
        } catch (AclException e) {
            aclLogger.warn("Client has no permission,AbstructPublishCloudEventProcessor send failed", e);
            return StatusCode.EVENTMESH_ACL_ERR;
        }
        return StatusCode.SUCCESS;
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -