import org.opendaylight.controller.config.yang.md.sal.rest.connector.Rpcs;
import org.opendaylight.controller.md.sal.dom.api.DOMDataBroker;
import org.opendaylight.controller.md.sal.dom.api.DOMMountPointService;
-import org.opendaylight.controller.md.sal.dom.broker.impl.DOMRpcRouter;
+import org.opendaylight.controller.md.sal.dom.api.DOMRpcService;
import org.opendaylight.controller.sal.core.api.Broker.ProviderSession;
import org.opendaylight.controller.sal.core.api.Provider;
import org.opendaylight.controller.sal.core.api.model.SchemaService;
private final StatisticsRestconfServiceWrapper stats = StatisticsRestconfServiceWrapper.getInstance();
private ListenerRegistration<SchemaContextListener> listenerRegistration;
- private ListenerRegistration<SchemaContextListener> rpcRouterSchemalistenerRegistration;
private PortNumber port;
private Thread webSocketServerThread;
BrokerFacade.getInstance().setContext(session);
BrokerFacade.getInstance().setDomDataBroker( domDataBroker);
-
- final DOMRpcRouter rpcRouter = new DOMRpcRouter();
-
final SchemaService schemaService = session.getService(SchemaService.class);
listenerRegistration = schemaService.registerSchemaContextListener(ControllerContext.getInstance());
- rpcRouterSchemalistenerRegistration = schemaService.registerSchemaContextListener(rpcRouter);
- BrokerFacade.getInstance().setRpcService(rpcRouter);
+ BrokerFacade.getInstance().setRpcService(session.getService(DOMRpcService.class));
ControllerContext.getInstance().setSchemas(schemaService.getGlobalContext());
@Override
public void close() {
- if (rpcRouterSchemalistenerRegistration != null) {
- rpcRouterSchemalistenerRegistration.close();
- }
-
if (listenerRegistration != null) {
listenerRegistration.close();
}