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;
}

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 ; }
creates a camel streamer .
