-
0 votesanswersviews
Lagom:如何让客户连接到主题
我正在制作使用Lagom的实时琐事应用程序,我希望将当前连接的客户端主题发布给所有用户 . 如何在线获取用户数? -
1 votesanswersviews
使用/公开服务调用合成到同一项目中的多个模块
在Service call composition中,我测试了记录的示例,它按预期工作 public ServerServiceCall logged(ServerServiceCall serviceCall) { return HeaderServiceCall.compose(requestHeader -> { System.out.prin... -
0 votesanswersviews
CQRS(Lagom)elasticsearch read-side
就耐用性而言,我是最可靠的,但我想用它来在读取端存储数据以获得最佳搜索效果 .如果我们在cassandra数据库中存储事件(写入端),这意味着数据永远不会丢失 . 我没有't really understand what is meant with '数据持久性' .如果我们在读取端使用ES,这是否意味着某些数据可能无法正确导入?这是否意味着有一天数据可能会随机丢失,或者有一天所有数据可能已经消失... -
1 votesanswersviews
用于身份验证的Lagom-java示例
是否存在任何带有Lagom框架的OAuth的java示例?或像BootZooka这样的项目,但在Java中 . 我认为Lagom的文档和他们创建的极少数视频根本没用 . -
0 votesanswersviews
Lagom akka-http集成
将 Akka HTTP 服务与/进行 Lagom 集成的最简单的解决方案是什么? 我有两个服务 - akkahttp:8000 和 lagom:9000 ,他们正在为Angular应用程序提供方法 . 为所有服务设置一个 endpoints 会很棒 - x:8888 适用于 x:8888/akkahttp 和 x:8888/lagom . -
0 votesanswersviews
Lagom微服务和Akka HTTP配置位置
我正在使用Lagom 1.4.6并获得 akka.http.scaladsl.model.EntityStreamException: HTTP chunk size exceeds the configured limit of 1048576 bytes 使用ServiceCall获取build.sbt中定义的impl . 也不 akka.http.server.parsing.max-ch... -
0 votesanswersviews
找不到模板:-Dsbt.version 0.13.13 lagom / lagom-scala.g8
下午好, 我试图遵循this hello world tutorial of lagom,但是在运行命令时: sbt new -Dsbt.version=0.13.13 lagom/lagom-scala.g8 我收到以下错误: Template not found for: -Dsbt.version 0.13.13 lagom/lagom-scala.g8 正如教程的设置部分所述,我检查了... -
0 votesanswersviews
Lagom和inter-PersistentEntity引用
在Lagom中,聚合根[DDD]每个都表示为PersistentEntity . 是否有可能一个PersistentEntity解析并保持对不同PersistentEntity的引用?我找不到任何说明这种情况的Lagom示例 . -
2 votesanswersviews
事件标记如何在Lagom中运行?
Lagom reference documentation显示了如何标记事件: object BlogEvent { val BlogEventTag = AggregateEventTag[BlogEvent] } sealed trait BlogEvent extends AggregateEvent[BlogEvent] { override def aggregateTag: ... -
0 votesanswersviews
可以使用Lagom 1.4前向websocket错误消息吗?
我在Lagom中使用流式服务调用 . 一旦我升级到1.4,服务器的错误消息就不会通过websockets传播到客户端 . 这可以使用lagomtestkit进行测试,但不能在使用SBT或实时部署中的“runAll”运行服务时使用 . 使用'runAll',所有失败的客户端调用返回“Peer关闭连接代码1011'内部错误'” 这里的问题很容易诊断 . akka-http 10.0.11 Frame... -
0 votesanswersviews
Lagom lagomServiceLocatorStart无法正常工作 - 连接被拒绝
我创建了一个名为hello-lagom的示例Lagom项目,一切似乎都运行正常 . 但是,当我尝试通过首先启动服务定位器然后像这样运行项目来运行helloworld-impl项目时: activator lagomServiceLocatorStart activator helloworld-impl/run 控制台显示服务定位器正在运行: [info] Service locator is ... -
1 votesanswersviews
Lagom框架/持久读取端/ Cassandra / DataStax /表未配置
我成功编译了http://www.lagomframework.com/documentation/1.0.x/ReadSide.html的代码示例 它是关于CQRS架构的读取端 . 只有问题:它没有运行 . 看起来像配置问题......此时Lagom的官方文档非常不完整 . 错误说: java.util.concurrent.CompletionException: java.util.conc... -
5 votesanswersviews
Lagom ConductR连接拒绝错误
我是lagom-sbt的新手,我正在尝试使用ConductR运行Lagom服务包 . 我在 plugins.sbt 中添加了以下 sbt-conductr 版本 addSbtPlugin("com.lightbend.conductr" % "sbt-conductr" % "2.4.0") 这是我到目前为止所做的 sbt sandb... -
0 votesanswersviews
Lagom:如何在没有Event Sourcing的情况下使用主题
我是Lagom的新手,我想在稍后处理事件采购 . 所以我没有使用persistentEntityRegistry,而是使用一个简单的存储库来进行CRUD操作 . 无论如何,我希望能够在创建操作发生时通知其他服务 . 在hello-lagom项目中,主题实现如下: override def greetingsTopic(): Topic[GreetingMessage] = TopicProdu... -
0 votesanswersviews
Lagom Kafka意外关闭错误
在Lagom Dev Enviornment中,使用lagomKafkaStart启动Kafka之后 有时它显示KafkaServer意外关闭,之后我需要运行clean命令再次运行它 . 请建议这是预期的行为 . -
0 votesanswersviews
无法覆盖lagom kafka参数
我创建了一个普通的java项目,并将lagom kafka客户端的所有依赖项放在classpath上,然后在源文件夹中放入application.conf application.conf的内容 lagom.broker.kafka { service-name = "" brokers = "127.0.0.1:9092" } 在运行应用程序... -
0 votesanswersviews
Lagom只支持REST吗?
我知道这是一个奇怪的问题......毕竟,为什么这些天会有人使用SOAP?但我想 Build 一个概念证明,我需要生成一个SOAP服务 . 对我来说,如何在Lagom中完成这一点并不明显,但从文档来看,它似乎非常关注REST,因此对于我正在做的事情看起来并不是一个好的选择 . -
1 votesanswersviews
Lagom框架的新微服务
如何将新的Micro Service添加到Lagom Framework . 我有一个默认的Micro-Services你好的Lagom项目 . 我想使用Maven构建工具添加更多微服务 . -
0 votesanswersviews
在Lagom使用泽西过滤器
阅读文档但无法找到使用泽西过滤器(ContainerRequestFilters,Filters等)的支持 . 有人可以请一些在lagom中使用泽西过滤器的例子吗? -
0 votesanswersviews
拉格姆与 Spring 天
Lagom默认使用Google Guice作为实现DI模式 . 我想改用Spring Framework . 可能吗?如果是这样,应该怎么做? 我已经成功地将Akka与Spring集成(使用来自文档和Internet的提示),但是在关于与Spring集成的文档中找不到任何内容 . -
0 votesanswersviews
带有SSL / TLS的Lagom
是否可以将Lagom配置为使用SSL / TLS连接? 我使用Java KeyTool生成了密钥库和信任文件, 我试图在application.conf文件中配置play框架来处理生成的文件但没有成功 . 谢谢您的帮助 . -
3 votesanswersviews
我应该在哪里定义Lagom中的自定义(de)序列化器?
我开始在Java中使用Lagom并且需要编写自定义(de)序列化程序 . 我已经阅读了文档并了解了NegotiatedSerializer,MessageSerializer,SerializerFactory等的角色 . 我不明白的是在哪个包中定义类是规范的 . 我查看了Chirper示例,看到在各种* API模块中的* Service接口旁边经常有具体的模型定义,但是没有自定义序列化器的示例 ... -
1 votesanswersviews
Lagom Cassandra司机
根据一些关于Lagom和Cassandra的研究,我发现: Lagom使用DataStax Java Driver for Cassandra,和 DataStax Java驱动程序仅支持Cassandra 3.0.x(link) 所以,如果我想使用Cassandra 3.11和Lagom,我该怎么做: 我应该使用像Achilles,PlayORM,......(link)这样的另... -
0 votesanswersviews
在SBT项目中找不到lagom-javadsl-api
我是Lagom和SBT的新手,我正在尝试使用IntelliJ执行我的第一个项目 . 我的项目结构是: 我的SBT版本是: sbt.version = 0.13.16 plugins.sbt文件包含: // The Lagom plugin addSbtPlugin("com.lightbend.lagom" % "lagom-sbt-plugin" % ... -
0 votesanswersviews
Lagom发送自定义标头
我正在使用自定义标头向 Non lagom service 发送POST请求时使用Lagom POC . 在我的情况下,我试图打postman-echo来测试自定义 Headers . 但是,虽然我相应地更改了代码,但它看起来没有设置标头: public CompletionStage<DsapAuthorizationResponse> hitAPI(AuthorizationRe... -
1 votesanswersviews
错误Angularjs Lagom框架
选项http://localhost:9000/api/chat/ 404(未找到)XMLHttpRequest无法加载http://localhost:9000/api/chat/ . 预检的响应具有无效的HTTP状态代码404 -
0 votesanswersviews
如何将事件存储在Lagom框架中
Lagom提供事件源设计模式 . 它将事件存储在数据库中,并构造从数据库检索时的状态 . 它是如何实际存储的 . 它是JSON还是任何其他二进制格式?鉴于Lagom支持Nosql以及rdbms,从RDBMS切换到noSql时有什么不同吗? -
0 votesanswersviews
Lagom将实体事件发布为websocket连接的Source
是否有可能(如果是,如何),直接发布实体更新流(没有任何其他主题)作为从这样的服务返回的Source? public ServiceCall<NotUsed, Source<EntityPublicEvent, ?>> entityUpdates() 我想要实现的是通过websocket在Angular 5中使用那些事件 . @Override publi... -
1 votesanswersviews
使用Lagom固定腹板
使用lightbend Lagom框架我正在尝试连接到Binance的websocket api . 但是,我在连接时遇到以下错误: 400普通HTTP请求已发送到HTTPS端口 是否可以从Lagom连接到安全的websocket服务?使用WebSocketClient?我有以下代码: trait BinanceStreamingService extends Service { de... -
0 votesanswersviews
从Lagom / Akka Kafka主题订阅者为Websocket创建源代码
我希望我的仅限Lagom订阅者服务订阅Kafka主题并将消息流式传输到websocket . 我使用此文档(https://www.lagomframework.com/documentation/1.4.x/scala/MessageBrokerApi.html#Subscribe-to-a-topic)作为指导,定义如下服务: // service call def stream():...