AggregatorSchemaMount implements GlobalRequestProcessor { @Override public String processRequest(NetconfClientInfo clientInfo, String netconfRequest) throws DispatchException { Document document = AggregatorMessage.stringToDocument(netconfRequest); return processSchemaMountRequest(document); } private  AggregatorSchemaMount();  AggregatorSchemaMount(Aggregator aggregator); void init(); void destroy(); @Override String processRequest(NetconfClientInfo clientInfo, String netconfRequest);  }
@Test public void processRequest() throws Exception { m_aggregator = new AggregatorImpl(); m_clientInfo = new NetconfClientInfo("UT", 1); AggregatorSchemaMount aggregatorSchemaMount = new AggregatorSchemaMount(m_aggregator); aggregatorSchemaMount.init(); String response = aggregatorSchemaMount.processRequest(m_clientInfo, TEST_REQUEST); assertTrue(response.contains(NetworkManagerRpc.NAMESPACE)); assertTrue(response.contains("root")); }