Сравнение версий

Ключ

  • Эта строка добавлена.
  • Эта строка удалена.
  • Изменено форматирование.

Оглавление

Соединение с MQ / MQ connection

Соединение с MQ.


(предупреждение)(warning)Необходима поддержка не только Кафки, а нескольких систем(Apache ActiveMQ, MQS, Spread, RabbitMQ, Beanstalkd)

Создать подключение к MQConnect to message broker

...

Устанавливает соединение к брокеру MQ и создает контекст с подпиской на выбраный топик.

Настройки

СвойствоАнгл. наименованиеОписаниеТипПример заполненияОбязательность заполнения поля
Параметры
Адрес
URLURL
Address

Сетевой адрес машины с установленным брокером MQ


Значение IP и номер порта.

Адрес

Robin.String
Да
ЛогинLoginЛогин для подключения к брокеру MQRobin.String
Нет
ПарольPasswordПароль для подключения к брокеру MQRobin.Password
Нет
Индекс группыGroup indexИндекс группы
ТопикTopic

Наименование очереди сообщений, из которой нужно будет получать сообщения.

Robin.String
Да
Имя группыGroup name

Название группы роботов, заданное пользователем.

Разные группы вычитывают сообщения из топика независимо друг от друга.

По умолчанию "1"



топиком указать разные группы, то сообщение из очереди получит каждая. Если указать одинаковую группу, то сообщение попадет только в одну из них.  Т.е. разные группы вычитывают сообщения из топика независимо друг от друга.


Robin.String
Да

Нет
Результаты
КонтекстContextКонтекст открытого сеанса работы с MQ, к которому будут обращаться дальнейшие действия.Robin.MQ
Нет

Особые условия использования

Отсутствуют.

Получить

...

сообщения из топика из MQ / MQ consume

...

Получить из топик MQПолучает сообщения из указанного топика MQ.

Настройки

СвойствоАнгл. наименованиеОписаниеТипПример заполненияОбязательность заполнения поля
Параметры
КонтекстContext

Контекст открытого сеанса работы с MQ

Robin.MQ
Да
ТопикTopicНазвание топика для приема сообщенийRobin.String
Да
Тайм-аутTime-out

Предельное время ожидания получения топикасообщения.

Указывается в миллисекундах.


По умолчанию равно 0.

Отрицательные значения запрещены.

Robin.Numeric
Нет
Результаты
Получаемые сообщенияResult

Получаемые сообщенияПолученное сообщение

Если топик пустой, то будет выведено стандартное сообщение. (вопрос) (предупреждение)

Robin.String



Нет

Особые условия использования

...

СвойствоАнгл. наименованиеОписаниеТипПример заполненияОбязательность заполнения поля
Параметры
КонтекстContext

Контекст открытого сеанса работы с MQ

Robin.MQ
Да
ТопикTopicНазвание топика для публикации сообщенийRobin.String
Да
СообщениеMessageТело сообщенияRobin.String
Да
Тайм-аутTime-out

Предельное время ожидания публикации.

Указывается в миллисекундах.


По умолчанию равно 0.

Отрицательные значения запрещены.

Robin.Numeric
Нет

Особые условия использования

Отсутствуют.

Получить сообщение по идентификатору / Get  Get message by ID

...

Получить сообщение по идентификаторуПолучает сообщение и присваивает ему идентификатор.

Настройки

СвойствоАнгл. наименованиеОписаниеТипПример заполненияОбязательность заполнения поля
Параметры
КонтекстContext

Контекст открытого сеанса работы с MQ

Robin.MQ
Да
Тайм-аутTime-out

Предельное время ожидания получения сообщения.

Указывается в миллисекундах.


По умолчанию равно 0.

Отрицательные значения запрещены.

Robin.Numeric
Нет
Результаты
Получаемые сообщенияRequired variablesПолучаемые сообщенияRobin.String
Нет

Особые условия использования

Отсутствуют.

...

Отправить сообщение / Reply 

...

Ответить.

Настройки

СвойствоАнгл. наименованиеОписаниеТипПример заполненияОбязательность заполнения поля
Параметры
КонтекстContext

Контекст открытого сеанса работы с MQ

Robin.MQ
Да
СообщениеMessageТело сообщенияRobin.String
Да
Тайм-аутTime-out

Предельное время ожидания отправки сообщения.

Указывается в миллисекундах.


По умолчанию равно 0.

Отрицательные значения запрещены.

Robin.Numeric
Нет

Особые условия использования

...