Необходима в будущем поддержка не только Кафки, а нескольких систем (ActiveMQ, IBM Websphere MQ, MSMQ, RabbitMQ, ZeroMQ, OpenMQ, Beanstalkd, Spread, Amazon SQS.).
Устанавливает соединение к брокеру 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).
| Свойство | Англ. наименование | Описание | Тип | Пример заполнения | Обязательность заполнения поля |
|---|---|---|---|---|---|
| Параметры | |||||
| Контекст | Context | Контекст открытого сеанса работы с MQ, который требуется закрыть | Robin.MQ | Да | |
Отсутствуют.
Получает сообщение из указанного топика MQ.
| Свойство | Англ. наименование | Описание | Тип | Пример заполнения | Обязательность заполнения поля |
|---|---|---|---|---|---|
| Параметры | |||||
| Контекст | Context | Контекст открытого сеанса работы с MQ | Robin.MQ | Да | |
| Топик | Topic | Название топика для приема сообщений | Robin.String | Да | |
Имя группы | Group name | Название группы роботов, заданное пользователем. Разные группы вычитывают сообщения из топика независимо друг от друга. По умолчанию "1" Если действиям, использующим один контекст, указать разные группы, то сообщение из очереди получит каждая. Если указать одинаковую группу, то сообщение попадет только в одну из них.
| 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 | Нет | |
Отсутствуют.
Получает сообщение и присваивает ему идентификатор.
| Свойство | Англ. наименование | Описание | Тип | Пример заполнения | Обязательность заполнения поля |
|---|---|---|---|---|---|
| Параметры | |||||
| Контекст | Context | Контекст открытого сеанса работы с MQ | Robin.MQ | Да | |
| Тайм-аут | Time-out | Предельное время ожидания получения сообщения. Указывается в миллисекундах. По умолчанию равно 0. Отрицательные значения запрещены. | Robin.Numeric | Нет | |
| Результаты | |||||
| Получаемые сообщения | Required variables | Получаемые сообщения | Robin.String | Нет | |
Отсутствуют.
Ответить.
| Свойство | Англ. наименование | Описание | Тип | Пример заполнения | Обязательность заполнения поля |
|---|---|---|---|---|---|
| Параметры | |||||
| Контекст | Context | Контекст открытого сеанса работы с MQ | Robin.MQ | Да | |
| Сообщение | Message | Тело сообщения | Robin.String | Да | |
| Тайм-аут | Time-out | Предельное время ожидания отправки сообщения. Указывается в миллисекундах. По умолчанию равно 0. Отрицательные значения запрещены. | Robin.Numeric | Нет | |
Отсутствуют.
