(long roleId, @NotNull Protocol<?> p)
| 1054 | |
| 1055 | // 优先在上下文中的Online上发送 |
| 1056 | public void sendWhileCommit(long roleId, @NotNull Protocol<?> p) { |
| 1057 | if (p instanceof Rpc && p.isRequest()) |
| 1058 | throw new IllegalArgumentException(p.getClass().getName() + " is rpc. please use sendRpc/sendOnlineRpc"); |
| 1059 | Transaction.whileCommit(() -> send(roleId, p)); |
| 1060 | } |
| 1061 | |
| 1062 | // 在指定Online上发送 |
| 1063 | public void sendWhileCommitOnline(long roleId, @NotNull Protocol<?> p) { |
nothing calls this directly
no test coverage detected