Изменение состояния прослушивания в автомате состояний реактивной пружины ⇐ JAVA

[Anonymous]

Я работаю над реактивным Java-проектом с конечным автоматом Spring версии 3.2.1. Мне нужно реактивно сохранять и объект каждый раз, когда состояние изменяется.
Раньше, когда я использовал Spring State Machine 2.x без реактивности, мне просто нужно было расширить StateMachineInterceptorAdapter и переопределить preStateChange на получите идентификатор объекта из
заголовка сообщения, затем получите объект, обновите статус объекта и сохраните его. Примерно так:

Код: Выделить всё

public class BookingMachineInterceptor extends StateMachineInterceptorAdapter {
private final BookingRepository bookingRepository;
@Override
public void preStateChange(State state, Message message,
Transition transition, StateMachine stateMachine,
StateMachine rootStateMachine) {

Optional.ofNullable(message).ifPresent(msg -> {
Optional.ofNullable(UUID.class.cast(msg.getHeaders().get("booking_id")))
.ifPresent(bookingId -> {
Booking booking = bookingRepository.getOne(bookingId);
booking.setState(state I.getId());
bookingRepository.save(booking);
});
});
}
}

Однако в версии ssm 3.2.1 кажется, что ни интерфейсы перехватчика, ни интерфейсы прослушивателей не поддерживают реактивность. Знаете ли вы, как можно добиться чего-то подобного с помощью нового ssm? Можно ли прослушивать изменения состояния и выполнять некоторый реактивный код, который возвращает Mono?

Подробнее здесь: https://stackoverflow.com/questions/772 ... te-machine