outboundConnectorPrototypeNewDeployment.java

@Scheduled(fixedDelay = 5000)
public void scheduleImport() throws OperateException {
  List<ProcessDefinition> processDefinitions = camundaOperateClient
    .searchProcessDefinitions();
  for (ProcessDefinition processDefinition: processDefinitions) {
    if (!registry.processDefinitionChecked(processDefinition.getKey())) {
      processBpmnXml(
        processDefinition,
        camundaOperateClient.getProcessDefinitionXml(processDefinition.getKey()));
      registry.markProcessDefinitionChecked(processDefinition.getKey());
    }
  }
}

private void processBpmnXml(ProcessDefinition processDefinition, String resource) {
  final BpmnModelInstance bpmnModelInstance = Bpmn.readModelFromStream(
    new ByteArrayInputStream(resource.getBytes()));
  bpmnModelInstance.getDefinitions()
    .getChildElementsByType(Process.class)
    .stream().flatMap(
       process -> process.getChildElementsByType(StartEvent.class).stream()
    )
    .map(startEvent -> startEvent.getSingleExtensionElement(ZeebeProperties.class))
    .filter(Objects::nonNull)
    .forEach(zeebeProperties -> processZeebeProperties(processDefinition, zeebeProperties));
  // TODO: Also process intermediate catching message events and Receive Tasks
}

private void processZeebeProperties(ProcessDefinition processDefinition, ZeebeProperties zeebeProperties) {
  InboundConnectorProperties properties = new InboundConnectorProperties(
    processDefinition.getBpmnProcessId(),
    processDefinition.getVersion().intValue(),
    processDefinition.getKey(),
    zeebeProperties.getProperties().stream()
      .collect(Collectors.toMap(ZeebeProperty::getName, ZeebeProperty::getValue)));

  if (InboundConnectorProperties.TYPE_WEBHOOK.equals(properties.getType())) {
      registry.registerWebhookConnector(properties);
  } 
  // ...