Sure , Let me learn and come back to forum if any questions! --Senthil
On Thu, Jul 27, 2017 at 11:30 AM, Andrea Cosentino <ancosen1...@yahoo.com> wrote: > 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 > > >> > > > > > > > > > > > >
