*/
public void init() {
LOG.info("StubpceProvider Session Initiated");
- final StubpceImpl consumer = new StubpceImpl(notificationPublishService,dataBroker);
- rpcRegistration = rpcRegistry.addRpcImplementation(StubpceService.class, consumer);
+ final StubpceImpl consumer = new StubpceImpl(this.notificationPublishService,this.dataBroker);
+ this.rpcRegistration = this.rpcRegistry.addRpcImplementation(StubpceService.class, consumer);
}
/**
*/
public void close() {
LOG.info("StubpceProvider Closed");
- rpcRegistration.close();
- stubPcelistenerRegistration.close();
+ this.rpcRegistration.close();
}
}