1回答
我想抛出一个异常，如下所示： Source.empty throw new RuntimeException("Failed") case Failure(e) => } 但异常不会出现在onComplete方法中。java.lang.RuntimeException: Fail
浏览 3提问于2019-04-23得票数 1
回答已采纳
1回答
我是Akka/Scala的新手，正在尝试调试下面的代码。当resultSetParser有异常时，它不会抛出它。相反，使用此代码的服务将永远处于空闲状态。我怎样才能让我的服务抛出异常，而不是永远在流上等待？在Akka中有没有类似watchException()函数的东西，我可以在watchTermination()之后立即调用它，让它抛出在处理流时看到的异常？
浏览 3提问于2017-11-04得票数 4
1回答
更改akka流的源数据
、、、
我正在学习Java流，并使用定义了以下内容：import java.util.List;在现实世界中，sourceData不会是静态的，Akka对如何处理变化的数据有自己的看法，还是由开发人员决定？或者Akka流的寿命很长，源数据的变化和流计算是根据某些参数重新执行的吗
浏览 1提问于2021-04-10得票数 0
回答已采纳
我有很多的网址，我想得到使用Akka HTTP，并使用流。我该怎么做呢？我已经搜索过了，但什么也没有找到，也找不到一种方法来处理文档本身中的esceptions。编辑:在摆弄了一下之后，我发现唯一的问题是HTTPS urls，即使这样流也没有关闭，但我在控制台上打印了错误
浏览 8提问于2020-05-07得票数 0
回答已采纳
1回答
我有一个akka Flow[I, O]，它不在我的控制范围之内，因为它来自一些第三方代码。每当输入元素没有生成输出元素时(例如，因为在流的某些部分抛出了异常)，我就需要做出反应。
浏览 34提问于2020-10-06得票数 2
2回答
我正在尝试使用Futures和Akka supervisor开发一个应用程序，但是当A future向某个参与者返回失败时，它的主管不会得到异常。
这是我的代码。
浏览 3提问于2014-12-18得票数 4
嗨，我想知道是否有人能帮助我理解第三方创建的GraphStage的异常处理。下面是一个演示我的问题的示例GraphStage。我抛出一个异常，这可能不是最佳实践。import akka.stream.stag
浏览 0提问于2018-11-25得票数 0
回答已采纳
这是我之前的问题：关键是，我可以实时地压缩/加密文件，同时逐块读取它(我没有在磁盘上创
浏览 2提问于2017-02-25得票数 1
回答已采纳
1回答
Akka有效负载异常捕获
、、、
我需要捕获akka抛出的超过有效负载的异常。这是因为如果我的有效负载超过了配置文件中设置的允许量，响应就会以超时结束。与目前的场景不同，我希望捕获akka在超出有效负载时抛出的异常，而不是等待超时。
浏览 0提问于2017-09-07得票数 1
3回答
我目前正在尝试开始使用Akka，但我面临着一个奇怪的问题。PoisonPill Thread [akka:event-driven:dispatcher:event:handler-6] (Suspended)
Unsafe.p
浏览 2提问于2011-05-30得票数 73
回答已采纳
1回答
Akka和备份/后备行动方
、、、、
我来阿克卡之前花了相当多的时间在，在那里，像阿克卡，失败是一个一流的公民。memoryFallback.fizz = this.fizz }在Hystrix中，如果run()抛出异常(例如SqlException如果在一定时间内抛出足够多的异常，则HystrixCommands“断路器”将被“跳闸”，只有getFallback()方法会被调用。
我有兴趣在阿克卡完成同样的任务，但要和演员一起完成。InMemo
浏览 2提问于2015-08-25得票数 2
INFO default-akka.actor.default-dispatcher-6 7347a正在启动。INFO default-AKA.ACTOR.DEFAULT-dispatcher 6 7347a完成INFO06/01/2020 05:06:35.165 akka://default/system/Materializers/StreamSupervisor-0/$$a#-993709322到Actorakka://default/sys
浏览 6提问于2020-06-01得票数 0
回答已采纳
1回答
反应性-卡夫卡流消费者:死信发生
、、、、
我试图使用akka的反应性卡夫卡库来消费卡夫卡的信息。-5] [akka://CommittableSourceConsumerMain/system/kafka-consumer-1] Message [akka.kafka.KafkaConsumerActor$Internal$Stop$] from Actor[akka://CommittableSourceConsumerMain/deadLetters] to Actor[akka</
浏览 4提问于2017-01-24得票数 3
回答已采纳
1回答
我正在开发一个使用Akka Kafka连接器的Kafka消费者应用程序。我希望消费者并行处理消息。我应该选择哪个消费群体？？如何在消费者端配置并行度？
浏览 16提问于2020-05-06得票数 0
1回答
在Akka Actors (使用Scala)中，可以使用监督策略来处理异常。根据异常类型，此策略可以决定如何处理参与者。它是否继续处理该消息(假设某些外部因素导致了异常，而该异常不再存在)，还是继续处理邮箱中的下一条消息？
浏览 4提问于2020-07-14得票数 0
回答已采纳
在探索Akka流时，我还遇到了Apache哪个流处理引擎。Akka流实现反应流并支持背压。
那么，如果我要在两者之间做出决定，我应该选择哪一个呢？它们有何不同之处，相似之处何在？
浏览 3提问于2020-04-23得票数 4
回答已采纳
在我的存储库函数中，我正在读取一个用户，然后更新该用户： this.read(u.id).flatMap {existingUser.createdDate)))}
当找不到用户时，我想在这里抛出一些异常<
浏览 5提问于2017-07-25得票数 0
回答已采纳
但是，如果引发异常，则调用方代码不会捕获该异常。
如何在reactor 2.0流中捕获异常？我想做的是:如果抛出异常，流处理必须停止。我需要在调用者线程(首先创建流的那个线程)中抛出异常。
浏览 0提问于2015-01-16得票数 2
我试图通过使用akka流参考文件将音频流从服务A发送到服务B (akka-streams库版本: 2.6.3)。一切都运行得很好，除了每月一次在akka流引用中抛出异常(每天使用该服务的次数约为50k )外，我找不到问题的原因。(ActorGraphInterpreter.scala:690)在服务A中负责推动音频通过SourceRe
浏览 1提问于2020-03-30得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
云直播
对象存储活动推荐
腾讯云开发者
