щас такая проблема что по jms стартует процесс и мы в нем обновляем некоторую сущность, а когда ее обнавляем нам снова приходит jms что она обновилась и стартует еще один экзекутер для этого процесса, прошлая таска еще не успела закоммититься и вылетает FlowableOptimisticLockingException, вот и надо в тесте это сэмулировать
А если на jms-очереди выставить задержку в доставке?
мне во flowable нужно сэмулировать FlowableOptimisticLockingException а для этого нужно чтоб сервисная таска подождала, пока выполнится в другом execute-ре другая таска
В rxjava/reactor есть же методы для работы с delay
щас такая проблема что по jms стартует процесс и мы в нем обновляем некоторую сущность, а когда ее обнавляем нам снова приходит jms что она обновилась и стартует еще один экзекутер для этого процесса, прошлая таска еще не успела закоммититься и вылетает FlowableOptimisticLockingException, вот и надо в тесте это сэмулировать
Нужно отправлять ивент после коммита естественно. Вообще странный кейс