BIP4435 Узел ответа агрегации получил ответное сообщение с пустым идентификатором ответа:

Question

Я получаю следующую ошибку при попытке выполнить Fan-In с использованием агрегатного узла в шине интеграции IBM.

( T24_Integ_Node.default ) The Aggregation Reply node has received a reply message which has a blank reply ID: ''.   
This is not allowed because the reply ID is needed so that a reply message can be matched to the original request message. If you are using WebSphere MQ to send and receive aggregation requests, the reply ID must be stored in the correlation identifier (CorrelId) field of the message descriptor (MQMD) and it must be set to the value of the message ID in the request message's MQMD

Поток сообщений выглядит так:

FILE<1> ->AggregateControl<1>->FAN-OUT-COMPUTE-NODES<1,2,3> ->FILE-OUTPUT-NODES<1,2,3> -> AGGREGATE-REQUEST-NODES<1,2,3> -> AGGREGATE-REPLY-NODE<1> -> FAN-IN-COMPUTE-NODE<1> -> FILE-OUTPUT-NODE<1>

Пожалуйста, обратите внимание, что я не использую узлы MQ.

Answer 1

То, что вы пытаетесь, не будет работать, потому что вы не используете протокол запроса / ответа внутри агрегации. Как указано в статье Центра знаний по этой ссылке: "Узлы агрегации работают правильно только для транспортов, использующих модель запроса / ответа", а запись и чтение из файлов не удовлетворяет этому требованию. Некоторыми узлами, которые удовлетворяют этому требованию, являются узлы MQ, асинхронные узлы SOAP и асинхронные узлы HTTP. Кроме того, вам нужно использовать узел AggregateControl, чтобы отметить начало разветвления, и я не вижу узла AggregateControl в эскизе потока.

Я подозреваю, что вы хотите отправить файлы во внешнее приложение (я), чтобы экземпляры этого приложения работали независимо и параллельно, получать файлы ответов, а затем группировать файлы ответов, основываясь на флаге (ах) в файлах. "имена или в содержании файлов". Если это так, используйте узел Collector.

Альтернативой может быть использование узлов агрегации с узлами MQ внутри агрегации, причем эти узлы MQ подают промежуточный поток, который изменяет протокол разветвления с MQ на файл, а затем, наоборот, протокол разветвления с файла на MQ. См. Пример агрегации веб-сервисов IIB для примера этого метода.