}
private static BatchedModifications newBatchedModifications() {
- BatchedModifications modifications = new BatchedModifications("tnx", DataStoreVersions.CURRENT_VERSION, "");
+ BatchedModifications modifications = new BatchedModifications(nextTransactionId(), DataStoreVersions.CURRENT_VERSION);
modifications.setDoCommitOnReady(true);
modifications.setReady(true);
modifications.setTotalMessagesSent(1);
}
private static ShardIdentifier newShardId(String memberName) {
- return ShardIdentifier.builder().memberName(MemberName.forName(memberName)).shardName("entity-ownership").
- type("operational" + NEXT_SHARD_NUM.getAndIncrement()).build();
+ return ShardIdentifier.create("entity-ownership", MemberName.forName(memberName),
+ "operational" + NEXT_SHARD_NUM.getAndIncrement());
}
private static class TestEntityOwnershipShard extends EntityOwnershipShard {
volatile boolean dropAppendEntries;
private final String myId;
+ @SuppressWarnings("unused")
public MockFollower(String myId) {
this(myId, true);
}