3637383940414243444546
@Test public void testServerRPC() throws Exception { final EventLoop eventLoop = new EventLoop(); eventLoop.start(); RPCTestServer server = new RPCTestServer(); InetSocketAddress localAddress = new InetSocketAddress("localhost", 0);
104105106107108109110111112113114
e2.printStackTrace(); } try { final EventLoop outerEventLoop = new EventLoop(); outerEventLoop.start(); final ThreadPoolExecutor targetExecutor = (ThreadPoolExecutor) Executors.newCachedThreadPool(); final ThreadPoolExecutor sourceExecutor = (ThreadPoolExecutor) Executors.newCachedThreadPool(); outerEventLoop.queueAsyncCallback(new Callbacks.Callback() { @Override