Skip to content

Commit e411d9a

Browse files
committed
GH-796 - Update transaction markers for newly introduced methods on DefaultEventPublicationRegistry.
1 parent 00bdc76 commit e411d9a

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

spring-modulith-events/spring-modulith-events-core/src/main/java/org/springframework/modulith/events/core/DefaultEventPublicationRegistry.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -113,6 +113,7 @@ public Collection<TargetEventPublication> findIncompletePublicationsOlderThan(Du
113113
* @see org.springframework.modulith.events.core.EventPublicationRegistry#markProcessing(java.lang.Object, org.springframework.modulith.events.core.PublicationTargetIdentifier)
114114
*/
115115
@Override
116+
@Transactional(propagation = Propagation.REQUIRES_NEW)
116117
public void markProcessing(Object event, PublicationTargetIdentifier identifier) {
117118
propagateStateTransition(event, identifier, it -> events.markProcessing(it.getIdentifier()), () -> {});
118119
}
@@ -142,6 +143,7 @@ public void markCompleted(Object event, PublicationTargetIdentifier targetIdenti
142143
* @see org.springframework.modulith.events.core.EventPublicationRegistry#markFailed(java.lang.Object, org.springframework.modulith.events.core.PublicationTargetIdentifier)
143144
*/
144145
@Override
146+
@Transactional(propagation = Propagation.REQUIRES_NEW)
145147
public void markFailed(Object event, PublicationTargetIdentifier targetIdentifier) {
146148

147149
propagateStateTransitionAndConclude(event, targetIdentifier, it -> events.markFailed(it.getIdentifier()), () -> {});

0 commit comments

Comments
 (0)