Hi Camel, I'm John, working on the Apache Beam project. I'm looking to write a Beam wrapper for some Camel components, as Camel has a very well developed ecosystem of connectors that we are looking to borrow.
I essentially want to inject messages into camel, or extract them, directly. Examples would be: from(something1?).to(some:existing:camel:component) from(some:existing:camel:component?with=config).to(something2?) Critically, I want to have my java process manually add data to something1, and have it be routed to the existing component properly. I'm mailing to ask if there is an existing component or technique I can use to get data into and out of Camel, or if this would be a new component of some kind. Thanks, John
