### Question:
NodeRequestProcessor extends RpcRequestProcessor<T> { protected abstract String getGroupId(final T request); NodeRequestProcessor(Executor executor, Message defaultResp); @Override Message processRequest(final T request, final RpcRequestClosure done);  }### Answer:
@Test public void testOK() { Node node = Mockito.mock(Node.class, withSettings().extraInterfaces(RaftServerService.class)); Mockito.when(node.getGroupId()).thenReturn("test"); PeerId peerId = new PeerId("localhost", 8081); Mockito.when(node.getNodeId()).thenReturn(new NodeId("test", peerId)); NodeManager.getInstance().addAddress(peerId.getEndpoint()); NodeManager.getInstance().add(node); this.processor.handleRequest(asyncContext, TestUtils.createPingRequest()); ErrorResponse resp = (ErrorResponse) asyncContext.getResponseObject(); assertNotNull(resp); assertEquals(0, resp.getErrorCode()); }