try {
final boolean undo = false;
if (!context.isOk(undo)) // this is a blocking operation
- throw new InternalException("Cancel failed. This should never happen. Contact application support.");
+ throw new InternalException("Cancel failed. This should never happen.");
// System.out.println("session cs: " + session.clientChanges);
// System.out.println("reverse cs: " + cs);
queryProvider.performDirtyUpdates(graph);
}
// This will send and accept the reverse change set.
transactionToken.cancelEnd(session.writeSupport, null, session.clusterStream);
+ } else {
+ queryProvider.performDirtyUpdates(graph);
+ queryProvider.performScheduledUpdates(graph);
}
}
session.writeSupport.clearMetadata();