I have a case where I have a large input stream that I would like to read from and unmarshal into multiple Camel Exchanges.
Currently the DataFormat interface requires you to return an Object after reading from the entire input stream. Ideally I would like my unmarshaller to create exchanges on the fly while consuming from the input stream.
I didn't see anything in the documentation regarding streamed unmarshallers.
from("source") // receives one big message
.unmarshal(new MyDataFormat()) // output numerous exchanges