import static org.mockito.Matchers.same;
import static org.mockito.Mockito.doReturn;
import static org.mockito.Mockito.verify;
+
import akka.actor.ActorRef;
import akka.persistence.SaveSnapshotFailure;
import akka.persistence.SaveSnapshotSuccess;
public void testOnSaveSnapshotSuccess() {
long sequenceNumber = 100;
- sendMessageToSupport(new SaveSnapshotSuccess(new SnapshotMetadata("foo", sequenceNumber, 1234L)));
+ long timeStamp = 1234L;
+ sendMessageToSupport(new SaveSnapshotSuccess(new SnapshotMetadata("foo", sequenceNumber, timeStamp)));
- verify(mockSnapshotManager).commit(eq(sequenceNumber));
+ verify(mockSnapshotManager).commit(eq(sequenceNumber), eq(timeStamp));
}
@Test
sendMessageToSupport(RaftActorSnapshotMessageSupport.COMMIT_SNAPSHOT);
- verify(mockSnapshotManager).commit(eq(-1L));
+ verify(mockSnapshotManager).commit(eq(-1L), eq(-1L));
}
@Test