【问题标题】:Akka.NET StreamsAkka.NET 流
【发布时间】:2017-09-11 09:09:53
【问题描述】:

您将如何每十秒重播一次 Web 服务请求,持续十次,直到它得到响应?

我尝试过RecoverWithRetriesInitialDelay,但第一次恢复会立即重播网络服务调用:

FromThirdOfContract().RecoverWithRetries(e =>
{
    return Source.FromTask(_third.GetThird(message.ContractIdLegacy)).InitialDelay(TimeSpan.FromSeconds(secondsbetween));
}, retry);

第一次重试立即发生,而不是十秒后。在 Akka,有一个 RestartSource 类;我们在 Akka.NET 中没有它。有什么想法吗?

【问题讨论】:

    标签: akka akka-stream akka.net-streams


    【解决方案1】:

    我终于用我的来源玩了Source.Lazily()。它正在工作,在初始延迟调用之前未对其进行评估。但我正在倾听其他想法

    【讨论】:

      猜你喜欢
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 2014-09-30
      • 2015-07-21
      相关资源
      最近更新 更多