Преобразование ByteArraySeekableStream обратно в JSON в Mule

Question

У меня есть поток, который я разделил, поскольку часть его может быть повторно использована. Я добавил ссылку на поток в существующем потоке к новому потоку, но столкнулся с проблемой с использованием типа данных, который изменяет полезную нагрузку при входе в новый поток.

Новый поток состоит из каждого цикла, который записывает полезную нагрузку в базу данных, а полезная нагрузка изменяется на тип данных ByteArraySeekableStream, когда он вводит новый поток, который несовместим с каждым циклом.

Мне нужно преобразовать полезную нагрузку ByteArraySeekableStream в тип данных, который совместим с каждым циклом, а затем сможет преобразовать полезную нагрузку обратно в исходный тип данных JSON до того, как он будет записан в базу данных.

Как это сделать?

В настоящее время комбинации я пытался не работала и он либо не на каждую петлю, или я не был в состоянии изменить полезную нагрузку обратно в JSON

Answer 1

Я обнаружил, что преобразование ByteArraySeekableStream с помощью JSON в Объектный трансформатор и установка класса возврата в java.lang.Object исправили проблему.