lagom

    0热度

    1回答

    只是想知道事件通知从持久事件源actor到读取处理器在lagom中的保证,有没有或没有消息持久性事件通知读取处理器将更新查询端? 我知道最终的一致性很好,但我正在谈论事件处理程序通知给Cassandra读取处理器。

    1热度

    1回答

    我正在创建lagom简单应用程序,定义一个休息终点并使用休息客户端邮递员命中终点。但作为回应,我得到了,行动没有发现错误。我与lagom整合阿卡,以下是我的代码: 服务: trait TwitterSchedulerService extends Service { def doWork: ServiceCall[NotUsed, Done] override def de

    0热度

    1回答

    我在lagom项目中创建了一个模块。我的模块只有卡夫卡消费者消费消息并将消息事件存储在卡桑德拉中。感谢为什么,在我的LagomApplicationLoader我没有定义任何服务,并初始lagomServer空与LagomServer.forServices()。但每当,我开始了我的申请,我得到以下异常: java.lang.IllegalArgumentException at com

    0热度

    1回答

    我试图实现一个使用Lagom 1.2.2设置的消息代理,并且碰到了墙壁。该文件对服务描述符下面的例子: default Descriptor descriptor() { return named("helloservice").withCalls(...) // here we declare the topic(s) this service will publish to

    1热度

    1回答

    在Lagom中,似乎从服务定位器加载的接触点只接受一个URI。我们如何指定多个cassandra接触点? lagom.services { cas_native = "tcp://10.0.0.120:9042" } 我已经尝试在akka持久性配置中设置接触点,但似乎并没有覆盖服务定位器配置。

    1热度

    3回答

    如何从Lagom的http请求中访问URL查询参数?我有一个要求,其中查询参数集是无限的和无限的。我想以地图的形式访问查询参数。有没有办法做到这一点?

    0热度

    1回答

    我使用@JSONCreator和@JsonCreator在Lagom框架中将响应bean转换为JSON。但是,JSON没有格式化。我如何使用注释(不是ObjectMapper)打印JSON?下面是我的示例响应豆: @Immutable @JsonDeserialize public class foo { private final List<Result> _result;

    0热度

    1回答

    我一直在试图为我的Lagom安装设置外部Cassandra。 在根POM我已经写 <configuration> <unmanagedServices> <cas_native>http://ip:9042</cas_native> </unmanagedServices> <cassandraEnabled

    1热度

    1回答

    我玩过lagom-scala-word-count激活器模板,我被迫终止了应用程序。自那时起嵌入式卡夫卡不起作用 - 这个项目和我创建的每一个新东西都变得无法使用。我已经试过: 运行SBT干净,删除嵌入卡夫卡数据 创造全新的项目(从其他激活模板) 重新启动我的机器。 尽管如此,我无法让Lagom工作。在第一次发射我获得以下行日志: [warn] o.a.k.c.NetworkClient - Er

    0热度

    1回答

    阅读文档,但找不到支持使用球衣过滤器(ContainerRequestFilters,过滤器等)。 有人可以在lagom使用泽西过滤器的一些例子吗?