import org.opendaylight.controller.cluster.access.concepts.TransactionIdentifier;
import org.opendaylight.controller.cluster.datastore.node.utils.stream.NormalizedNodeDataOutput;
import org.opendaylight.controller.cluster.datastore.node.utils.stream.NormalizedNodeInputOutput;
+import org.opendaylight.controller.cluster.datastore.node.utils.stream.NormalizedNodeStreamVersion;
import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier;
/**
abstract class AbstractReadPathTransactionRequestProxyV1<T extends AbstractReadPathTransactionRequest<T>>
extends AbstractReadTransactionRequestProxyV1<T> {
private static final long serialVersionUID = 1L;
+
private YangInstanceIdentifier path;
+ private transient NormalizedNodeStreamVersion streamVersion;
protected AbstractReadPathTransactionRequestProxyV1() {
// For Externalizable
AbstractReadPathTransactionRequestProxyV1(final T request) {
super(request);
path = request.getPath();
+ streamVersion = request.getVersion().getStreamVersion();
}
@Override
public final void writeExternal(final ObjectOutput out) throws IOException {
super.writeExternal(out);
- try (NormalizedNodeDataOutput nnout = NormalizedNodeInputOutput.newDataOutput(out)) {
+ try (NormalizedNodeDataOutput nnout = NormalizedNodeInputOutput.newDataOutput(out, streamVersion)) {
nnout.writeYangInstanceIdentifier(path);
}
}