1回答
我有一个Lagom服务，它将持久化实体的事件写入cassandra。我想通过嵌入一个连接到同一个cassandra的读取端处理器来处理来自另一个应用程序(不是基于lagom)的这些事件。我没有找到任何关于如何将lagom服务或读取端处理器嵌入到现有java/scala应用程序中的文档，这是可能的吗？
浏览 24提问于2020-05-31得票数 0
1回答
没有提到任何关于MongoDB支持的内容，但是Lagom似乎有JPA和JDBC支持。
可以用作MongoDB和Lagom之间的JPA接口吗？
浏览 1提问于2017-05-08得票数 4
回答已采纳
1回答
我有一个读取端，它应该向Cassandra写入条目，我想编写一个测试，确保向读取端发送一个事件，然后在Cassandra中检查行是否确实已经写入。如何在测试中访问Cassandra会话？
浏览 19提问于2020-05-14得票数 0
阅读lagom文档，我们可以使用读取端处理器和message broker api构建读取端。
使用一种比使用另一种有什么优势？在对一些应用程序进行原型设计时，我注意到读取端处理器在事件持久化到事件日志和读取模型更新之间具有比Broker Api更高的延迟。
浏览 0提问于2018-05-06得票数 0
我在谷歌上搜索，但除了Cassandra阅读端文档页面之外，没有找到任何其他链接。所以，我只想问Akka-Cassandra包中是否已经包含了用于批量插入行的API或函数，或者我必须多次调用insert代码才能插入多行。
浏览 2提问于2017-09-27得票数 0
1回答
Q1。是不是每个事件都有不同的分片编号？Q3。即使在不同的分片中使用不同的标签对事件进行分片，如何保持顺序？ ProductAdded-2 UserCreated-2 U
浏览 0提问于2019-12-30得票数 0
我已经实现了一个读取端处理器来放置已处理的事件并维护一个读取端cassandra表。但是，发现事件源在一段时间后失败，并出现此错误。很少有事件被处理并存储在表中。
浏览 2提问于2018-09-24得票数 0
1回答
在Lagom中，此服务可以跨单个集群的多个节点运行。Hello-Service-2, Hello-Service-3,
Cluster2: Hello-Service-4, Hello-Service-5, Hello-Service-6 我想要实现的是读取端处理器和事件消费者更好的可扩展性： 在Lagom中，我们需要预先设置集群中给定事件标签的分片数量。(假设我正在构建一个多租户应用程序，我将根据组织id对实体进行分片，这样一组组织的所有实体都将进入
浏览 8提问于2019-06-03得票数 2
只是想知道事件通知从持久性事件源参与者传递到lagom中的读处理器的保证，是否存在或没有消息持久性来将事件通知传递到将更新查询端的读处理器？我理解最终的一致性，这是很好的，但我说的是事件处理程序通知卡桑德拉读处理器。
浏览 3提问于2017-02-15得票数 0
回答已采纳
2回答
我正在使用Lagom框架，并通过mvn测试运行测试。使用com.google.inject.CreationException测试失败。was while locating for parameter<init>at
com.lightbend.lagom.javadsl.s
浏览 0提问于2017-10-14得票数 1
升级到1.4之后，来自服务器的错误消息不会通过websockets传播到客户端。这在使用lagomtestkit进行测试时起作用，但在使用SBT中的“runAll”运行服务或在活动部署中运行服务时则不起作用。使用“runAll”，所有失败的客户端调用都会返回“代码1011‘内部错误的对等关闭连接”。
这里的问题很容易诊断。Akka-HTTP10.0.11 FrameOutHandler的第66-68行创建WebSocket closeFrame，抛出异常中传递的内容并返回“内部错误”，尽
浏览 0提问于2018-02-13得票数 0
回答已采纳
1回答
我一直在尝试为我的Lagom设置设置一个外部的Cassandra。在我写的root pom中 <unmanagedServices>MoreExecutors.java:310))lagom.persistence.
浏览 8提问于2017-03-07得票数 0
回答已采纳
我知道特定实体的事件是在读取端按顺序处理的，但我认为下一个事件的处理不会等到前一个事件成功处理并更新数据库。
我说的对吗？如果是的话，那么是否有一种方法可以强制一个事件仅在成功处理之前的事件并更新读取端数据库时才在读取端处理？
浏览 2提问于2017-12-29得票数 0
回答已采纳
1回答
因为我找不到任何用Lagom构建的“真实”应用程序的例子，所以我很难找到Lagom的方法。我不得不猜测什么是最好的练习，我总是害怕陷入陷阱。帐户属于用户，但可以在用户之间“共享”(使用某种授权系统，一个用户是管理员，另一个用户可以读取或编辑帐户)。交易有一个可选的“借方”账户、一个可选的“贷方”账户和一个始终为正的金额。the复制数个accounts.中的事务，会发生什么？我认为事务有自己的服务。在这种情况下，我可以在记录交易时使用Kafka发布事件，这样帐户实体就可以“更新”它的余额。I的事务事件设置一个读
浏览 3提问于2020-05-10得票数 1
回答已采纳
2回答
为了学习lagom，我创建了一个简单的应用程序，其中包含一些简单的持久实体和一个持久的读取端(根据官方文档，使用cassandra)我可以看到实现这一目标的几种方法
浏览 0提问于2018-10-16得票数 0
我成功地从编译了代码示例唯一的问题是:它不能运行。lagom.persistence.read-side.cassandra.contact-points = ["127.0.0.1"]
lagom.persistence.read-side.ca
浏览 2提问于2016-05-15得票数 1
我被困在如何使用拉古姆的读端处理器与图形。为了给您一个想法，下面是使用Cassandra和lagom的代码。import akka.NotUsed;import com.lightbend.lagom.javadsl.persistence.cassandra.CassandraSession
浏览 3提问于2018-05-28得票数 1
回答已采纳
我正在Lagom (scala)中构建一个身份验证服务，它由一个设备实体和一个事件处理器组成。该服务使用JDBC插件，而不是默认的Cassandra。在编写集成测试时，我发现事件处理器并不是仅用于初始化的事件。我不知道怎么接近..。persistentEntityRegistry.register(wire[DeviceEntity])}
集成测试</e
浏览 6提问于2018-01-02得票数 0
回答已采纳
我对Lagom框架还很陌生，我正在寻找最好的方法来吸引我的分布式应用程序的所有用户。//...我也在上面检查了这个
很明显，读取端的概念适用于用户服务的一个实例。但是，在生产环境中，我应该让同一服务的多个实例可以在多个节点上运行。在这种情况下，我认为每个服务都应该有自己的
浏览 0提问于2018-01-08得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
