У меня есть XML, который я пытаюсь пройти через Интеграционный поток. Вот шаги, которые я делаю:
- Отфильтруйте сообщение, если оно содержит узел XML: "filterMe" И имеет type = "filterType" - Если это так, я не хочу обработайте это.
- Преобразуйте его из XML в класс Kotlin и добавьте несколько заголовков в сообщение.
Не могу найти способ правильно отфильтровать сообщение по 2 XML свойствам. Любая помощь очень ценится.
Вот пример XML
<?xml version="1.0" encoding="UTF-8"?>
<Response type="filterType">//Filter on this
<event>
<header>
<type>Test</type>
</header>
<body>
<filterMe>filter me out</filterMe> //Filter this too
</body>
</event>
</Response>
Поток интеграции
return IntegrationFlows
.from(inputChannel)
.filter("filterMe"::contains)
.transform { payload: String ->
val jsonMessage = XML.toJSONObject(payload).toString()