private void sendSignals(UUID jobId, AuthData exportAuthData, AuthData importAuthData,
    JobLifeCycle jobLifeCycle, Monitor monitor) {
    if(!transferSignalEnabled) {
      monitor.info(() -> "Transfer Signal Disabled.");
      return;
    }

    SignalRequest signalRequest = SignalRequest.builder()
      .setJobId(jobId.toString())
      .setDataType(JobMetadata.getDataType().getDataType())
      .setJobStatus(jobLifeCycle)
      .setExportingService(JobMetadata.getExportService())
      .setImportingService(JobMetadata.getImportService())
      .build();

    try {
      exportSignalHandlerProvider.get().sendSignal(signalRequest, exportAuthData, monitor);
      importSignalHandlerProvider.get().sendSignal(signalRequest, importAuthData, monitor);
    } catch (CopyExceptionWithFailureReason | IOException | RetryException e) {
      monitor.info(() -> "Errored while sending transfer signals.", e);
    }
  }
Process our job, whose metadata is available via {@link JobMetadata}.
portability-transfer/src/main/java/org/datatransferproject/transfer/JobProcessor.java