PutJobConfigInterceptor.java 文件源码

@Override
public Object aroundReadFrom(ReaderInterceptorContext context) throws IOException {

    String json = JsonStrings.inputStreamToString(context.getInputStream());
    JsonStrings.isNotNullOrEmpty(json);
    context.setInputStream(new ByteArrayInputStream(json.getBytes(Charset.forName("UTF-8"))));

    String jobId = uriInfo.getPathParameters().getFirst("jobId");
    Job job = jobManager.getJob(jobId).orElseThrow(NotFoundException::new);
    Class<? extends JobConfigurationModel> configurationModelType = getJobConfigurationModelClass(job.getJobConfiguration());
    context.setType(configurationModelType);
    context.setGenericType(configurationModelType);
    return context.proceed();

}