X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;ds=sidebyside;f=openflowplugin-impl%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fopenflowplugin%2Fimpl%2Fservices%2FAbstractMultipartService.java;h=d29fbbf9708545ce26341df94529c886df76d136;hb=refs%2Fchanges%2F77%2F100077%2F17;hp=6e38acb771c4ff5b3724d856bdb6851be63b9455;hpb=331e40fa25c7d2994afae7064091ed65989d8e40;p=openflowplugin.git diff --git a/openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/services/AbstractMultipartService.java b/openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/services/AbstractMultipartService.java index 6e38acb771..d29fbbf970 100644 --- a/openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/services/AbstractMultipartService.java +++ b/openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/services/AbstractMultipartService.java @@ -22,9 +22,8 @@ import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731 import org.opendaylight.yangtools.yang.common.RpcResult; public abstract class AbstractMultipartService extends AbstractService> { - private static final Function ALTERNATE_IS_COMPLETE = message -> - !(message instanceof MultipartReply) || !((MultipartReply) message).isRequestMore(); + !(message instanceof MultipartReply) || !((MultipartReply) message).getRequestMore(); protected AbstractMultipartService(final RequestContextStack requestContextStack, final DeviceContext deviceContext) { @@ -32,7 +31,8 @@ public abstract class AbstractMultipartService extends Ab } @Override - protected FutureCallback createCallback(RequestContext> context, Class requestType) { + protected FutureCallback createCallback(final RequestContext> context, + final Class requestType) { return canUseSingleLayerSerialization() ? new SingleLayerMultipartRequestCallback<>(context, requestType, getDeviceContext(), getEventIdentifier()) : new MultiLayerMultipartRequestCallback<>(context, requestType, getDeviceContext(), getEventIdentifier()); @@ -44,5 +44,4 @@ public abstract class AbstractMultipartService extends Ab ? super.handleServiceCall(input, ALTERNATE_IS_COMPLETE) : super.handleServiceCall(input); } - }