Перейти к основному содержимому

Подписаться

Осуществляет подписку на тему в схеме PUB/SUB

Функция Подписаться(Знач Соединение, Знач Префикс) Экспорт

ПараметрCLI опцияТипОбяз.Назначение
Соединение--connПроизвольныйОбъект компоненты с открытым соединением или портом
Префикс--prefixСтрокаТребуемый префикс (тема) сообщений для получения
Возвращаемое значение

Соответствие Из КлючИЗначение - Результат обработки

Пример использования для 1С:Предприятие/OneScript
// Сервер
Порт = 5555;
ОбъектСервера = OPI_ZeroMQ.ОткрытьПортPub(Порт);

Если Не OPI_ZeroMQ.ЭтоОбъектКоннектора(ОбъектСервера) Тогда
ВызватьИсключение OPI_Инструменты.JSONСтрокой(ОбъектСервера);
КонецЕсли;

// Клиент
Адрес = "tcp://127.0.0.1:5555";
ОбъектКлиента = OPI_ZeroMQ.СоздатьСоединениеSub(Адрес);

Если Не OPI_ZeroMQ.ЭтоОбъектКоннектора(ОбъектКлиента) Тогда
ВызватьИсключение OPI_Инструменты.JSONСтрокой(ОбъектКлиента);
КонецЕсли;

Префикс = "topic.";
Сообщение = СтрШаблон("%1ZeroMQ_SUB_%2", Префикс, Формат(ТекущаяДата(), "ДФ=yyyyMMddhhmmss"));
Данные = ПолучитьДвоичныеДанныеИзСтроки(Сообщение);

Результат = OPI_ZeroMQ.Подписаться(ОбъектКлиента, Префикс);
Результат
{
"result": true
}