import com.google.common.util.concurrent.FluentFuture;
import com.google.common.util.concurrent.ListenableFuture;
import org.eclipse.jdt.annotation.NonNull;
+import org.opendaylight.mdsal.binding.api.DataBroker;
import org.opendaylight.mdsal.common.api.CommitInfo;
import org.opendaylight.mdsal.common.api.LogicalDatastoreType;
import org.opendaylight.yangtools.yang.binding.DataObject;
requestProcessor.merge(store, path, data);
}
+ /*
+ * (non-Javadoc)
+ *
+ * @see org.opendaylight.transportpce.common.network.NetworkTransactionService#getDataBroker()
+ */
+ @Override
+ public DataBroker getDataBroker() {
+ return requestProcessor.getDataBroker();
+ }
+
}
import com.google.common.util.concurrent.ListenableFuture;
import java.util.Optional;
import org.eclipse.jdt.annotation.NonNull;
+import org.opendaylight.mdsal.binding.api.DataBroker;
import org.opendaylight.mdsal.common.api.CommitInfo;
import org.opendaylight.mdsal.common.api.LogicalDatastoreType;
import org.opendaylight.yangtools.yang.binding.DataObject;
FluentFuture<? extends @NonNull CommitInfo> commit();
void close();
+
+ /**
+ * the Databroker related to NetworkTransactionService.
+ * @return the Databroker related to NetworkTransactionService.
+ */
+ DataBroker getDataBroker();
}
rwTx = dataBroker.newReadWriteTransaction();
return rwTx;
}
+
+ /**
+ * Return the dataBroker related to RequestProcessor.
+ * @return the dataBroker
+ */
+ public DataBroker getDataBroker() {
+ return dataBroker;
+ }
}