@@ 64-72 (lines=9) @@ | ||
61 | $this->aggregateTypeIdentifier = $reflClass->getShortName(); |
|
62 | } |
|
63 | ||
64 | protected function doDeleteWithLock(AggregateRootInterface $aggregate) |
|
65 | { |
|
66 | if (null !== $this->eventStore) { |
|
67 | $this->eventStore->appendEvents($this->getTypeIdentifier(), |
|
68 | $aggregate->getUncommittedEvents()); |
|
69 | } |
|
70 | ||
71 | parent::doDeleteWithLock($aggregate); |
|
72 | } |
|
73 | ||
74 | protected function doSaveWithLock(AggregateRootInterface $aggregate) |
|
75 | { |
|
@@ 74-82 (lines=9) @@ | ||
71 | parent::doDeleteWithLock($aggregate); |
|
72 | } |
|
73 | ||
74 | protected function doSaveWithLock(AggregateRootInterface $aggregate) |
|
75 | { |
|
76 | if (null !== $this->eventStore) { |
|
77 | $this->eventStore->appendEvents($this->getTypeIdentifier(), |
|
78 | $aggregate->getUncommittedEvents()); |
|
79 | } |
|
80 | ||
81 | parent::doSaveWithLock($aggregate); |
|
82 | } |
|
83 | ||
84 | /** |
|
85 | * Returns the type identifier to use when appending events in the event store. Default to the simple class name of |