Help apache camel jdbc + active

[RJILI Youssef]

I'm new in apache camel and i have a problem about the filling of the
activemq.
I want to get the values from DB and filled it into activemq.
My activemq is started:

My code :


private void fillActiveMq() throws Exception{
JndiRegistry registry = new JndiRegistry(new JndiContext());
CamelContext camelCtxt = new DefaultCamelContext(registry);
MysqlDataSource datasource = getDataSource();
JdbcEndpoint endpoint = getJDBCEndPoint(datasource, camelCtxt);

registry.bind("bulksms", datasource);

camelCtxt.addComponent("activemq",ActiveMQComponent.activeMQComponent("vm://localhost?broker.persistent=false"));
camelCtxt.addEndpoint("jdbc:bulksms", endpoint);

        ProducerTemplate pT= camelCtxt.createProducerTemplate();
        pT.sendBody("jdbc:bulksms" , "select message from message");

camelCtxt.addRoutes(new RouteBuilder() {

 @Override
public void configure() throws Exception {
interceptSendToEndpoint("jdbc:*").throwException(new
ConnectException("Cannot connect"));
from("jdbc:bulksms").setBody(constant("select message from
message")).to("activemq:queue:messages");
}
});
  camelCtxt.start();
Thread.sleep(1000);

camelCtxt.stop();
}
 private  MysqlDataSource getDataSource() {
MysqlDataSource datasource = new MysqlDataSource();
datasource.setUser("root");
datasource.setPassword("root");
datasource.setDatabaseName("bulksms");
datasource.setPortNumber(3306);
datasource.setServerName("127.0.0.1");
return datasource;
}

private  JdbcEndpoint getJDBCEndPoint(MysqlDataSource datasource,
CamelContext camelCtxt) {

JdbcEndpoint endpoint = new JdbcEndpoint();
endpoint.setDataSource(datasource);
endpoint.setCamelContext(camelCtxt);
return endpoint;
}

I have this exception :
Exception in thread "main" java.lang.UnsupportedOperationException: Not
supported
at
org.apache.camel.component.jdbc.JdbcEndpoint.createConsumer(JdbcEndpoint.java:59)
at
org.apache.camel.impl.EventDrivenConsumerRoute.addServices(EventDrivenConsumerRoute.java:65)
at
org.apache.camel.impl.DefaultRoute.onStartingServices(DefaultRoute.java:80)
at org.apache.camel.impl.RouteService.warmUp(RouteService.java:134)
at
org.apache.camel.impl.DefaultCamelContext.doWarmUpRoutes(DefaultCamelContext.java:2109)
at
org.apache.camel.impl.DefaultCamelContext.safelyStartRouteServices(DefaultCamelContext.java:2039)
at
org.apache.camel.impl.DefaultCamelContext.doStartOrResumeRoutes(DefaultCamelContext.java:1827)
at
org.apache.camel.impl.DefaultCamelContext.doStartCamel(DefaultCamelContext.java:1699)
at
org.apache.camel.impl.DefaultCamelContext.doStart(DefaultCamelContext.java:1544)
at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:61)
at
org.apache.camel.impl.DefaultCamelContext.start(DefaultCamelContext.java:1512)
at com.apachecamel.ManageQueueFromDB.fillActiveMq(ManageQueueFromDB.java:76)
at com.apachecamel.ManageQueueFromDB.main(ManageQueueFromDB.java:43)

I only used java DSL code, Any Help please