private EventType checkType(Record response) {
if (response == null) {
return EventType.other;
} else if (response instanceof ConnectRequest) {
return EventType.write;
} else if (response instanceof CreateRequest) {
return EventType.write;
} else if (response instanceof DeleteRequest) {
return EventType.write;
} else if (response instanceof SetDataRequest) {
return EventType.write;
} else if (response instanceof SetACLRequest) {
return EventType.write;
} else if (response instanceof SetMaxChildrenRequest) {
return EventType.write;
} else if (response instanceof SetSASLRequest) {
return EventType.write;
} else if (response instanceof SetWatches) {
return EventType.write;
} else if (response instanceof SyncRequest) {
return EventType.write;
} else if (response instanceof ExistsRequest) {
return EventType.read;
} else if (response instanceof GetDataRequest) {
return EventType.read;
} else if (response instanceof GetMaxChildrenRequest) {
return EventType.read;
} else if (response instanceof GetACLRequest) {
return EventType.read;
} else if (response instanceof GetChildrenRequest) {
return EventType.read;
} else if (response instanceof GetChildren2Request) {
return EventType.read;
} else if (response instanceof GetSASLRequest) {
return EventType.read;
} else {
return EventType.other;
}
}
ClientCnxnAspect.java 文件源码
java
阅读 39
收藏 0
点赞 0
评论 0
项目:incubator-pulsar
作者:
评论列表
文章目录