TO @tools1c
НастройкиСжатия = КлиентRMQ.НастройкиСжатия("zstd");
Ответ = КлиентRMQ.ОпубликоватьСообщение(Канал, Данные, "nomra", КлиентRMQ.Exchange_direct(),,,,,НастройкиСжатия);Map<String, Object> arguments = new HashMap<>();
arguments.put("x-queue-type", "stream");
// maximum stream size: 20 GB
arguments.put("x-max-length-bytes", 20_000_000_000);
// size of segment files: 100 MB
arguments.put("x-stream-max-segment-size-bytes", 100_000_000);
// size of stream bloom filter: 32
arguments.put("x-stream-filter-size-bytes", 32);
channel.queueDeclare(
"my-stream",
true, // durable
false, false, // not exclusive, not auto-delete
arguments
);
АргументыОчереди = Новый Массив;
АргументыОчереди.Добавить(КлиентRMQ.НовыйАргумент("x-queue-type","stream"));
Очередь = КлиентRMQ.ОбъявитьОчередь(Канал, "node1", "nomra", КлиентRMQ.Exchange_direct(), Истина,,,АргументыОчереди);
КоличествоПредзагруженныхНеПодтвержденныхСообщений = 10;
Канал = КлиентRMQ.СоздатьКанал(Подключение,,КоличествоПредзагруженныхНеПодтвержденныхСообщений);
Версия 0.36.0 (2023-11-08):
Переход на Event API вместо Callback API: Это крупное изменение внутренней архитектуры, может повлиять на стабильность и производительность кода.
Заголовки = КлиентRMQ.ДобавитьЗаголовок("Заголовок1", "ЗначениеЗаголовка1");
Заголовки = КлиентRMQ.ДобавитьЗаголовок("Заголовок2", "ЗначениеЗаголовка2", Заголовки);
Заголовки = КлиентRMQ.ДобавитьЗаголовок("Заголовок3", "ЗначениеЗаголовка3", Заголовки);
Ответ = КлиентRMQ.ОпубликоватьСообщение(Канал, Данные, "nomra", КлиентRMQ.Exchange_direct(),,,,Заголовки);Для каждого текЗаголовок Из ДанныеСообщения.Заголовки Цикл
Сообщить(СтрШаблон("%1:%2", текЗаголовок.Ключ, текЗаголовок.Значение));
КонецЦикла;
// Создать получателя, через которого будут получаться сообщения из очереди
Таймаут = 5; // таймаут при ожидании сообщения (в сек). Если = 0, таймаута нет.
Получатель = КлиентRMQ.СоздатьПолучателя(Канал, "node1", "ПолучательНоменклатуры",,,,,Таймаут);
Функция СоздатьПолучателя(Канал, ИмяОчереди, ТэгПолучателя = "", no_ack = Ложь, exclusive = Ложь, no_local = Ложь, nowait = Ложь) Экспорт
content_type, content_encoding, priority, correlation_id, reply_to, expiration, message_id, timestamp, type, user_id, app_id, cluster_id. Пример использования этих свойств в обработке ИспользованиеСвойствСообщений.rpc_queue, в которую будут поступать запросы от клиента и которую будет прослушивать сервер.reply_to с названием очереди, в которую сервер должен отправить ответ.reply_to.reply_to (указанную клиентом).correlation_id, сервер в ответном сообщение скопирует это свойство, таким образом клиет будет знать на какой именно запрос ему ответил сервер.expiration, то по истечении этого времени RMQ удалить сообщение из очереди.// Указывается явно с какого раздела и с какого смещения начать читать
// Если не требуется явно указывать номер раздела и смещение, а надо подписаться на топик полность
// и смещение будет запоминаться на сервере (через вызов КлиентKafka.СохранитьСмещение(Сообщение))
// то можно не исползовать этот метод, а указать топик в КлиентKafka.КонфигурацияПотребителя(Топик)
// Если топик указан через ДобавитьТопикРазделИСмещение, то настройки топика в КлиентKafka.КонфигурацияПотребителя(Топик) будет игнорироваться
КлиентKafka.ДобавитьТопикРазделИСмещение(КонфигурацияПотребителя, "1CRefs", 0, 2);