final BatchedModifications batched = new BatchedModifications(msg.getTransactionID(),
DataStoreVersions.CURRENT_VERSION, "");
batched.setDoCommitOnReady(msg.isDoCommitOnReady());
+ batched.setTotalMessagesSent(1);
batched.setReady(true);
msg.getModification().applyToCursor(new BatchedCursor(batched));