readyLocal.getRemoteVersion());
batched.setDoCommitOnReady(readyLocal.isDoCommitOnReady());
batched.setTotalMessagesSent(1);
- batched.setReady(true);
+ batched.setReady(readyLocal.getParticipatingShardNames());
readyLocal.getModification().applyToCursor(new BatchedCursor(batched));