1c/OpenIntegrations
1
0
Fork 0
mirror of https://github.com/Bayselonarrend/OpenIntegrations.git synced 2026-05-16 09:38:28 +02:00
Code Issues Releases Activity

Доработка тестов ZMQ, метод ОбработатьЗапрос

Browse Source
This commit is contained in:
Anton Titovets
2026-05-07 10:29:28 +03:00
parent 21b396728b
commit 2b9dd6f261
3 changed files with 34 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/ru/BSL/OpenIntegrations/src/CommonModules/OPI_ZeroMQ/Module.bsl
+28
View File
@@ -262,6 +262,34 @@
КонецФункции
// Обработать запрос
// Отправляет запрос и ожидает ответ в течении указанного времени (для схемы REQ/REP)
//
// Параметры:
// Соединение - Произвольный - Объект компоненты с открытым соединением - conn
// Данные - ДвоичныеДанные - Данные для отправки - data
// ТаймаутОтправки - Число, Неопределено - Таймаут отправки (в мс). Без таймаута, если неопределено - treq
// ТаймаутПолучения - Число, Неопределено - Таймаут получения (в мс). Без таймаута, если неопределено - trep
//
// Возвращаемое значение:
// Соответствие Из КлючИЗначение - Результат обработки
Функция ОбработатьЗапрос(Знач Соединение
, Знач Данные
, Знач ТаймаутОтправки = Неопределено
, Знач ТаймаутПолучения = Неопределено) Экспорт
РезультатОтправки = ОтправитьДанные(Соединение, Данные, ТаймаутОтправки);
Если Не РезультатОтправки["result"] Тогда
Возврат РезультатОтправки;
КонецЕсли;
РезультатПолучения = ПолучитьДанные(Соединение, ТаймаутПолучения);
Возврат РезультатПолучения;
КонецФункции
// Подписаться
// Осуществляет подписку на тему в схеме PUB/SUB
//
src/ru/BSL/Tests/src/CommonModules/OPI_ПолучениеДанныхТестов/Module.bsl
Vendored
+3 -3
View File
@@ -342,9 +342,9 @@
НовыйТест(ТаблицаТестов, "TC_Клиент" , "TCP Клиент" , TCP);
НовыйТест(ТаблицаТестов, "WS_Клиент" , "WebSocket Клиент" , WebSocket);
НовыйТест(ТаблицаТестов, "WS_Сервер" , "WebSocket Сервер" , WebSocket);
НовыйТест(ТаблицаТестов, "ZMQ_Подключение" , "ZeroMQ Подключение" , ZMQ);
НовыйТест(ТаблицаТестов, "ZMQ_Прослушивание" , "ZeroMQ Прослушивание" , ZMQ);
НовыйТест(ТаблицаТестов, "ZMQ_Взаимодействие" , "ZeroMQ Взаимодействие" , ZMQ);
НовыйТест(ТаблицаТестов, "ZMQ_МетодыПодключения" , "Подключение" , ZMQ);
НовыйТест(ТаблицаТестов, "ZMQ_МетодыПрослушивания" , "Прослушивание" , ZMQ);
НовыйТест(ТаблицаТестов, "ZMQ_МетодыВзаимодействия" , "Взаимодействие" , ZMQ);
НовыйТест(ТаблицаТестов, "TC_Сервер" , "TCP Сервер" , TCP);
НовыйТест(ТаблицаТестов, "SQLL_ОсновныеМетоды" , "Основные методы" , SQLite);
НовыйТест(ТаблицаТестов, "SQLL_ORM" , "ORM" , SQLite);
src/ru/BSL/Tests/src/CommonModules/OPIt_ZeroMQ/Module.bsl
Vendored
+3 -3
View File
@@ -92,7 +92,7 @@
#Область ZeroMQ
Процедура ZMQ_Подключение() Экспорт
Процедура ZMQ_МетодыПодключения() Экспорт
ПараметрыТеста = Новый Структура;
OPI_ПолучениеДанныхТестов.ПараметрВКоллекцию("ZeroMQ_Address", ПараметрыТеста);
@@ -105,7 +105,7 @@
КонецПроцедуры
Процедура ZMQ_Прослушивание() Экспорт
Процедура ZMQ_МетодыПрослушивания() Экспорт
ПараметрыТеста = Новый Структура;
OPI_ПолучениеДанныхТестов.ПараметрВКоллекцию("ZeroMQ_Port", ПараметрыТеста);
@@ -117,7 +117,7 @@
КонецПроцедуры
Процедура ZMQ_Взаимодействие() Экспорт
Процедура ZMQ_МетодыВзаимодействия() Экспорт
ПараметрыТеста = Новый Структура;
OPI_ПолучениеДанныхТестов.ПараметрВКоллекцию("ZeroMQ_Address", ПараметрыТеста);