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

ZeebeClientBuilder介绍

暂无

代码示例

代码示例来源：origin: zeebe-io/zeebe

public void createClient() {
 client = ZeebeClient.newClientBuilder().withProperties(properties.get()).build();
 determineDefaultPartition();
}

代码示例来源：origin: berndruecker/flowing-retail

@Bean
public ZeebeClient zeebe() {
 System.out.println("Connect to Zeebe at '" + zeebeBrokerContactPoint + "'");
 
 // Cannot yet use Spring Zeebe in current alpha
 ZeebeClient zeebeClient = ZeebeClient.newClientBuilder() //
   .brokerContactPoint(zeebeBrokerContactPoint) //
   .build();
 
 // Trigger deployment
 zeebeClient.workflowClient().newDeployCommand() //
  .addResourceFromClasspath("order-kafka.bpmn") //
  .send().join();
 
 return zeebeClient;
}

代码示例来源：origin: zeebe-io/zeebe

/**
 * @return a new Zeebe client with default configuration values. In order to customize
 *     configuration, use the methods {@link #newClientBuilder()} or {@link
 *     #newClient(ZeebeClientConfiguration)}. See {@link ZeebeClientBuilder} for the configuration
 *     options and default values.
 */
static ZeebeClient newClient() {
 return newClientBuilder().build();
}

代码示例来源：origin: zeebe-io/zeebe

public static void main(final String[] args) {
  final String broker = "localhost:26500";

  final ZeebeClientBuilder clientBuilder =
    ZeebeClient.newClientBuilder().brokerContactPoint(broker);

  try (ZeebeClient client = clientBuilder.build()) {

   final DeploymentEvent deploymentEvent =
     client.newDeployCommand().addResourceFromClasspath("demoProcess.bpmn").send().join();

   System.out.println("Deployment created with key: " + deploymentEvent.getKey());
  }
 }
}

代码示例来源：origin: io.zeebe/zeebe-client-java

/**
 * @return a new Zeebe client with default configuration values. In order to customize
 *     configuration, use the methods {@link #newClientBuilder()} or {@link
 *     #newClient(ZeebeClientConfiguration)}. See {@link ZeebeClientBuilder} for the configuration
 *     options and default values.
 */
static ZeebeClient newClient() {
 return newClientBuilder().build();
}

代码示例来源：origin: zeebe-io/zeebe

public static void main(final String[] args) {
  final String broker = "127.0.0.1:26500";

  final ZeebeClientBuilder builder = ZeebeClient.newClientBuilder().brokerContactPoint(broker);

  try (ZeebeClient client = builder.build()) {
   System.out.println("Requesting topology with initial contact point " + broker);

   final Topology topology = client.newTopologyRequest().send().join();

   System.out.println("Topology:");
   topology
     .getBrokers()
     .forEach(
       b -> {
        System.out.println("    " + b.getAddress());
        b.getPartitions()
          .forEach(
            p ->
              System.out.println(
                "      " + p.getPartitionId() + " - " + p.getRole()));
       });

   System.out.println("Done.");
  }
 }
}

代码示例来源：origin: io.zeebe/zeebe-test

public void createClient() {
 client = ZeebeClient.newClientBuilder().withProperties(properties.get()).build();
 determineDefaultPartition();
}

代码示例来源：origin: zeebe-io/zeebe

public static void main(final String[] args) {
  final String broker = "127.0.0.1:26500";

  final String bpmnProcessId = "demoProcess";

  final ZeebeClientBuilder builder = ZeebeClient.newClientBuilder().brokerContactPoint(broker);

  try (ZeebeClient client = builder.build()) {

   System.out.println("Creating workflow instance");

   final WorkflowInstanceEvent workflowInstanceEvent =
     client
       .newCreateInstanceCommand()
       .bpmnProcessId(bpmnProcessId)
       .latestVersion()
       .send()
       .join();

   System.out.println(
     "Workflow instance created with key: " + workflowInstanceEvent.getWorkflowInstanceKey());
  }
 }
}

代码示例来源：origin: zeebe-io/zeebe

public static void main(final String[] args) {
 final String broker = "127.0.0.1:26500";
 final String jobType = "foo";
 final ZeebeClientBuilder builder = ZeebeClient.newClientBuilder().brokerContactPoint(broker);
 try (ZeebeClient client = builder.build()) {
  System.out.println("Opening job worker.");
  final JobWorker workerRegistration =
    client
      .newWorker()
      .jobType(jobType)
      .handler(new ExampleJobHandler())
      .timeout(Duration.ofSeconds(10))
      .open();
  System.out.println("Job worker opened and receiving jobs.");
  // call workerRegistration.close() to close it
  // run until System.in receives exit command
  waitUntilSystemInput("exit");
 }
}

代码示例来源：origin: zeebe-io/zeebe

public static void main(final String[] args) {

  final String broker = "localhost:26500";

  final ZeebeClientBuilder clientBuilder =
    ZeebeClient.newClientBuilder().brokerContactPoint(broker);

  try (ZeebeClient client = clientBuilder.build()) {

   final Workflows workflows = client.newWorkflowRequest().send().join();

   System.out.println("Printing all deployed workflows:");

   workflows
     .getWorkflows()
     .forEach(
       wf -> {
        System.out.println("Workflow resource for " + wf + ":");

        final WorkflowResource resource =
          client.newResourceRequest().workflowKey(wf.getWorkflowKey()).send().join();

        System.out.println(resource);
       });

   System.out.println("Done");
  }
 }
}

代码示例来源：origin: zeebe-io/zeebe

public static void main(final String[] args) {
 final String broker = "127.0.0.1:26500";
 final ZeebeClientBuilder builder = ZeebeClient.newClientBuilder().brokerContactPoint(broker);
 try (ZeebeClient client = builder.build()) {
  final Order order = new Order();
  order.setOrderId(31243);
  client
    .newCreateInstanceCommand()
    .bpmnProcessId("demoProcess")
    .latestVersion()
    .payload(order)
    .send()
    .join();
  client.newWorker().jobType("foo").handler(new DemoJobHandler()).open();
  // run until System.in receives exit command
  waitUntilSystemInput("exit");
 }
}