Скажем, у меня есть и класс событий, который содержит данные и тип события (из удаленного сервиса)
public class Event{
String StringData;
Integer IntData;
EvenType eventType;
}
, где EventType - это enum:
public enum EventType{
NEW,UPDATE,DELETE
}
Скажите, что у меня естьконвейер, который обрабатывает поток события и должен обрабатывать данные внутри события в соответствии с его типом.Например, если это новое событие, необходимо сохранить его в БД и зарегистрировать, если это событие удаления, сохранить его в файл, поэтому каждый тип события имеет свое собственное поведение, которое необходимо реализовать.
, например:
List<Event> events = ...
events.forEach(e->??? ); //how to process the event based on its type