public synchronized void init() {
LOG.info("Initializing TopologyStatsProvider service.");
- this.transactionChain = this.dataBroker.createTransactionChain(this);
+ this.transactionChain = this.dataBroker.createMergingTransactionChain(this);
final TimerTask task = new TimerTask() {
@Override
public void run() {
if (!closed.get()) {
transactionChain.close();
- transactionChain = dataBroker.createTransactionChain(this);
+ transactionChain = dataBroker.createMergingTransactionChain(this);
}
}