Hi,

I am facing one problem with file component.

My requirement is :File component to read the xml/txt/csv file from directory as periodically and store the database.

For above task i wrote the like

Endpoint is folder and camel consuming files from the folder periodically until ends the workflow..

String insertQuery = "insert into tblblacklistednumbers(fldTransactionId,fldPhoneNumber,fldDescription) values (#,#,#)";

                System.out.println(insertQuery.trim());

                JaxbDataFormat jaxb = new JaxbDataFormat("com.upc.mds.processor");

                System.out.println("path in jaxb"+jaxb.getContextPath());

                System.out.println("object in jaxb"+jaxb.toString());

                from("file://D:/BLNData")

                .processRef("test")

         .choice()

         .when()

         .method("fileHelper", "isCsv")

         .unmarshal().csv()  

         .processRef("test")

         .processRef("blndataProcessor")

         .loop(property("blnLoop"))

         .processRef("setBodyProcessor")

         //.to("writeSql:call blacklistednumbersprod(#,#,#)")

         .to("dataSource:"+insertQuery.trim())

         //.to("bean:normalizer")

         .end()

         .end()

         .choice()        

         .when()

         .method("fileHelper", "isXml")        

         .unmarshal(jaxb)        

         .processRef("test")

         .processRef("blndataProcessor")

          .to("dataSource:"+insertQuery.trim())

          .processRef("test")

         .end()        

        ;

The above code working fine by using the Thread.sleep(n) in my main problem but my requirement in actual project  is:

we are used the Reflection  in main problem to start the router and The connection is establish/lessening until workflow ends.

Is it possible ?

Please can you provide some ideas