Quartz exception with camel

[uzairkamal <uz...@iacgrp.com>]

Exception in thread "main" java.lang.InstantiationError: org.quartz.JobDetail
	at
org.apache.camel.routepolicy.quartz.ScheduledRoutePolicy.createJobDetail(ScheduledRoutePolicy.java:143)
	at
org.apache.camel.routepolicy.quartz.ScheduledRoutePolicy.scheduleRoute(ScheduledRoutePolicy.java:80)
	at
org.apache.camel.routepolicy.quartz.CronScheduledRoutePolicy.doOnInit(CronScheduledRoutePolicy.java:63)
	at
org.apache.camel.routepolicy.quartz.CronScheduledRoutePolicy.onInit(CronScheduledRoutePolicy.java:35)
	at
org.apache.camel.impl.DefaultRouteContext.commit(DefaultRouteContext.java:207)
	at
org.apache.camel.model.RouteDefinition.addRoutes(RouteDefinition.java:883)
	at
org.apache.camel.model.RouteDefinition.addRoutes(RouteDefinition.java:172)
	at
org.apache.camel.impl.DefaultCamelContext.startRoute(DefaultCamelContext.java:722)
	at
org.apache.camel.impl.DefaultCamelContext.startRouteDefinitions(DefaultCamelContext.java:1789)
	at
org.apache.camel.impl.DefaultCamelContext.doStartCamel(DefaultCamelContext.java:1575)
	at
org.apache.camel.impl.DefaultCamelContext.doStart(DefaultCamelContext.java:1444)
	at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:60)
	at
org.apache.camel.impl.DefaultCamelContext.start(DefaultCamelContext.java:1412)
	at CamelTests.test(CamelTests.java:79)
	at abc.main(abc.java:17)




Code is as follows


==============================================================================

import com.mysql.jdbc.jdbc2.optional.MysqlDataSource;


import org.apache.camel.*;

import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.component.jdbc.JdbcEndpoint;
import org.apache.camel.impl.DefaultCamelContext;
import org.apache.camel.impl.JndiRegistry;

import org.apache.camel.routepolicy.quartz.CronScheduledRoutePolicy;

import org.apache.camel.util.jndi.JndiContext;


/*
 * To change this template, choose Tools | Templates and open the template
in
 * the editor.
 */
/**
 *
 * @author Uzair
 */
public class CamelTests {
    
    public void test() throws Exception {
        
        JndiRegistry registry = new JndiRegistry(new JndiContext());
        final CamelContext camelCtxt = new DefaultCamelContext(registry);
        MysqlDataSource datasource = getDataSource();
       final JdbcEndpoint endpoint = getJDBCEndPoint(datasource, camelCtxt);
        
        registry.bind("intuira", getDataSource());
        
        //camelCtxt.addEndpoint("direct:start", endpoint);

    //    camelCtxt.addRoutes(new RouteBuilder() {
      RouteBuilder myRoute = new RouteBuilder(camelCtxt) {

              
            @Override
            public void configure() throws Exception {
                
                
        ProducerTemplate producerTemplate =
camelCtxt.createProducerTemplate();    
    
       try{
                    Endpoint jdbcEndpoint =
camelCtxt.getEndpoint("direct:start");
              
                
              
                MyProcessor routeProcessor = new
MyProcessor(producerTemplate, jdbcEndpoint, camelCtxt);
               
from("direct:start").process(routeProcessor).to("jdbc:intuira");
       
       }catch(Exception ex){
       
       }
               
//from("quartz://myGroup/myTimerName?cron=0+0/1+12-18+?+*+MON-FRI")
                // 
from("timer://kickoff?period=10000").process(routeProcessor).to("jdbc:intuira");

            }
        };
        
          camelCtxt.addRoutes(new RouteBuilder() {

            @Override
            public void configure() throws Exception {
                CronScheduledRoutePolicy policy = new
CronScheduledRoutePolicy();
              
               
                policy.setRouteStartTime("*/3 * * * * ?");
       
from("direct:start").routePolicy(policy).routeId("myRoute").to("mock:results");
            }
          
          
          });
        
        camelCtxt.start();
        
        Thread.sleep(100000);

        camelCtxt.stop();

      
        
    }
    
    private MysqlDataSource getDataSource() {
        MysqlDataSource datasource = new MysqlDataSource();
        datasource.setUser("uzairkamal");
        datasource.setPassword(xxxxxxxxxxxxxxxxxxxx");
        datasource.setDatabaseName("xxxxxxxxxxxxxx");
        datasource.setServerName("xxxxxxxxxxxxxxxx");
        return datasource;
    }
    
    private JdbcEndpoint getJDBCEndPoint(MysqlDataSource datasource,
CamelContext camelCtxt) {
        
        JdbcEndpoint endpoint = new JdbcEndpoint();
        endpoint.setDataSource(datasource);
        endpoint.setCamelContext(camelCtxt);
        return endpoint;
    }
}
==============================================================================





--
View this message in context: http://camel.465427.n5.nabble.com/Quartz-exception-with-camel-tp5729172.html
Sent from the Camel - Users mailing list archive at Nabble.com.