return this.yangRibId;
}
- @Override
- public TransactionChain createPeerChain(final TransactionChainListener listener) {
- return this.dataBroker.createMergingTransactionChain(listener);
- }
-
@Override
public DOMTransactionChain createPeerDOMChain(final DOMTransactionChainListener listener) {
return this.domDataBroker.createMergingTransactionChain(listener);
import java.util.Set;
import java.util.stream.Collectors;
import org.opendaylight.mdsal.binding.api.DataBroker;
-import org.opendaylight.mdsal.binding.api.TransactionChain;
-import org.opendaylight.mdsal.binding.api.TransactionChainListener;
import org.opendaylight.mdsal.common.api.CommitInfo;
import org.opendaylight.mdsal.dom.api.DOMDataBroker;
import org.opendaylight.mdsal.dom.api.DOMDataTreeChangeService;
return this.ribImpl.createPeerDOMChain(listener);
}
- @Override
- public TransactionChain createPeerChain(final TransactionChainListener listener) {
- return this.ribImpl.createPeerChain(listener);
- }
-
@Override
public RIBExtensionConsumerContext getRibExtensions() {
return this.ribImpl.getRibExtensions();
import java.util.Set;
import org.eclipse.jdt.annotation.NonNull;
import org.opendaylight.mdsal.binding.api.DataBroker;
-import org.opendaylight.mdsal.binding.api.TransactionChain;
-import org.opendaylight.mdsal.binding.api.TransactionChainListener;
import org.opendaylight.mdsal.dom.api.DOMDataTreeChangeService;
import org.opendaylight.mdsal.dom.api.DOMTransactionChain;
import org.opendaylight.mdsal.dom.api.DOMTransactionChainListener;
*/
DOMTransactionChain createPeerDOMChain(DOMTransactionChainListener listener);
- /**
- * Allocate a new transaction chain for use with a peer.
- *
- * @param listener {@link TransactionChainListener} handling recovery
- * @return A new transaction chain.
- */
- TransactionChain createPeerChain(TransactionChainListener listener);
-
/**
* Return the RIB extensions available to the RIB instance.
*
import static org.mockito.ArgumentMatchers.any;
import static org.mockito.ArgumentMatchers.anyInt;
import static org.mockito.ArgumentMatchers.eq;
-import static org.mockito.Mockito.doAnswer;
import static org.mockito.Mockito.doNothing;
import static org.mockito.Mockito.doReturn;
import static org.mockito.Mockito.mock;
import java.util.Collections;
import org.junit.Before;
import org.mockito.Mock;
-import org.opendaylight.mdsal.binding.api.TransactionChainListener;
import org.opendaylight.mdsal.common.api.CommitInfo;
import org.opendaylight.mdsal.common.api.LogicalDatastoreType;
import org.opendaylight.mdsal.dom.api.DOMDataTreeChangeService;
.params.xml.ns.yang.bgp.rib.rev180329.bgp.rib.Rib.class, new RibKey(RIB_ID))).when(this.rib)
.getInstanceIdentifier();
doReturn(this.domTx).when(this.rib).createPeerDOMChain(any(DOMTransactionChainListener.class));
- doAnswer(invocation -> {
- final Object[] args = invocation.getArguments();
- return getDataBroker().createTransactionChain((TransactionChainListener) args[0]);
- }).when(this.rib).createPeerChain(any(TransactionChainListener.class));
doReturn(getDataBroker()).when(this.rib).getDataBroker();
doReturn(AS).when(this.rib).getLocalAs();