import com.google.common.util.concurrent.ListenableFuture;
import java.util.List;
import java.util.function.Function;
-import javax.annotation.Nonnull;
+import org.eclipse.jdt.annotation.NonNull;
import org.opendaylight.openflowplugin.api.openflow.device.DeviceContext;
import org.opendaylight.openflowplugin.api.openflow.device.RequestContext;
import org.opendaylight.openflowplugin.api.openflow.device.RequestContextStack;
import org.opendaylight.yangtools.yang.common.RpcResult;
public abstract class AbstractMultipartService<I, T extends OfHeader> extends AbstractService<I, List<T>> {
-
private static final Function<OfHeader, Boolean> ALTERNATE_IS_COMPLETE = message ->
- !(message instanceof MultipartReply) || !((MultipartReply) message).isRequestMore();
+ !(message instanceof MultipartReply) || !((MultipartReply) message).getRequestMore();
protected AbstractMultipartService(final RequestContextStack requestContextStack,
final DeviceContext deviceContext) {
}
@Override
- protected FutureCallback<OfHeader> createCallback(RequestContext<List<T>> context, Class<?> requestType) {
+ protected FutureCallback<OfHeader> createCallback(final RequestContext<List<T>> context,
+ final Class<?> requestType) {
return canUseSingleLayerSerialization()
? new SingleLayerMultipartRequestCallback<>(context, requestType, getDeviceContext(), getEventIdentifier())
: new MultiLayerMultipartRequestCallback<>(context, requestType, getDeviceContext(), getEventIdentifier());
}
@Override
- public final ListenableFuture<RpcResult<List<T>>> handleServiceCall(@Nonnull final I input) {
+ public final ListenableFuture<RpcResult<List<T>>> handleServiceCall(@NonNull final I input) {
return canUseSingleLayerSerialization()
? super.handleServiceCall(input, ALTERNATE_IS_COMPLETE)
: super.handleServiceCall(input);
}
-
}