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

.to("destination");