import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-public abstract class AbstractMultipartRequestOnTheFlyCallback<T extends OfHeader> extends AbstractMultipartRequestCallback<T> {
+public abstract class AbstractMultipartRequestOnTheFlyCallback<T extends OfHeader>
+ extends AbstractMultipartRequestCallback<T> {
private static final Logger LOG = LoggerFactory.getLogger(AbstractMultipartRequestOnTheFlyCallback.class);
private final DeviceInfo deviceInfo;
private final EventIdentifier doneEventIdentifier;
final ConvertorExecutor convertorExecutor) {
super(context, requestType, deviceContext, eventIdentifier);
deviceInfo = deviceContext.getDeviceInfo();
- doneEventIdentifier = new EventIdentifier(getMultipartType().name(), deviceContext.getDeviceInfo().getNodeId().toString());
+ doneEventIdentifier =
+ new EventIdentifier(getMultipartType().name(), deviceContext.getDeviceInfo().getNodeId().toString());
txFacade = deviceContext;
deviceRegistry = deviceContext;
this.statisticsWriterProvider = statisticsWriterProvider;
}
@Override
- @SuppressWarnings("unchecked")
+ @SuppressWarnings({"unchecked", "checkstyle:IllegalCatch"})
public void onSuccess(final OfHeader result) {
if (Objects.isNull(result)) {
LOG.warn("Response received was null.");
} catch (final Exception ex) {
LOG.warn("Unexpected exception occurred while translating response: {}.", result.getClass(), ex);
setResult(RpcResultBuilder.<List<T>>failed().withError(RpcError.ErrorType.APPLICATION,
- String.format("Unexpected exception occurred while translating response: %s. %s", result.getClass(), ex)).build());
+ String.format("Unexpected exception occurred while translating response: %s. %s",
+ result.getClass(),
+ ex)).build());
endCollecting(false);
return;
}
}
/**
- * Get tx facade
+ * Get tx facade.
* @return tx facade
*/
protected TxFacade getTxFacade() {
}
/**
- * Starts collecting of multipart data
+ * Starts collecting of multipart data.
*/
private synchronized void startCollecting() {
EventsTimeCounter.markStart(doneEventIdentifier);
instanceIdentifier,
deviceRegistry.getDeviceGroupRegistry());
break;
+ default:
+ LOG.warn("Unsupported type {}", getMultipartType());
}
}
/**
- * Ends collecting of multipart data
+ * Ends collecting of multipart data.
* @param setResult set empty success result
*/
private void endCollecting(final boolean setResult) {
case OFPMPGROUPDESC:
deviceRegistry.getDeviceGroupRegistry().processMarks();
break;
+ default:
+ LOG.warn("Unsupported type {}", getMultipartType());
}
}
/**
- * Get multipart type
+ * Get multipart type.
* @return multipart type
*/
protected abstract MultipartType getMultipartType();
-
}