subscribe

fun subscribe()

Выполняет подписку на поток сообщений брокера.

Подписка выполняется в отдельном потоке, так как метод subscribeWithFilter — блокирующий и должен выполняться вне JavaFX-потока.

Фильтрация сообщений:

  • по типу команды (равно eventCmd);

  • по managerId (соответствует текущему thisManager).

Каждый принятый пакет сообщений:

  • берёт последнее значение (msgs.last());

  • извлекает protobuf-структуру через extractProto;

  • преобразует в DTO через convertToEvent;

  • обновляет UI через update.