Необходима в будущем поддержка не только Кафки, а нескольких систем (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 | Да | |
| Тайм-аут | Time-out | Предельное время ожидания получения сообщения. Указывается в миллисекундах. По умолчанию равно 0. Отрицательные значения запрещены. | Robin.Numeric | Нет | |
| Результаты | |||||
| Получаемое сообщение | Result | Полученное сообщение | Robin.String | Нет | |
Отсутствуют.
Отправить сообщение.
| Свойство | Англ. наименование | Описание | Тип | Пример заполнения | Обязательность заполнения поля |
|---|---|---|---|---|---|
| Параметры | |||||
| Контекст | Context | Контекст открытого сеанса работы с MQ | Robin.MQ | Да | |
| Сообщение | Message | Тело сообщения | Robin.String | Да | |
| Тайм-аут | Time-out | Предельное время ожидания публикации. Указывается в миллисекундах. По умолчанию равно 0. Отрицательные значения запрещены. | Robin.Numeric | Нет | |
Отсутствуют.
