+
+ public static void immediatePayloadReplication(final ShardDataTree shardDataTree, final Shard mockShard) {
+ doAnswer(invocation -> {
+ shardDataTree.applyReplicatedPayload(invocation.getArgument(0), invocation.getArgument(1));
+ return null;
+ }).when(mockShard).persistPayload(any(TransactionIdentifier.class), any(CommitTransactionPayload.class),
+ anyBoolean());
+ }