Python
Java
PHP
IOS
Android
Nodejs
JavaScript
Html5
Windows
Ubuntu
Linux
如何在超时的情况下在单独的调度程序上运行 Akka Streams 图?
这个问题是基于我做过的一个宠物项目 这个SO https stackoverflow com questions 34641861 akka http blocking in a future blocks the server 34645
scala
akka
akkastream
akkahttp
如何在 IntelliJ IDEA 中运行 akka actor
来自 Akka 网站文档 然后 这个主要方法将创建所需的基础设施 运行演员 启动给定的主要演员并安排 一旦主要参与者终止 整个应用程序就会关闭 因此 您将能够使用类似于以下的命令运行上面的代码 下列的 java classpath akka
Java
intellijidea
akka
Akka Stream Graph 恢复问题
我创建了一个图表来并行化具有相同输入的两个流 这些流产生 Future Option Entity 如果 flowA 失败 我想返回 Future None 但恢复似乎没有被调用 val graph Flow Input Future Op
scala
akka
akkastream
在 Akka 中配置嵌套 Router
我有一些嵌套的路由器 应创建它FromConfig 我想要的是这样的 test akka actor deployment worker router round robin nr of instances 5 slave router b
scala
routes
config
akka
案例类和案例对象之间的区别?
我正在学习 Scala 和 Akka 并且在最近的查找中solution https stackoverflow com questions 22770927 waiting for multiple results in akka 我发现
scala
akka
知道 akka actor 何时完成
有几个人和我一起从事一个项目 一直在试图找出解决这个问题的最佳方法 看起来这应该是经常需要的标准东西 但由于某种原因我们似乎无法得到正确的答案 如果我有一些工作要做 并且我向路由器抛出一堆消息 我如何知道所有工作何时完成 例如 如果我们正在
Java
akka
玩 Scala Akka WebSockets 更改 actor 路径
我遵循使用 Scala Play 和 Akka Actor 创建 Web 套接字的示例 https www playframework com documentation 2 5 x ScalaWebSockets Handling Web
scala
playframework
WebSocket
akka
如何解析 Spray-routing 中的 get 请求参数?
这就是代码部分的样子 get respondWithMediaType MediaTypes application json entity as HttpRequest obj gt complete println obj ok 我可以
scala
HttpRequest
akka
spray
如何使 scalatest 与 Spraytestkit 和 HttpServiceActor 一起工作
我在看Spray 1 3 1 测试套件文档 http spray io documentation 1 2 1 spray testkit 但找不到下面我需要的正确示例 我有这个样本spray 1 3 1 service trait MyS
scala
akka
spray
Akka 和 ReactiveMongo
我正在尝试找到在集群工作人员之间共享相同连接池的最佳方法 我有以下结构 Master Actor gt Worker Actors 最多 100 个或更多 gt MongoDB 我想在工作人员和 MongoDB 之间放置reactivemo
MongoDB
scala
akka
Actor
reactivemongo
Akka Testkit 错误且版本不明确
我正在使用 Akka testkit 库来测试我的一些演员 这是我的 build sbt 中的内容 com typesafe akka akka testkit 2 6 10 Test 这是我得到的错误 java lang IllegalS
sbt
akka
如何将 sbteclipse 插件添加到 SBT 0.10.x
我想查看akka的源代码 似乎使用的是0 7 x版本的sbt 我将项目配置转换为0 10 x版本 当我在库依赖项中添加 sbteclipse 并运行 eclipse create src 生成 eclipse 项目时 它告诉 eclipse
eclipse
scala
sbt
akka
Akka、SQS 和 Camel 的消费者投票率
我正在做的一个项目需要从SQS读取消息 我决定使用Akka来分布式处理这些消息 由于 Camel 支持 SQS 并且在 Consumer 类中内置了 Akka 中使用的功能 因此我认为最好以这种方式实现端点并读取消息 尽管我还没有看到很多人
scala
apachecamel
akka
amazonsqs
为什么我的 akka 日志记录不能在游戏中运行
我的日志记录在我的播放代码中工作正常 但我的 akka 代码没有记录到文件 标准输出 class EmailActor extends Actor with ActorLogging import EmailActor log info e
scala
playframework
akka
如何隐藏 Akka 远程 Actor 来查找?
我正在运行 Akka 2 0 2 微内核 并希望为不受信任的远程参与者实现身份验证方案 首先想到的是设置一个身份验证参与者 当身份验证成功时 该参与者会返回对工作参与者的引用 但是 我应该如何保护工作参与者不被简单地通过 actorFor
scala
authentication
remoting
Actor
akka
使用 Akka java API 时 Kotlin 类型推断编译错误
我想在 Kotlin 程序中使用 Akka java API 当我想设置时onCompleteakka 的回调Future 我遇到了 Kotlin 编译器错误 而 java 等效项工作得很好 val future Future
Java
akka
typeinference
kotlin
Akka HTTP 连接池在几个小时后挂起
我有一个 HTTP 连接池 在运行几个小时后挂起 private def createHttpPool host String SourceQueue HttpRequest Promise HttpResponse val pool Ht
scala
akka
akkahttp
如何处理 Akka 子 actor 的长时间初始化?
我有一个演员 它创建一个子演员来执行一些冗长的计算 问题是子 Actor 的初始化需要几秒钟 并且父 Actor 在子 Actor 创建和完全初始化之间发送给子 Actor 的所有消息都将被丢弃 这是我正在使用的代码的逻辑 class Ch
scala
akka
Actor
为什么参与者“询问”模式被视为反模式或“代码味道”?
据我所知 询问 模式被认为是一种不好的做法 应该避免 相反 推荐的模式是 每个请求的参与者 模型 然而 这对我来说没有意义 因为 询问 模式正是这样做的 它为每个请求创建一个轻量级参与者 那么为什么这被认为是不好的 特别是当 future
scala
akka
Actor
Akka 通过可堆叠行为拦截接收
Akka 和 Scala 新手 请根据需要随意编辑问题 以便清楚地表达我在 Scala 和 Akka 领域的意图 在展示代码片段之前 这是我想要解决的问题 我本质上想开发一个通用模块 供我的团队在使用 Akka Actor 开发应用程序时使
scala
akka
slf4j
Interceptor
MDC
1
2
3
4
5
6
...10
»