QueMessageHandler { public synchronized List<Notification> processRequest(NetconfClientInfo clientInfo, AbstractNetconfRequest request, ResponseChannel channel) { LOGGER.debug(String.format("processing incoming request %s from client %s on channel %s", request, clientInfo, channel)); RequestTask task = new RequestTask(clientInfo, request, channel, m_netconfServerMessageListener, m_netconfLogger); task.run(); LOGGER.debug(String.format("done processing incoming request %s from client %s on channel %s", request, clientInfo, channel)); return task.getNetconfConfigChangeNotifications(); } QueMessageHandler(NetconfServerMessageListener netconfServerMessageListener); synchronized List<Notification> processRequest(NetconfClientInfo clientInfo, AbstractNetconfRequest request,
                                                          ResponseChannel channel);  }
@Test public void testProcessRequest() { m_queMessageHandler.processRequest(m_clientInfo, m_closeSessionRequest, m_responseChannel); verify(m_netconfServerMessageListener).onCloseSession(eq(m_clientInfo), eq(m_closeSessionRequest), anyObject()); m_queMessageHandler.processRequest(m_clientInfo, m_getConfigRequest, m_responseChannel); verify(m_netconfServerMessageListener).onGetConfig(eq(m_clientInfo), eq(m_getConfigRequest), anyObject()); }