DSL ZESB > Компоненты языка > Раздел Message Queue

Компонент для работы с очередями Rabbit MQ.

Свойства:

Наименование

Значения

Уникальный идентификатор компонента, только чтение.

name

Название компонента

DataSource

Строка соединения с брокером сообщений или ссылка на ресурс объявленный в проекте.

CommandType

Тип операции

Тип данных: Enum;

•GET - Получить сообщение из очереди

•PUT - Поместить сообщение в очередь

Queue

Имя очереди

Exchange

Точка обмена

Headers

Параметры запроса.

Тип данных: List;

Свойства объекта:

Наименование

Тип

Описание

Key

String

Имя переменной для подстановки в шаблон

Value

String

Значение переменной взятое из локальной памяти с помощью JPATH или введенное вручную.

Строковое выражение JPATH начинается с $.

Пример:

$.JSON.result.code или Просто текст

Body

Тело сообщения

параметр обязателен только при выборе CommandType = GET

Можно значение передавать с помощью JPATH

MessageType

Тип сообщения. Устанавливает специальный заголовок. Необязательно

Можно значение передавать с помощью JPATH

MessageId

Уникальный идентификатор сообщения. (Необязательно)

Можно значение передавать с помощью JPATH

CorrelationId

Уникальный идентификатор соответствия сообщения (Необязательно)

Можно значение передавать с помощью JPATH

WhenDataNullCancel

Если при получении сообщения пусто не выполнять поток дальше

Тип данных: Boolean;

Output

Результат выполнения запроса.

Тип данных: String

Пример значения:

test.out_data //Переменная будет сохранена в локальную область памяти

RabbitMQ

RabbitMQ