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