Необходима поддержка не только Кафки, а нескольких систем. (Apache ActiveMQ, MQS, Spread, RabbitMQ, Beanstalkd)
Создать подключение к MQ / MQ connect
Устанавливает соединение к брокеру MQ и создает контекст с подпиской на выбранный топик.
Настройки
| Свойство | Англ. наименование | Описание | Тип | Пример заполнения | Обязательность заполнения поля |
|---|---|---|---|---|---|
| Параметры | |||||
| Адрес | Address | Сетевой адрес машины с установленным брокером MQ Значение IP и номер порта. | Robin.String | Да | |
| Логин | Login | Логин для подключения к брокеру MQ | Robin.String | Нет | |
| Пароль | Password | Пароль для подключения к брокеру MQ | Robin.Password | Нет | |
| Топик | Topic | Наименование очереди сообщений, из которой нужно будет получать сообщения. | Robin.String | Да | |
| Имя группы | Group name | Название группы роботов, заданное пользователем. Разные группы вычитывают сообщения из топика независимо друг от друга. По умолчанию "1" Если подключениям с одинаковым топиком указать разные группы, то сообщение из очереди получит каждая. Если указать одинаковую группу, то сообщение попадет только в одну из них. Т.е. разные группы вычитывают сообщения из топика независимо друг от друга. | Robin.String | Нет | |
| Результаты | |||||
| Контекст | Context | Контекст открытого сеанса работы с MQ, к которому будут обращаться дальнейшие действия. Возможно требуются разные контексты для чтения сообщений из топика и записи сообщений в топик. Требуется проверка при реализации. | Robin.MQ | Нет | |
Особые условия использования
Отсутствуют.
Получить сообщения из топика из MQ / MQ consume
Получает сообщения из указанного топика MQ.
Настройки
| Свойство | Англ. наименование | Описание | Тип | Пример заполнения | Обязательность заполнения поля |
|---|---|---|---|---|---|
| Параметры | |||||
| Контекст | Context | Контекст открытого сеанса работы с MQ | Robin.MQ | Да | |
| Топик | Topic | Название топика для приема сообщений | Robin.String | Да | |
| Тайм-аут | Time-out | Предельное время ожидания получения сообщения. Указывается в миллисекундах. По умолчанию равно 0. Отрицательные значения запрещены. | Robin.Numeric | Нет | |
| Результаты | |||||
| Получаемые сообщения | Result | Полученное сообщение Если топик пустой, то будет выведено стандартное сообщение. | Robin.String | Нет | |
Особые условия использования
Отсутствуют.
Опубликовать в топик MQ / MQ publish
Отправить сообщение.
Настройки
| Свойство | Англ. наименование | Описание | Тип | Пример заполнения | Обязательность заполнения поля |
|---|---|---|---|---|---|
| Параметры | |||||
| Контекст | Context | Контекст открытого сеанса работы с MQ | Robin.MQ | Да | |
| Топик | Topic | Название топика для публикации сообщений | Robin.String | Да | |
| Сообщение | Message | Тело сообщения | Robin.String | Да | |
| Тайм-аут | Time-out | Предельное время ожидания публикации. Указывается в миллисекундах. По умолчанию равно 0. Отрицательные значения запрещены. | Robin.Numeric | Нет | |
Особые условия использования
Отсутствуют.
Получить сообщение по идентификатору / 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 | Нет | |
Особые условия использования
Отсутствуют.
Обзор
Инструменты контента