Очереди сообщений, валидация по OpenAPI 3.0, многопоточность и мониторинг из коробки
Зарегистрируйте исходящее сообщение в очереди одной строкой кода:
// Регистрация сообщения для отправки
ИдентификаторСообщения = РегистрыСведений.инт_ОчередьИсходящихСообщений.ЗарегистрироватьСообщение(
СсылкаНаДокумент, // Исходные данные
ПотокДанных, // СправочникСсылка.инт_ПотокиДанных
Ложь // Регистрировать дубли
);Минимальное вмешательство в код
Подсистема берёт на себя инфраструктурный слой: формирование, сериализацию, валидацию, отправку и ведение истории. Вам достаточно добавить одну строку в момент события.
┌─────────────────┐ ┌─────────────────┐ ┌─────────────────┐
│ Исходные │ │ Поток данных │ │ Подписчик │
│ данные │────▶│ + Обработчик │────▶│ (HTTP/MQ/...) │
│ (Ссылка/Данные)│ │ + Валидация │ │ │
└─────────────────┘ └─────────────────┘ └─────────────────┘
│
▼
┌─────────────────────┐
│ Очередь сообщений │
│ + История статусов │
│ + Метрики │
└─────────────────────┘| Тип | Описание |
|---|---|
| HTTP произвольный | Отправка на любой REST/HTTP endpoint |
| Подсистема интеграции | Межбазовая интеграция с такой же подсистемой |
| RabbitMQ | Публикация сообщений в очередь AMQP |
| Kafka | Публикация в топики Apache Kafka |
| JRPC 2.0 | JSON-RPC 2.0 вызовы |