akka 相关问题

我有一系列看起来像这样的路径； path（“ slides” / Segment）{segment => getFromDirectory（s“ $ {cfg.slidesDir} / $ segment”）}〜path（“ foo” / Segment）{segment => getFromDirectory（s“ $ {...

scala akka akka-http

回答 1 投票 0

在Akka Sharding上启动时初始化实体

如何在集群启动时预启动实体？我已经找到了一种方法，但是我认为这不是正确的方法。它包括将StartEntity（entityId）消息发送到...

scala akka sharding akka-cluster

回答 1 投票 0

Scala和Akka HTTP：读取具有多个字段的有效负载

我正在尝试在Akka HTTP中创建一个HTTP请求，该请求将能够通过HTTP请求发送两个字符串“ string1”和“ string2”。我目前有以下代码可以处理简单的...

scala akka akka-http

回答 1 投票 0

Akka中调度程序与路由器之间的差异

我正在浏览Akka文档和其他Wiki。谁能告诉我Akka框架中的Dispatcher＆Routers有什么区别？

akka

回答 1 投票 3

Actor消息分配给调度程序线程

已知分派器线程负责执行参与者消息。使用吞吐量参数，我们可以定义no。由调度程序线程处理的消息，然后再移至另一个...

akka akka-actor akka-dispatcher

回答 1 投票 0

如何在运行时使用application.conf更改akka Actors日志级别

如何设置application.conf使其能够在运行时更改akka logLevel？我可以设置任何属性吗？我正在使用slf4j和logback作为后端。我刚刚设置了logback.xml：

logging akka logback slf4j application.conf

回答 1 投票 0

Akka流：使用OverflowStrategy.fail（）模拟失败的流

我是Akka和Akka流的新手。我创建了一个虚拟流，并希望它以异常结束，因为我的map（）函数非常慢，并且我将缓冲区设置为1。所以我的问题分为两部分：为什么...

java akka akka-stream

回答 1 投票 0

akka ActorSystem进程如何从actor接收

我如何使进程使用ActorOf创建Actor，并允许Actor ping父进程。我的目的是允许参与者将信号发送到其父进程（ActorSystem主线程）以调用...

scala akka actor actorsystem

回答 1 投票 0

为什么AKKA TypedActor类具有两个具有相同签名的方法？

在使用TypedActor.get（system）intellij拼写错误“歧义方法调用”时，此处系统的类型为ActorSystem。我在TypedActor类文件的反编译源代码中发现有两个...

java akka

回答 1 投票 0

将Akka流传递到上游服务以进行填充

我需要调用上游服务（Azure Blob服务）以将数据推送到OutputStream，然后需要通过akka转过来并将其推送回客户端。没有akka（只有servlet代码）...

java stream akka akka-stream

回答 1 投票 6

在Akka类型演员中创建调度程序/计时器

我正在尝试在我的Akka中创建一个计划程序，键入它只是为了对其进行测试，就像每x秒运行一次。 def start（）：Behavior [ClientMsg] = Behaviors.setup {ctx => ctx.log.info（“ start（）named”）...

scala akka akka-typed

回答 2 投票 0

我如何将the回路线列表添加到汽车当前的路线列表之前？

我想知道如何在Car类中访问方向状态，以便可以在Detour案例类（List [Direction]）中添加消息。所以我目前所拥有的是一个交叉点...

scala akka actor event-based-programming

回答 1 投票 0

akka 相关问题

最新问题