X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-distributed-datastore%2Fsrc%2Ftest%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fdatastore%2FFrontendReadWriteTransactionTest.java;fp=opendaylight%2Fmd-sal%2Fsal-distributed-datastore%2Fsrc%2Ftest%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fdatastore%2FFrontendReadWriteTransactionTest.java;h=847b24b92ebe8fbf79fa55dbbc58eea2b8fba2f3;hp=c3c62067d2863e0046dbc49687db14376fed8711;hb=731e7284cf0895fdb1b89427f91762e80e67c2ff;hpb=39f938a071f0955c0eec12bfcb200889a6aa695a

diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/FrontendReadWriteTransactionTest.java b/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/FrontendReadWriteTransactionTest.java
index c3c62067d2..847b24b92e 100644
--- a/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/FrontendReadWriteTransactionTest.java
+++ b/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/FrontendReadWriteTransactionTest.java
@@ -10,6 +10,7 @@ package org.opendaylight.controller.cluster.datastore;
 import static org.junit.Assert.assertNotNull;
 import static org.junit.Assert.assertNull;
 import static org.mockito.Matchers.any;
+import static org.mockito.Matchers.eq;
 import static org.mockito.Matchers.same;
 import static org.mockito.Mockito.mock;
 import static org.mockito.Mockito.verify;
@@ -17,6 +18,7 @@ import static org.mockito.Mockito.verifyNoMoreInteractions;
 import static org.mockito.Mockito.when;
 
 import akka.actor.ActorRef;
+import java.util.Optional;
 import org.junit.Before;
 import org.junit.Test;
 import org.opendaylight.controller.cluster.access.commands.ModifyTransactionRequestBuilder;
@@ -59,7 +61,7 @@ public class FrontendReadWriteTransactionTest {
         shardTransaction = new ReadWriteShardDataTreeTransaction(mockParent, TX_ID, mockModification);
         openTx = FrontendReadWriteTransaction.createOpen(mockHistory, shardTransaction);
 
-        when(mockParent.finishTransaction(same(shardTransaction))).thenReturn(mockCohort);
+        when(mockParent.finishTransaction(same(shardTransaction), eq(Optional.empty()))).thenReturn(mockCohort);
     }
 
     private TransactionSuccess<?> handleRequest(final TransactionRequest<?> request) throws RequestException {
@@ -87,7 +89,7 @@ public class FrontendReadWriteTransactionTest {
         final TransactionRequest<?> readyReq = b.build();
 
         assertNotNull(handleRequest(readyReq));
-        verify(mockParent).finishTransaction(same(shardTransaction));
+        verify(mockParent).finishTransaction(same(shardTransaction), eq(Optional.empty()));
 
         assertNotNull(handleRequest(readyReq));
         verifyNoMoreInteractions(mockParent);
@@ -101,7 +103,7 @@ public class FrontendReadWriteTransactionTest {
         final TransactionRequest<?> readyReq = b.build();
 
         assertNull(handleRequest(readyReq));
-        verify(mockParent).finishTransaction(same(shardTransaction));
+        verify(mockParent).finishTransaction(same(shardTransaction), eq(Optional.empty()));
 
         assertNull(handleRequest(readyReq));
         verifyNoMoreInteractions(mockParent);
@@ -115,7 +117,7 @@ public class FrontendReadWriteTransactionTest {
         final TransactionRequest<?> readyReq = b.build();
 
         assertNull(handleRequest(readyReq));
-        verify(mockParent).finishTransaction(same(shardTransaction));
+        verify(mockParent).finishTransaction(same(shardTransaction), eq(Optional.empty()));
 
         assertNull(handleRequest(readyReq));
         verifyNoMoreInteractions(mockParent);
@@ -129,7 +131,7 @@ public class FrontendReadWriteTransactionTest {
         final TransactionRequest<?> readyReq = b.build();
 
         assertNotNull(handleRequest(readyReq));
-        verify(mockParent).finishTransaction(same(shardTransaction));
+        verify(mockParent).finishTransaction(same(shardTransaction), eq(Optional.empty()));
 
         handleRequest(new ReadTransactionRequest(TX_ID, 0, mock(ActorRef.class), YangInstanceIdentifier.EMPTY, true));
     }
@@ -142,7 +144,7 @@ public class FrontendReadWriteTransactionTest {
         final TransactionRequest<?> readyReq = b.build();
 
         assertNotNull(handleRequest(readyReq));
-        verify(mockParent).finishTransaction(same(shardTransaction));
+        verify(mockParent).finishTransaction(same(shardTransaction), eq(Optional.empty()));
 
         b.setSequence(1);
         b.addModification(mock(TransactionModification.class));