question: private CamelStreamer < Integer , String > createCamelStreamer ( IgniteDataStreamer < Integer , String > dataStreamer ) { CamelStreamer < Integer , String > streamer = new CamelStreamer < > ( ) ; streamer . setIgnite ( grid ( ) ) ; streamer . setStreamer ( dataStreamer ) ; streamer . setEndpointUri ( "jetty:" + url ) ; dataStreamer . allowOverwrite ( true ) ; dataStreamer . autoFlushFrequency ( 1 ) ; return streamer ; }
target:  Creates a Camel streamer.