axon

    2热度

    1回答

    假设我有一个在几毫秒内转账的传奇。我有调用触发佐贺的命令的REST控制器。我该如何等待传奇的结尾来检查结果或异常,让我的控制器作为回应返回?如果它只是一个不会触发传奇的单独命令,我可以使用命令网关和回调函数来通知我成功或失败。 UPDATE: 我能够有我的控制器返回响应佐贺通过结束后: 1)我的控制器方法返回DeferredResult我保存到地图 2)我控制器有一个事件处理程序,用于侦听结束事件

    0热度

    1回答

    对于我的Java EE(7)项目,我想使用Axon框架。 Axon ReplayingCluster的其中一个参数是TransactionManager,但Axon仅支持NoTransactionManager和SpringTransactionManager。 但是,如果我没有误认为JTA,交易已由应用程序服务器在EntityManager(我已存储在JpaEventStore中)管理。 我的问

    1热度

    1回答

    使用轴突框架我有错误后为非空: Aggregate identifier must be non-null after applying an event. Make sure the aggregate identifier is initialized at the latest when handling the creation event. I use this StorageEngin

    1热度

    1回答

    我刚开始探索基于事件的轴测框架跟踪。我看到有人支持提高和处理事件。 我有一个场景,有多个服务与不同的实例/ jvm使用http进行通信。 我现在想使用事件进行服务通信。我不确定我们如何通过网络传递事件,并让它们由运行在不同jvm/host中的服务处理。 axonframework是否为此提供任何支持,还是应该直接与此消息中间件集成。

    0热度

    1回答

    我们担心为域事件使用单个Mongo集合(domainevents)的性能。 将domainevents集合拆分为每个聚合根分离集合是一个好主意吗? 我们有查询模型,它是基于多个聚合根的事件生成的。如果我们将domainevents划分为多个集合,那么Axon仍然会保留聚合根上的事件顺序吗? 这是否是一个好主意?

    0热度

    1回答

    我有一个用例,我想发布一个非状态chaininging事件作为触发器。 在绝大多数情况下,聚合会通过应用它们来发布事件。但是,有时需要将事件(可能来自另一个组件内)直接发布到事件总线。要发布事件,只需在EventMessage中包装描述事件的有效负载即可。 GenericEventMessage.asEventMessage(Object)方法允许您将任何对象封装到EventMessage中...

    2热度

    1回答

    我正在开发一个小的cqrs实现,我对它很陌生。 我想分离每个处理程序(命令和事件)从聚合和 确保所有工作正常。命令处理程序从控制器被触发 ,但从那里触发事件处理程序。 任何人请帮助。 public class User extends AbstractAnnotatedAggregateRoot<String> { /** * */ private static final long s

    0热度

    1回答

    我发送命令,并通过CommandGateway.sendAndWait(对象命令,长超时,TIMEUNIT单元)方法期待一个结果从超时无效响应: Greeting greeting = commandGateway.sendAndWait(new GenericCommandMessage<GetGreetingCommand>(cmd), 1000, TimeUnit.MILLISECONDS)

    5热度

    2回答

    我一直在寻找比AxonFramework的传奇更加复杂的工作流程 - 我们正在使用它 - 我在Netflix指挥中找到了一个。 不幸的是,我在互联网上搜索了一个体面的例子,但无济于事。 我的问题是,在Netflix Conductor中,如何定义和创建Task或WorkflowTask,最重要的是,将微服务链接到它?这是来自github的Netflix Conductor代码: WorkflowD

    3热度

    2回答

    在Vaughn Vernon的Implementing Domain-Driven Design书中,他描述了在聚合根中使用工厂方法。一个例子是Forum聚合根,其中startDiscussion工厂方法返回Discussion聚合根。 public class Forum extends Entity { ... public Discussion startDiscus