本文整理了Java中org.opencastproject.job.api.Job.getPayload()方法的一些代码示例，展示了Job.getPayload()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Job.getPayload()方法的具体详情如下：
包路径：org.opencastproject.job.api.Job
类名称：Job
方法名：getPayload

Job.getPayload介绍

[英]Gets the serialized output that was produced by this job, or null if nothing was produced, or if it has yet to be produced.
[中]获取此作业生成的序列化输出，如果未生成任何内容或尚未生成，则为null。

代码示例

代码示例来源：origin: opencast/opencast

@Override
public List<String> getJobPayloads(String operation) throws ServiceRegistryException {
 List<String> result = new ArrayList<>();
 for (String serializedJob : jobs.values()) {
  try {
   Job job = JobParser.parseJob(serializedJob);
   if (operation.equals(job.getOperation())) {
    result.add(job.getPayload());
   }
  } catch (IOException e) {
   throw new IllegalStateException("Error unmarshaling job", e);
  }
 }
 return result;
}

代码示例来源：origin: opencast/opencast

/**
 * Remove all files created by the given jobs
 * @param jobs
 */
private void cleanupWorkspace(List<Job> jobs) {
 for (Job job : jobs) {
   String jobPayload = job.getPayload();
   if (StringUtils.isNotEmpty(jobPayload)) {
    try {
     MediaPackageElement timelinepreviewsMpe = MediaPackageElementParser.getFromXml(jobPayload);
     URI timelinepreviewsUri = timelinepreviewsMpe.getURI();
     workspace.delete(timelinepreviewsUri);
    } catch (MediaPackageException ex) {
     // unexpected job payload
     logger.error("Can't parse timeline previews attachment from job {}", job.getId());
    } catch (NotFoundException ex) {
     // this is ok, because we want delete the file
    } catch (IOException ex) {
     logger.warn("Deleting timeline previews image file from workspace failed: {}", ex.getMessage());
     // this is ok, because workspace cleaner will remove old files if they exist
    }
   }
  }
}

代码示例来源：origin: opencast/opencast

/**
 * Update the job from the service registry and get its payload.
 *
 * @return the payload or none, if either to job cannot be found or if the job has no or an empty payload
 */
public static Opt<String> getPayload(ServiceRegistry reg, Job job)
    throws NotFoundException, ServiceRegistryException {
 for (Job updated : update(reg, job)) {
  return Opt.nul(updated.getPayload());
 }
 return Opt.none();
}

代码示例来源：origin: opencast/opencast

case FINISHED:
 job.setStatus(jobStatus);
 job.setPayload(processedJob.getPayload());
 finishedJobs.put(job, jobStatus);
 break;

代码示例来源：origin: opencast/opencast

String jobPayload = job.getPayload();
if (StringUtils.isEmpty(jobPayload)) {
 continue;

代码示例来源：origin: opencast/opencast

String jobPayload = job.getPayload();
if (StringUtils.isNotEmpty(jobPayload)) {
 MediaPackageElement timelinePreviewsMpe = null;

代码示例来源：origin: opencast/opencast

throw new WorkflowOperationException("Transcription format conversion job did not complete successfully");
transcription = MediaPackageElementParser.getFromXml(job.getPayload());

代码示例来源：origin: opencast/opencast

final Status fromDbStatus = fromDb.getStatus();
fromDb.setPayload(job.getPayload());
fromDb.setStatus(job.getStatus());
fromDb.setDispatchable(job.isDispatchable());

代码示例来源：origin: opencast/opencast

public JaxbJob(Job job) {
 this();
 this.id = job.getId();
 this.dateCompleted = job.getDateCompleted();
 this.dateCreated = job.getDateCreated();
 this.dateStarted = job.getDateStarted();
 this.queueTime = job.getQueueTime();
 this.runTime = job.getRunTime();
 this.version = job.getVersion();
 this.payload = job.getPayload();
 this.processingHost = job.getProcessingHost();
 this.createdHost = job.getCreatedHost();
 this.id = job.getId();
 this.jobType = job.getJobType();
 this.operation = job.getOperation();
 if (job.getArguments() != null)
  this.arguments = unmodifiableList(job.getArguments());
 this.status = job.getStatus();
 this.parentJobId = job.getParentJobId();
 this.rootJobId = job.getRootJobId();
 this.dispatchable = job.isDispatchable();
 this.uri = job.getUri();
 this.creator = job.getCreator();
 this.organization = job.getOrganization();
 this.jobLoad = job.getJobLoad();
 if (job.getBlockedJobIds() != null)
  this.blockedJobIds = unmodifiableList(job.getBlockedJobIds());
 this.blockingJobId = job.getBlockingJobId();
}

代码示例来源：origin: opencast/opencast

public static JpaJob from(Job job) {
 JpaJob newJob = new JpaJob();
 newJob.id = job.getId();
 newJob.dateCompleted = job.getDateCompleted();
 newJob.dateCreated = job.getDateCreated();
 newJob.dateStarted = job.getDateStarted();
 newJob.queueTime = job.getQueueTime();
 newJob.runTime = job.getRunTime();
 newJob.version = job.getVersion();
 newJob.payload = job.getPayload();
 newJob.jobType = job.getJobType();
 newJob.operation = job.getOperation();
 newJob.arguments = job.getArguments();
 newJob.status = job.getStatus().ordinal();
 newJob.parentJobId = job.getParentJobId();
 newJob.rootJobId = job.getRootJobId();
 newJob.dispatchable = job.isDispatchable();
 newJob.uri = job.getUri();
 newJob.creator = job.getCreator();
 newJob.organization = job.getOrganization();
 newJob.jobLoad = job.getJobLoad();
 newJob.blockedJobIds = job.getBlockedJobIds();
 newJob.blockingJobId = job.getBlockingJobId();
 return newJob;
}