X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-distributed-datastore%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fdatastore%2Fmessages%2FReadData.java;fp=opendaylight%2Fmd-sal%2Fsal-distributed-datastore%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fdatastore%2Fmessages%2FReadData.java;h=1113a854bfda89e457bf9cd17c736d9e2f8159fa;hp=6352b5734b9dae632f187792c5119d1ce815fb10;hb=abaef4a5ae37f27542155457fe7306a4662b1eeb;hpb=1b2f032084fc334f1027524afe40c608706c56e3;ds=sidebyside diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/messages/ReadData.java b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/messages/ReadData.java index 6352b5734b..1113a854bf 100644 --- a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/messages/ReadData.java +++ b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/messages/ReadData.java @@ -5,7 +5,6 @@ * terms of the Eclipse Public License v1.0 which accompanies this distribution, * and is available at http://www.eclipse.org/legal/epl-v10.html */ - package org.opendaylight.controller.cluster.datastore.messages; import com.google.common.base.Preconditions; @@ -17,33 +16,34 @@ import org.opendaylight.mdsal.dom.spi.store.DOMStoreReadTransaction; import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier; import org.opendaylight.yangtools.yang.data.api.schema.NormalizedNode; -public class ReadData extends AbstractRead>> { +public class ReadData extends AbstractRead> { private static final long serialVersionUID = 1L; public ReadData() { } - public ReadData(final YangInstanceIdentifier path, short version) { + public ReadData(final YangInstanceIdentifier path, final short version) { super(path, version); } @Override - public FluentFuture>> apply(DOMStoreReadTransaction readDelegate) { + public FluentFuture> apply(final DOMStoreReadTransaction readDelegate) { return readDelegate.read(getPath()); } @Override - public void processResponse(Object readResponse, SettableFuture>> returnFuture) { + public void processResponse(final Object readResponse, + final SettableFuture> returnFuture) { if (ReadDataReply.isSerializedType(readResponse)) { ReadDataReply reply = ReadDataReply.fromSerializable(readResponse); - returnFuture.set(Optional.>ofNullable(reply.getNormalizedNode())); + returnFuture.set(Optional.ofNullable(reply.getNormalizedNode())); } else { returnFuture.setException(new ReadFailedException("Invalid response reading data for path " + getPath())); } } @Override - protected AbstractRead>> newInstance(short withVersion) { + protected AbstractRead> newInstance(final short withVersion) { return new ReadData(getPath(), withVersion); } @@ -52,7 +52,7 @@ public class ReadData extends AbstractRead>> { return (ReadData)serializable; } - public static boolean isSerializedType(Object message) { + public static boolean isSerializedType(final Object message) { return message instanceof ReadData; } }