func main() {
  client, err := zbc.NewZBClient("localhost:26500")
  jobWorker := client.NewJobWorker().JobType("my-service-task").Handler(handleJob).Open()
  defer jobWorker.Close()
  jobWorker.AwaitClose()
}

func handleJob(client worker.JobClient, job entities.Job) {
  // here: business logic that is executed with every job
  log.Println(job)
  // and let the workflow engine know we are done
  request, err := client.NewCompleteJobCommand().JobKey(jobKey)
  request.Send()
}