当前位置: 首页 > 知识库问答 >
问题:

java客户端在Cadence中重试选项示例

牧璞
2023-03-14

我正在寻找java中cadence的重试选项示例,例如,我正在尝试下面的代码片段,但似乎活动没有重试

@ActivityMethod(scheduleToCloseTimeoutSeconds = 30)
@MethodRetry(maximumAttempts = 2, initialIntervalSeconds = 1, expirationSeconds = 30, maximumIntervalSeconds = 30)
String getGreetingContentOverTheWeb(URL url) throws IOException;

对于上述活动,我预计如果失败,应该会自动重试,下面是我如何调用它

@Override
public String getGreeting(String name) {
    // This is a blocking call that returns only after the activity has completed.
    try {
        String content = activities.getGreetingContentOverTheWeb(new URL("http://localhost:3000/import-map/books"));
        return activities.composeGreeting(content, name);
    } catch (IOException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
    }
    return activities.composeGreeting("Hello", name);
    
}

如果我在这里做了什么不正确的事情,请告诉我,

下面是前端的快照

共有1个答案

公冶经纶
2023-03-14

从事件历史记录来看,活动似乎被重试了。我通过查看ActivityTaskStarted.attempt字段来确定它。那里的数量等于重试的数量。因此,根据指定的重试策略,活动正好按请求执行了两次。

我知道这个名字非常混乱,因为尝试应该从1开始,而不是从0开始。我们已经在我的团队维护的temporal.io节奏分叉中修复了这个问题。

 类似资料:
  • 我们试图对cadence设置进行基准测试(目前在2个EC2实例上运行:m5a.xlarge ),发现了许多cadence客户端错误: cadence_service:cadence_matching,操作:历史记录重新记录活动任务已启动

  • 问题内容: 我们的系统与多个Web服务提供商进行通信。它们都是从单个Java客户端应用程序调用的。到目前为止,所有的Web服务都已通过SSL进行,但是没有一个使用客户端证书。好吧,一个新的合作伙伴正在改变这一现状。 使应用程序使用证书进行调用很容易;设置和将做到这一点。但是,现在的问题是如何制作它,使其仅在调用该特定Web服务时使用证书。我想更一般地说,我们希望能够选择要使用的客户端证书(如果有)

  • 问题内容: 我试图在JAVA中找到一个简单的(ha)带有工作服务的SOAP示例,但我似乎找不到的任何例子。 我已经试过这一个,从这个例子,但它只是不工作,它要求我把一个斜杠的,但它在那里并没有什么发生。 那么,有谁知道任何SOAP示例链接,我可以下载/请求并使用它吗? 谢谢你的帮助。 问题答案: 要用Java实现简单的SOAP客户端,可以使用SAAJ框架(JSE 1.6及更高版本附带): 带有Ja

  • 我想在一些计算机之间建立点对点连接,这样用户就可以在没有外部服务器的情况下聊天和交换文件。我最初的想法如下: 我在服务器上制作了一个中央服务器插座,所有应用程序都可以连接到该插座。此ServerSocket跟踪已连接的套接字(客户端),并将新连接的客户端的IP和端口提供给所有其他客户端。每个客户端都会创建一个新的ServerSocket,所有客户端都可以连接到它。 换句话说:每个客户端都有一个Se

  • 客户端播放:30秒示例 我当地的咖啡馆设有摇摇欲坠,不稳定的无线网络,并由市议会慷慨地赞助纳税人的钱。连接后,您将被重定向到一个受SSL保护的页面,提示您输入用户名和密码。输入详细信息后,您就可以自由地享受间歇性的辍学,类似难题的速度以及配置错误的透明代理。 我倾向于在第一时间使这种事情自动化,因为从长远来看,现在花费的时间将超过所花的时间。在这种情况下,我可能会使用Firebug来过滤表单发布参