Maybe you need to learn a bit about camel. What camel is and what is a consumer.There is a lot of documentation on the website. Il mer, 26 lug, 2017 alle 21:15, SenthilKumar K<senthilec...@gmail.com> ha scritto: Not sure if i already have an answer... Still i'm not clear :-( ..
Questions : 1) *Can this Cassandra Camel Consumer opt for my Use Case ?* 2) If Yes ( for above Q) , How to use Cassandra Consumer ? *It would be great if i get sample code !* --Senthil On Thu, Jul 27, 2017 at 12:41 AM, Andrea Cosentino <ancosen1...@yahoo.com> wrote: > You already have an answer. > > Il mer, 26 lug, 2017 alle 21:09, SenthilKumar K > <senthilec...@gmail.com> ha scritto: > Ping !!! > > It would be great if anybody help me here :-) .. > > --Senthil > > On Wed, Jul 26, 2017 at 4:47 PM, SenthilKumar K <senthilec...@gmail.com> > wrote: > > > Adding Dev Group ... > > > > > > --Senthil > > > > On Wed, Jul 26, 2017 at 3:14 PM, SenthilKumar K <senthilec...@gmail.com> > > wrote: > > > >> Hello Camel Users , Recently i started exploring possibilities of > >> streaming data from Cassandra Table for my use case, found * > https://github.com/apache/camel/tree/master/components/camel-cassandraql > >> <https://github.com/apache/camel/tree/master/components/ > camel-cassandraql>* > > >> . This seems to be good candidate for my use case! > >> > >> > >> Use Case : > >> ProcessA --Write---> Cassandra <---READ--- ProcessB ---> Analytics > System > >> > >> ProcessA is responsible to write data continuously to apache cassandra > >> and in near realtime another process read/parse and send it to > downstream > >> system. > >> > >> Consumer : > >> https://github.com/oscerd/camel-cassandra/blob/master/src/ > >> main/java/com/github/oscerd/component/cassandra/CassandraConsumer.java > >> > >> I want to start the Consumer Process which should run 24/7 and start > >> processing unless until it gets Kill Request.. > >> > >> Here is the Code i tried: > >> public class CassandraConsumer { > >> public static void main(String[] args) throws Exception { > >> CassandraEndpoint endpoint = new CassandraEndpoint(); > >> endpoint.setPort("9042"); > >> endpoint.setKeyspace("test"); > >> endpoint.setHost("127.0.0.1"); > >> endpoint.setTable("stream_data"); > >> endpoint.setPollingQuery("select * from stream_data"); > >> Processor p = new Processor() { > >> public void process(Exchange exchange) throws Exception { > >> ResultSet body = (ResultSet) exchange.getIn().getBody(); > >> List<Row> allRows = body.all(); > >> for(Row r : allRows ){ > >> System.out.println(r.getInt("id")+" "+r.getString("data")); > >> } > >> } > >> }; > >> endpoint.createConsumer(p).start(); > >> } > >> } > >> > >> This is not working ( I dont know how to use Consumer ). > >> > >> Questions : > >> 1) Can this Cassandra Camel Consumer opt for my Use Case ? > >> 2) If Yes ( for above Q) , How to use Cassandra Consumer ? It > >> would be great if i get sample code ! > >> > >> > >> --Senthil > >> > > > > > >
