- final ReadyLocalTransaction msg = (ReadyLocalTransaction) obj;
- final BatchedModifications batched = new BatchedModifications(msg.getTransactionID(),
- DataStoreVersions.CURRENT_VERSION, "");
- batched.setDoCommitOnReady(msg.isDoCommitOnReady());
+ final ReadyLocalTransaction readyLocal = (ReadyLocalTransaction) obj;
+ final BatchedModifications batched = new BatchedModifications(readyLocal.getTransactionID(),
+ readyLocal.getRemoteVersion(), "");
+ batched.setDoCommitOnReady(readyLocal.isDoCommitOnReady());