向远程 Cadence 服务器注册工作流程:任何示例

问题描述

如何使用远程 Cadence 服务器注册工作流?几乎所有示例都指向本地服务器。

谢谢 桑杰

解决方法

回答我自己的问题。如果没有 Matt Anger 的帮助,就无法解决这个问题。

ClientOptions tOptions = ClientOptions.newBuilder().setHost(serverHostName).setPort(serverPort).build() ;
WorkflowServiceTChannel tChannel = new WorkflowServiceTChannel(tOptions);
WorkflowClientOptions clientOptions = WorkflowClientOptions.newBuilder().setDomain(serverDomain).build();
WorkflowClient wfClient = WorkflowClient.newInstance(tChannel,clientOptions);
WorkerFactoryOptions factoryOptions = WorkerFactoryOptions.newBuilder().build();
WorkerFactory factory = WorkerFactory.newInstance(wfClient,factoryOptions);
// the class referred to below is from the tutorial
Worker worker = factory.newWorker("HelloWorldTaskList",WorkerOptions.newBuilder()
                                            .setMaxConcurrentActivityExecutionSize(100)
                                            .setMaxConcurrentWorkflowExecutionSize(100)
                                            .build());
 worker.registerWorkflowImplementationTypes(HelloWorldImpl.class);
 factory.start();

相关问答

错误1:Request method ‘DELETE‘ not supported 错误还原:...
错误1:启动docker镜像时报错:Error response from daemon:...
错误1:private field ‘xxx‘ is never assigned 按Alt...
报错如下,通过源不能下载,最后警告pip需升级版本 Requirem...