如何使用 Akka 2.3.x 运行 Play 2.2.x?
有没有办法结合akka 2.3和玩2.2?现在，我在运行此类应用程序时遇到 AbstractMethodError.我需要在一个应用程序中同时使用它们，因为 Akka 2.3 带有非常有用的 akka 持久性模块，该模块非常可靠(与其前身相反)，而且这种可靠性对我来说非常重要.我已经尝试从源代码编译 play 2.2.2 并将那里的 akka 依赖项更改为 2.3，但我仍然遇到相同的错误: [E
..
akka-persistence相关内容
只有在所有事件都被持久化后才更新actor状态
在持久化actor的receive方法中，我收到一堆我想持久化的事件，只有在所有事件都持久化后，再更新我的状态.我该怎么做? def 接收:接收 = {...case NewEvents(events) =>坚持(事件){ singleEvent =>//使用这个单一事件更新状态}//在每个事件都被持久化之后，再做一件事} 请注意，persist() 调用不会阻塞，因此我不能在此之后放置代码.
..
如何在Scala中序列化函数？
我对akka持久性不屑一顾，并遇到了对象序列化的典型问题。我的对象（如下所示）具有基本的类型和功能。我阅读了此 ，此和这，但没有一个帮助我使以下序列化。 测试实用程序 object SerializationUtil { def write（obj：Any）：String = { val temp = Files.createTempFile（null，null）.toFile
..
Akka持久性测试方法
我熟悉此处定义的Akka测试方法： http://doc.akka.io/docs/akka/snapshot/scala/testing.html 我了解如何使用TestKit，TestActorRef，TestProbe等。我也了解我的核心领域逻辑应与Akka隔离地进行提取和测试。 我的问题是关于在Akka Persistence角色（即PersistentActor和Per
..
akka持久性，至少在语义上一次失败后恢复
我头上乱七八糟 避免邮箱中毒 http://doc.akka.io/docs/akka/2.4.2/general/supervision.html 然后，新角色恢复处理其邮箱，这意味着在角色本身之外看不到 重新启动，但值得注意的是 例外，即消息 我的情况：演员收到运行命令的“命令” 。 Actor尝试访问远程服务。服务不可用。引发异常。我希望演员继续与远程服务器联系。我不希望
..
为什么Akka Persisence Query Read Journal不检索我的事件？
我在理解Akka Persistence Query时遇到问题，尤其是方法 eventsByTag ，因为它的行为不像我期望的那样。 class我称为一个开始监听具有特定标记的持久事件的类。 class CassandraJournal（imp val system：ActorSystem ）{ def invokeStreaming = { val readJournal
..
使用Akka执行事件采购时如何在CQRS中逼近Q？
与事件来源结合使用时，是否存在一种进行CQRS的好方法？ 我想到的一种方法是，在命令变成事件并持久保存到事件日志后，在（持久角色的）命令处理程序中执行此操作（这些事件代表Write模型），我将使用事件总线将事件发送给感兴趣的订阅查询参与者，以便他们可以更新其查询模型。 我想的另一种方式（假设该期刊支持）是使用持久性查询（通过Akka Streams），例如 allPersistence
..
Akka持久性查询事件流和CQRS
我正在尝试在我的ES-CQRS体系结构中实现读取端。假设我有一个这样的持久性参与者： object UserWrite { 密封特征UserEvent 密封特征状态 案例对象未初始化扩展状态 案例类User（用户名：字符串，密码：字符串）扩展状态 案例类AddUser（用户：用户） 案例类UserAdded（用户：User）扩展UserEvent 案例类UserEvents（use
..
列族ID不匹配(找到cebcc380-72d4-11e7-9a6b-bd620b945799；预期为c05d6970-72d4-11e7-9a6b-bd620b945799)
如何解决此错误 列族ID不匹配(发现cebcc380-72d4-11e7-9a6b-bd620b945799；预期为c05d6970-72d4-11e7-9a6b-bd620b945799) Caused by: java.util.concurrent.ExecutionException: org.apache.cassandra.exceptions.Configuratio
..
当与Play 2.2.1一起使用时，带有Akka 2.3.0的Akka Persistence Cassandra引发致命的EOFException
您知道为什么在将Akka添加到我的库依赖项并执行test任务后会出现以下错误吗? Uncaught error from thread [reactivemongo-akka.actor.default-dispatcher-4] shutting down JVM since 'akka.jvm-exit-on-fatal-error' is enabled for ActorSystem
..
如何在Akka 2.3.x上运行Play 2.2.x?
有什么方法可以将Akka 2.3与Play 2.2结合起来吗?现在我在运行这样的应用程序时遇到AbstractMethodError.我需要将它们都放在一个应用程序中，因为Akka 2.3附带了非常有用的akka持久性模块，该模块非常可靠(与之前的版本相反)，而这种可靠性在我的情况下非常重要.我尝试从源代码编译play 2.2.2并将akka依赖项更改为2.3，但是我仍然遇到相同的错误:
..
无法通过haproxy连接到cassandra容器
我正在尝试将外部应用程序连接到在mesos集群上运行dockerized的Cassandra。 这些是我在mesos上运行的应用程序： 集装箱ID图像命令创建状态端口名称 137760ce852a cassandra：最新“/docker-entrypoint.s”15分钟前15分钟7000-7001 / tcp，7199 / tcp，9160 / tcp，0.0.0.0:31634
..