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