История страницы
Отображение дочерних элементов |
---|
Подсказка |
---|
...
...
Необходима в будущем поддержка не только Кафки, а нескольких систем (ActiveMQ, IBM Websphere MQ, MSMQ, RabbitMQ, ZeroMQ, OpenMQ, Beanstalkd, Spread, Amazon SQS |
...
Создать подключение к MQ / MQ connect
Устанавливает соединение к брокеру MQ и создает контекст с подпиской на выбранный топик.
Настройки
...
Сетевой адрес машины с установленным брокером MQ
Значение IP и номер порта.
...
Наименование очереди сообщений, из которой нужно будет получать сообщения.
...
Название группы роботов, заданное пользователем.
Разные группы вычитывают сообщения из топика независимо друг от друга.
По умолчанию "1"
Если подключениям с одинаковым топиком указать разные группы, то сообщение из очереди получит каждая. Если указать одинаковую группу, то сообщение попадет только в одну из них. Т.е. разные группы вычитывают сообщения из топика независимо друг от друга.
В процессе реализации необходимо определить, где более правильно оставить данный параметр: в данном действии или в действии Чтения сообщения, и оставить только в одном из них.
...
Контекст открытого сеанса работы с MQ, к которому будут обращаться дальнейшие действия.
Возможно требуются разные контексты для чтения сообщений из топика и записи сообщений в топик. Требуется проверка при реализации.
...
Особые условия использования
Отсутствуют.
Разорвать подключение к MQ / MQ disconnect
Действие завершает сессию обмена сообщениями с сервером (брокером MQ).
...
Контекст открытого сеанса работы с MQ, который требуется закрыть
...
Особые условия использования
Отсутствуют.
Получить сообщение из топика из MQ / MQ consume
Получает сообщение из указанного топика MQ.
Настройки
...
Контекст открытого сеанса работы с MQ
...
Имя группы
...
Название группы роботов, заданное пользователем.
Разные группы вычитывают сообщения из топика независимо друг от друга.
По умолчанию "1"
Если действиям, использующим один контекст, указать разные группы, то сообщение из очереди получит каждая. Если указать одинаковую группу, то сообщение попадет только в одну из них.
В процессе реализации необходимо определить, где более правильно оставить данный параметр: в действии Подключение или в данном действии, и оставить только в одном из них.
...
Предельное время ожидания получения сообщения.
Указывается в миллисекундах.
По умолчанию равно 0.
Отрицательные значения запрещены.
...
Полученное сообщение
Если топик пустой, то будет выведено стандартное сообщение.
Robin.String
...
Особые условия использования
Отсутствуют.
Опубликовать в топик MQ / MQ publish
...
. |
...
Настройки
...
Контекст открытого сеанса работы с MQ
...
) |
...
. |
...
...
По умолчанию составляет неделю, т.е. 7 дней.
...
Предельное время ожидания публикации.
Указывается в миллисекундах.
По умолчанию равно 0.
Отрицательные значения запрещены.
...
Особые условия использования
Отсутствуют.
Получить сообщение по идентификатору / Get message by ID
Получает сообщение и присваивает ему идентификатор.
Настройки
...
Контекст открытого сеанса работы с MQ
...
Предельное время ожидания получения сообщения.
Указывается в миллисекундах.
По умолчанию равно 0.
Отрицательные значения запрещены.
...
Особые условия использования
Отсутствуют.
Отправить сообщение / Reply
Ответить.
Настройки
...
Контекст открытого сеанса работы с MQ
...
Предельное время ожидания отправки сообщения.
Указывается в миллисекундах.
По умолчанию равно 0.
Отрицательные значения запрещены.
...
Особые условия использования
Отсутствуют.