CloudBP_JobWorker.java

zeebeClient
  .newWorker()
  .jobType(jobType)
  .handler(new ExampleJobHandler())
  .timeout(Duration.ofSeconds(10))
  .open()) {
    waitUntilSystemInput("exit");
  }

// ...

class ExampleJobHandler implements JobHandler {
  public void handle(final JobClient client, final ActivatedJob job) {
    // here: business logic that is executed with every job
    System.out.println(job);
    client.newCompleteCommand(job.getKey()).send().join();
  }
 }