diff --git a/src/ru/BSL/OpenIntegrations/src/CommonModules/OPI_ZeroMQ/Module.bsl b/src/ru/BSL/OpenIntegrations/src/CommonModules/OPI_ZeroMQ/Module.bsl index aee572c97c..9db8e12680 100644 --- a/src/ru/BSL/OpenIntegrations/src/CommonModules/OPI_ZeroMQ/Module.bsl +++ b/src/ru/BSL/OpenIntegrations/src/CommonModules/OPI_ZeroMQ/Module.bsl @@ -262,6 +262,34 @@ КонецФункции +// Обработать запрос +// Отправляет запрос и ожидает ответ в течении указанного времени (для схемы REQ/REP) +// +// Параметры: +// Соединение - Произвольный - Объект компоненты с открытым соединением - conn +// Данные - ДвоичныеДанные - Данные для отправки - data +// ТаймаутОтправки - Число, Неопределено - Таймаут отправки (в мс). Без таймаута, если неопределено - treq +// ТаймаутПолучения - Число, Неопределено - Таймаут получения (в мс). Без таймаута, если неопределено - trep +// +// Возвращаемое значение: +// Соответствие Из КлючИЗначение - Результат обработки +Функция ОбработатьЗапрос(Знач Соединение + , Знач Данные + , Знач ТаймаутОтправки = Неопределено + , Знач ТаймаутПолучения = Неопределено) Экспорт + + РезультатОтправки = ОтправитьДанные(Соединение, Данные, ТаймаутОтправки); + + Если Не РезультатОтправки["result"] Тогда + Возврат РезультатОтправки; + КонецЕсли; + + РезультатПолучения = ПолучитьДанные(Соединение, ТаймаутПолучения); + + Возврат РезультатПолучения; + +КонецФункции + // Подписаться // Осуществляет подписку на тему в схеме PUB/SUB // diff --git a/src/ru/BSL/Tests/src/CommonModules/OPI_ПолучениеДанныхТестов/Module.bsl b/src/ru/BSL/Tests/src/CommonModules/OPI_ПолучениеДанныхТестов/Module.bsl index 8c2b20e594..f7452104bb 100644 --- a/src/ru/BSL/Tests/src/CommonModules/OPI_ПолучениеДанныхТестов/Module.bsl +++ b/src/ru/BSL/Tests/src/CommonModules/OPI_ПолучениеДанныхТестов/Module.bsl @@ -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); diff --git a/src/ru/BSL/Tests/src/CommonModules/OPIt_ZeroMQ/Module.bsl b/src/ru/BSL/Tests/src/CommonModules/OPIt_ZeroMQ/Module.bsl index e64bf6886e..c8c3ad4dd0 100644 --- a/src/ru/BSL/Tests/src/CommonModules/OPIt_ZeroMQ/Module.bsl +++ b/src/ru/BSL/Tests/src/CommonModules/OPIt_ZeroMQ/Module.bsl @@ -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", ПараметрыТеста);