Aggregate，DomainEvent with Prooph

文章/答案/技术大牛

发布

1回答

php、events、aggregate、domain-events、prooph

我使用过Prooph，并且创建了简单的聚合和域事件，它们只处理单一的实体类型。但现在我在想，聚合和领域事件是否应该特定于这些第三方网站抓取器。

浏览 10提问于2017-08-09得票数 0

1回答

如何避免使用prooph的事件源？

prooph

所以我不会使用Prooph/事件源组件，这就是为什么Prooph的团队不会维护事件源组件的原因。(会议) 问题来了，聚合、DomainEvent等属于领域层，它们都放在事件源组件中.事件存储属于基础设施层，所以我可以直接使用prooph/事件存储组件。然而，我发现Prooph\EventSourcing\Aggregate\AggregateRepository类在prooph/event-store-symfony-bundle中被使用，

浏览 3提问于2018-11-28得票数 0

回答已采纳

2回答

异步等待，代码永远不会执行

c#、asynchronous、async-await

我的问题是，代码永远不会到达aggregate.MarkChangesAsCommitted方法和下一个await。public async Task CommitChanges() foreach (var aggregate in _trackedAggregates.Values){ await _eventStorage.Save(aggregate.Idusi

浏览 7提问于2014-05-01得票数 1

回答已采纳

1回答

在使用Spring Data Common时，是否可以在聚合根的构造函数中注册域事件

domain-events、spring-data-commons

像这样repo.save(aggregate); private TeacherId teacherId; }@ToString()pub

浏览 1提问于2018-08-29得票数 0

1回答

进入Laravel CommandBus的Prooph无法识别CommandHandler

php、laravel、cqrs、event-sourcing、prooph

我有一个laravel 5.7应用程序，我想在其中添加用于事件采购的prooph。我已经按照说明进行了操作，但是我检索到了这个错误： Prooph\ServiceBus\Exception\RuntimeException: CommandBus was not able to identifya CommandHandler for command App\src\Prooph\Model\Procedure\Command\ChangeProcedureState in /var/www/html/

浏览 9提问于2018-11-21得票数 0

1回答

groupByKey创建重新分区主题，即使没有关键更改。

apache-kafka、apache-kafka-streams、spring-cloud-stream

stream) { Serde<SlotSlot.class); .groupByKey(Serialized.with(Serdes.String(), domainEventSerde)) .g

浏览 0提问于2018-04-07得票数 1

回答已采纳

2回答

覆盖分部类中的抽象方法

c#、inheritance、abstract-class、partial-classes、auto-generate

我有一个名为PersonAbstract的抽象类。它有一个名为Age的抽象属性两个类Customer和Employee扩展了PersonAbstract。这两者的自动生成代码：{ { } { }我使用分部类向Employee和Cus

浏览 2提问于2012-03-29得票数 0

回答已采纳

2回答

如何使用spring正确发布DDD域事件？

java、spring、domain-driven-design

下面是我的基本Aggregate类： private final DomainEventPublisher domainEventPublisher; domainEventPublisher.publish(domainEventDomainEventImpl());} 这是我的DomainEvent

浏览 2提问于2019-10-04得票数 6

回答已采纳

1回答

将依赖项注入DBContext的正确方法

c#、asp.net-core、.net-core、entity-framework-core、domain-driven-design

CancellationToken()) var aggregates = ChangeTracker.Entries<IAggregateRoot>().ToList(); { {await _bus.Publish(domainEvent, doma

浏览 2提问于2020-06-20得票数 1

1回答

是否可以使用Prooph设置事件created_at时间？

event-sourcing、prooph

我正在评估证据是否适合这个项目。我阅读了这些文档，但是它们没有涵盖这个案例，我不知道如何像这样使用它，或者我想要做的事情在事件来源方面是否有意义。[ {"time": "2021-11-08 10:22:00", "setting": "on"},

浏览 2提问于2021-11-06得票数 1

回答已采纳

1回答

用于聚合的清洁架构存储库包装器

c#、mongodb、repository、domain-driven-design、clean-architecture

;using SharedKernel.Domain.UniqueKey; public interface IEventRepository Task SaveAsync(IEnumerable<DomainEvent> events); Task<IEnumerable

浏览 9提问于2022-09-26得票数 0

回答已采纳

1回答

kafka流中的Aggregration和国营商店保留

apache-kafka-streams

final KStream<String, DomainEvent> inputStream....final KStream<String, DomainEvent> outputStream = inputStream .groupByKey(Serialized.with(Serdes.String(), jsonSerde)) .aggreg

浏览 0提问于2018-07-22得票数 9

回答已采纳

1回答

为什么该方法使用Activator.CreateInstance而不是直接使用"new ()“？

GetNotificationCorrespondingToDomainEvent In 方法中，它有以下方法：{ typeof(DomainEventNotification<>).MakeGenericType(domainEvent</em

浏览 1提问于2022-02-12得票数 0

回答已采纳

3回答

是否不能转换具有“where”类型约束的泛型参数？

c#、generics

我有一个基类：{public class DomainEventPublisher private List<DomainEventSubscriber<DomainEvent>> subscribers; public void Subscribe<T>(DomainEventSubscr

浏览 13提问于2013-05-06得票数 7

回答已采纳

1回答

在ES:索引名称中包含Alpakka索引的Akka流仅在开始执行时进行评估

elasticsearch、akka、akka-stream、alpakka

val elasticSettings = ElasticsearchSinkSettings(bufferSize = 10) ElasticsearchFlow.create[DomainEvent](index, "domain-event", elasticSettings

浏览 0提问于2018-04-18得票数 4

1回答

如何在带有身份的CQRS模式中为用户表引发事件

asp.net、asp.net-identity、cqrs

IReadOnlyCollection<BaseEvent> DomainEvents => _domainEvents.AsReadOnly(); { } { _domainEve

浏览 17提问于2022-11-17得票数 0

回答已采纳

2回答

PersistentFSM执行元中的Stackoverflow异常

scala、akka

case class DoTransaction(item: String, amount: Int, change: Double) extends DomainEvent case class Reject(reason: String) extends Domain

浏览 2提问于2016-04-05得票数 5

1回答

对事件源中的命令、域事件和外部事件感到困惑

domain-driven-design、microservices、event-sourcing、aggregate

= Map(command) }事件发布，现在是事件处理程序的时间。class SpecialOfferActivatedDomainEventHandler{ product.Apply(domainEvent) }好了。

浏览 0提问于2019-02-05得票数 5

1回答

轻型事件--平原期货或Akka

scala、playframework、akka、akka-persistence

有一些用例如下所示。2)现在后端需要生成并触发CreateUser事件，这会将用户创建为第三方应用程序(例如，我们可以说它将createUser变成一个外部权限系统)。这是完全异步和后台类型的过程，客户端既不知道它，也不等待这个API的成功或失败。但是，对此CreateUser事件的所有调用都必须与其失败或成功一起记录，以便进行审计和补救(如果发生故障)。 First approach是为这些异步事件设计基于Future的异步API(应用程序

浏览 2提问于2014-07-02得票数 0

1回答

DDD在PHP -> DomainEventPublisher ->中的subscribe方法在哪里使用？

php、domain-driven-design、domain-events

$domainEvent) $this->recordThat($domainEvent); } { $this->recordedEven

浏览 28提问于2016-11-17得票数 1

点击加载更多