有没有办法关闭 Akka 的调试输出?
在使用 Akka 时,我实现了一个简单的命令行应用程序。 但是 Akka 也会将语句打印到命令行,例如: [GENERIC] [27.10.11 22:57] [RemoteClientStarted(…
禁用 Akka STM (Multiverse) 的日志记录
我正在使用 akka stm ,当我的应用程序启动时,它会打印出来(到stderr): Okt 20, 2011 10:17:10 AM org.multiverse.api.GlobalStmInstance Informa…
如何定义更简洁的scala函数
我正在使用 akka 库并提供一个部分函数,以便由参与者在运行时通过热交换来实现。 akka 热交换采用 PartialFunction[Any, Unit] 形式的参数。我的…
让两个本地实例与 Akka Actor 通信所需的最少代码是什么?
我想知道在一台机器上启动两个应用程序实例所需的最少代码是什么,这两个实例可以相互发送和接收消息。 据我了解,我需要 启动一个可以处理消息的演员…
为什么使用 akka eventhandler 进行日志记录
在以下文档中,事件处理程序被描述为取代日志记录 http://akka.io/docs/akka/1.2/general/event -handler.html 有一个事件处理程序取代了 Akka 中的日…
使用spray/scala从发布请求中获取表单参数
我对 Scala/Spray 真的很陌生。通过一些测试,我能够使用参数函数从 Get 请求中获取参数。不过,我试图在请求正文中获取从 POST 请求发送的一些参数。…
使用 akka future 和 actor 并行化列表
我想向参与者发送消息列表,在未来立即收到回复,然后等待所有未来完成,然后再返回调用方法。通过阅读 akka 文档,我相信 Future.sequence 是可行的…
Akka 集群 Java API 示例
我对测试 2.0-SNAPSHOT Akka 集群功能非常感兴趣,但出于我的目的,我想在 Java 中执行此操作。 我已阅读此处的示例: http://letitcrash.posterous.c…
与 Scala.Actors 相比,如何正确设置 Akka.Actors
如何运行 2 个 Akka Actor,调用者每 n 秒向消费者发送一条消息? 由于 Scala.Actors 库中没有循环反应方法,我陷入了困境 不知何故,以下内容将不会…
使用 Java API 的 Akka-Camel 集成模块示例
有人可以给我指出一个使用 Akka Camel 集成模块的示例 - 使用 Java API。我有一个用例,其中调用 REST 服务,该服务将并行启动一些 Akka Actor 来处理…
如何取消发布 Akka Camel 消费者?
在我向 Camel 消费者 actor 发送消息后,它不会被取消发布。这可以防止应用程序关闭。如果我只是启动和停止演员而不发送任何消息,它就会起作用。我在…