/
R.D.X
/
pieplex-api
Обзор
Документация
Войти
/
R.D.X
/
pieplex-api
Код
Запросы
0
Задачи
Вики
Пакеты
0
Релизы
0
CI/CD
Аналитика
Безопасность
master
src/main/java/ru/rdx/pieplex/api/endpoint/IncomingActiveEndpoint.java
18 строк
825 B
a.kiselev
async handlers call
23 сен 2025, 18:47
23 сен 2025, 18:47
a391e5a
Код
Авторство
О чём код?
package ru.rdx.pieplex.api.endpoint; import ru.rdx.pieplex.api.data.IRData; import java.util.function.BiConsumer; import java.util.List; import java.util.Collections; // точка в активном режиме сама производит необходимые действия и дергает обработчики // точка подключения для входящих сообщений. // на такой точке можно реализовать крон расписание. // подписку на очереди кафка кролик и прочее public interface IncomingActiveEndpoint extends EndpointInstance, IncomingEndpoint { void subscribe(List<BiConsumer<IRData, AnswerAsync>> subscriber); default void unsubscribe() { subscribe(Collections.emptyList()); } }