import org.opendaylight.openflowplugin.impl.statistics.ofpspecific.EventsTimeCounter;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.Error;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.OfHeader;
-import org.opendaylight.yangtools.yang.common.RpcError;
+import org.opendaylight.yangtools.yang.common.ErrorType;
import org.opendaylight.yangtools.yang.common.RpcResult;
import org.opendaylight.yangtools.yang.common.RpcResultBuilder;
private final RequestContext<T> context;
private final Class<?> requestType;
private final MessageSpy spy;
- private EventIdentifier eventIdentifier;
+ private final EventIdentifier eventIdentifier;
AbstractRequestCallback(final RequestContext<T> context,
final Class<?> requestType,
}
@Override
- public final void onFailure(@NonNull final Throwable throwable) {
+ public final void onFailure(final Throwable throwable) {
final RpcResultBuilder<T> builder;
if (null != eventIdentifier) {
EventsTimeCounter.markEnd(eventIdentifier);
err.getTypeString(),
err.getCodeString());
- builder = RpcResultBuilder.<T>failed().withError(RpcError.ErrorType.APPLICATION, errorString, throwable);
+ builder = RpcResultBuilder.<T>failed().withError(ErrorType.APPLICATION, errorString, throwable);
spyMessage(StatisticsGroup.TO_SWITCH_SUBMIT_FAILURE);
} else {
if (throwable != null) {
builder = RpcResultBuilder.<T>failed()
- .withError(RpcError.ErrorType.APPLICATION, throwable.getMessage(), throwable);
+ .withError(ErrorType.APPLICATION, throwable.getMessage(), throwable);
} else {
Throwable deviceReadFailedThrowable = new Throwable("Failed to read from device.");
builder = RpcResultBuilder.<T>failed()
- .withError(RpcError.ErrorType.APPLICATION, deviceReadFailedThrowable.getMessage(),
+ .withError(ErrorType.APPLICATION, deviceReadFailedThrowable.getMessage(),
deviceReadFailedThrowable);
}
spyMessage(StatisticsGroup.TO_SWITCH_SUBMIT_ERROR);