|
@@ -217,7 +217,6 @@ public class EntityEventListener implements EventListener, Ordered {
|
|
.collectList()
|
|
.collectList()
|
|
.flatMap((list) -> {
|
|
.flatMap((list) -> {
|
|
List<Object> after = createAfterData(list, context);
|
|
List<Object> after = createAfterData(list, context);
|
|
- context.set(readyToUpdateContextKey,after);
|
|
|
|
updated.set(Tuples.of(list, after));
|
|
updated.set(Tuples.of(list, after));
|
|
return sendUpdateEvent(list,
|
|
return sendUpdateEvent(list,
|
|
after,
|
|
after,
|
|
@@ -301,9 +300,11 @@ public class EntityEventListener implements EventListener, Ordered {
|
|
.setParam(dslUpdate.toQueryParam())
|
|
.setParam(dslUpdate.toQueryParam())
|
|
.fetch()
|
|
.fetch()
|
|
.collectList()
|
|
.collectList()
|
|
|
|
+ .doOnNext(list->{
|
|
|
|
+ context.set(readyToDeleteContextKey, list);
|
|
|
|
+ })
|
|
.filter(CollectionUtils::isNotEmpty)
|
|
.filter(CollectionUtils::isNotEmpty)
|
|
.flatMap(list -> {
|
|
.flatMap(list -> {
|
|
- context.set(readyToDeleteContextKey,list);
|
|
|
|
deleted.set(list);
|
|
deleted.set(list);
|
|
return this
|
|
return this
|
|
.sendDeleteEvent(list, (Class) mapping.getEntityType(), EntityBeforeDeleteEvent::new);
|
|
.sendDeleteEvent(list, (Class) mapping.getEntityType(), EntityBeforeDeleteEvent::new);
|
|
@@ -476,6 +477,6 @@ public class EntityEventListener implements EventListener, Ordered {
|
|
|
|
|
|
@Override
|
|
@Override
|
|
public int getOrder() {
|
|
public int getOrder() {
|
|
- return Ordered.LOWEST_PRECEDENCE;
|
|
|
|
|
|
+ return Ordered.LOWEST_PRECEDENCE - 100;
|
|
}
|
|
}
|
|
}
|
|
}
|