- final CaptureSnapshotReply reply = expectMsgClass(duration("3 seconds"), CaptureSnapshotReply.class);
- assertNotNull("getSnapshotState is null", reply.getSnapshotState());
- assertEquals("SnapshotState type", ShardSnapshotState.class, reply.getSnapshotState().getClass());
- assertEquals("Snapshot", snapshot, ((ShardSnapshotState)reply.getSnapshotState()).getSnapshot());
+ final CaptureSnapshotReply reply = kit.expectMsgClass(Duration.ofSeconds(3), CaptureSnapshotReply.class);
+ assertNotNull("getSnapshotState is null", reply.getSnapshotState());
+ assertEquals("SnapshotState type", ShardSnapshotState.class, reply.getSnapshotState().getClass());
+ assertEquals("Snapshot", snapshot, ((ShardSnapshotState)reply.getSnapshotState()).getSnapshot());