import org.opendaylight.controller.cluster.access.commands.TransactionMerge;
import org.opendaylight.controller.cluster.access.commands.TransactionModification;
import org.opendaylight.controller.cluster.access.commands.TransactionPreCommitRequest;
+import org.opendaylight.controller.cluster.access.commands.TransactionPurgeRequest;
import org.opendaylight.controller.cluster.access.commands.TransactionRequest;
import org.opendaylight.controller.cluster.access.commands.TransactionSuccess;
import org.opendaylight.controller.cluster.access.commands.TransactionWrite;
case THREE_PHASE:
sendRequest(commitRequest(true), callback);
break;
+ case READY:
+ //no op
+ break;
default:
throw new IllegalArgumentException("Unhandled protocol " + maybeProto.get());
}
} else if (request instanceof TransactionAbortRequest) {
ensureFlushedBuider();
sendAbort(callback);
+ } else if (request instanceof TransactionPurgeRequest) {
+ purge();
} else {
throw new IllegalArgumentException("Unhandled request {}" + request);
}