StreamConsumer(StreamEndpoint endpoint, org.apache.camel.Processor processor, String uri)
StreamProducer(StreamEndpoint endpoint, String uri)
Apache Camel