Tried that. But It gives the same error.
On Wed, Jul 30, 2014 at 10:33 AM, Dhanuka Ranasinghe <[email protected]> wrote: > Can you please verify,whether you have added below component to dropins ? > > org.wso2.carbon.cassandra.datareader-4.3.0-SNAPSHOT.jar > > *Dhanuka Ranasinghe* > > Senior Software Engineer > WSO2 Inc. ; http://wso2.com > lean . enterprise . middleware > > phone : +94 715381915 > > > On Wed, Jul 30, 2014 at 10:13 AM, Asitha Nanayakkara <[email protected]> > wrote: > >> I'v used the following to get a CQL connection >> com.datastax.driver.core.Cluster cluster = InitialContext.doLookup(" >> CassandraRepo"); >> >> And added the following entry to master-datasources.xml >> >> <datasource> >> <name>WSO2_CASSANDRA_DB</name> >> <description>The datasource used for cassandra</description> >> <jndiConfig> >> <name>CassandraRepo</name> >> </jndiConfig> >> <definition type="CASSANDRA"> >> <configuration> >> <async>false</async> >> <clusterName>TestCluster</clusterName> >> <compression>SNAPPY</compression> >> <concurrency>100</concurrency> >> <username>admin</username> >> <password encrypted="true">admin</password> >> <port>9042</port> >> <maxConnections>100</maxConnections> >> <hosts> >> <host>127.0.0.1</host> >> </hosts> >> <loadBalancePolicy> >> <exclusionThreshold>2.5</exclusionThreshold> >> <latencyAware>true</latencyAware> >> <minMeasure>100</minMeasure> >> <policyName>RoundRobinPolicy</policyName> >> <retryPeriod>10</retryPeriod> >> <scale>2</scale> >> </loadBalancePolicy> >> <poolOptions> >> >> <coreConnectionsForLocal>10</coreConnectionsForLocal> >> >> <coreConnectionsForRemote>10</coreConnectionsForRemote> >> >> <maxConnectionsForLocal>10</maxConnectionsForLocal> >> >> <maxConnectionsForRemote>10</maxConnectionsForRemote> >> >> <maxSimultaneousRequestsForLocal>10</maxSimultaneousRequestsForLocal> >> >> <maxSimultaneousRequestsForRemote>10</maxSimultaneousRequestsForRemote> >> >> <minSimultaneousRequestsForLocal>10</minSimultaneousRequestsForLocal> >> >> <minSimultaneousRequestsForRemote>10</minSimultaneousRequestsForRemote> >> </poolOptions> >> <reconnectPolicy> >> <baseDelayMs>100</baseDelayMs> >> >> <policyName>ConstantReconnectionPolicy</policyName> >> </reconnectPolicy> >> <socketOptions> >> <connectTimeoutMillis>200</connectTimeoutMillis> >> <keepAlive>true</keepAlive> >> <readTimeoutMillis>200</readTimeoutMillis> >> <tcpNoDelay>true</tcpNoDelay> >> </socketOptions> >> </configuration> >> </definition> >> </datasource> >> >> >> >> >> >> On Wed, Jul 30, 2014 at 7:48 AM, Dhanuka Ranasinghe <[email protected]> >> wrote: >> >>> Can you please let me know the exact steps followed? >>> On 29 Jul 2014 17:47, "Udara Rathnayake" <[email protected]> wrote: >>> >>>> Hi Asitha, >>>> >>>> Not sure whether you can use this approach or not, previously in ES >>>> product we had following Cassandra data-source[1] definition and able to >>>> create connection using following, But we have used cassandra.cql.jdbc >>>> driver here. >>>> >>>> CarbonDataSource carbonDataSource = >>>> DataSourceManager.getInstance().getDataSourceRepository().getDataSource("SOCIAL_CASSANDRA_DB"); >>>> DataSource dataSource = (DataSource) carbonDataSource.getDSObject(); >>>> conn = dataSource.getConnection(); >>>> >>>> [1] >>>> >>>> <datasource> >>>> <name>SOCIAL_CASSANDRA_DB</name> >>>> <description>The cassandra datasource used for storing social >>>> activities</description> >>>> <definition type="RDBMS"> >>>> <configuration> >>>> <url>jdbc:cassandra://localhost:9160/EVENT_KS</url> >>>> <username>admin</username> >>>> <password>admin</password> >>>> >>>> <driverClassName>org.apache.cassandra.cql.jdbc.CassandraDriver</driverClassName> >>>> </configuration> >>>> </definition> >>>> </datasource> >>>> >>>> Regards, >>>> UdaraR >>>> >>>> >>>> On Tue, Jul 29, 2014 at 2:25 PM, Asitha Nanayakkara <[email protected]> >>>> wrote: >>>> >>>>> Hi, >>>>> >>>>> While trying to integrate CQL data source feature of >>>>> master-datasources.xml to MB I get an error at run time. >>>>> >>>>> I've used the following method to get the connection >>>>> >>>>>> com.datastax.driver.core.Cluster cluster >>>>>> = InitialContext.doLookup("CassandraRepo"); >>>>> >>>>> >>>>> Following is the error I get. >>>>> >>>>> [2014-07-29 14:08:57,035] ERROR >>>>> {org.wso2.carbon.ndatasource.core.DataSourceRepository} - A data source >>>>> reader cannot be found for the type 'CASSANDRA' >>>>> org.wso2.carbon.ndatasource.common.DataSourceException: A data source >>>>> reader cannot be found for the type 'CASSANDRA' >>>>> at >>>>> org.wso2.carbon.ndatasource.core.DataSourceRepository.createDataSourceObject(DataSourceRepository.java:196) >>>>> at >>>>> org.wso2.carbon.ndatasource.core.DataSourceRepository.registerDataSource(DataSourceRepository.java:359) >>>>> at >>>>> org.wso2.carbon.ndatasource.core.DataSourceRepository.addDataSource(DataSourceRepository.java:473) >>>>> at >>>>> org.wso2.carbon.ndatasource.core.DataSourceManager.initSystemDataSource(DataSourceManager.java:185) >>>>> at >>>>> org.wso2.carbon.ndatasource.core.DataSourceManager.initSystemDataSources(DataSourceManager.java:157) >>>>> at >>>>> org.wso2.carbon.ndatasource.core.internal.DataSourceServiceComponent.initSystemDataSources(DataSourceServiceComponent.java:191) >>>>> at >>>>> org.wso2.carbon.ndatasource.core.internal.DataSourceServiceComponent.setSecretCallbackHandlerService(DataSourceServiceComponent.java:177) >>>>> at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) >>>>> at >>>>> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57) >>>>> at >>>>> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) >>>>> at java.lang.reflect.Method.invoke(Method.java:606) >>>>> at >>>>> org.eclipse.equinox.internal.ds.model.ComponentReference.bind(ComponentReference.java:376) >>>>> at >>>>> org.eclipse.equinox.internal.ds.model.ServiceComponentProp.bindReference(ServiceComponentProp.java:432) >>>>> at >>>>> org.eclipse.equinox.internal.ds.model.ServiceComponentProp.bind(ServiceComponentProp.java:218) >>>>> at >>>>> org.eclipse.equinox.internal.ds.model.ServiceComponentProp.build(ServiceComponentProp.java:345) >>>>> at >>>>> org.eclipse.equinox.internal.ds.InstanceProcess.buildComponent(InstanceProcess.java:620) >>>>> at >>>>> org.eclipse.equinox.internal.ds.InstanceProcess.buildComponents(InstanceProcess.java:197) >>>>> at >>>>> org.eclipse.equinox.internal.ds.Resolver.getEligible(Resolver.java:343) >>>>> at >>>>> org.eclipse.equinox.internal.ds.SCRManager.serviceChanged(SCRManager.java:222) >>>>> at >>>>> org.eclipse.osgi.internal.serviceregistry.FilteredServiceListener.serviceChanged(FilteredServiceListener.java:107) >>>>> at >>>>> org.eclipse.osgi.framework.internal.core.BundleContextImpl.dispatchEvent(BundleContextImpl.java:861) >>>>> at >>>>> org.eclipse.osgi.framework.eventmgr.EventManager.dispatchEvent(EventManager.java:230) >>>>> at >>>>> org.eclipse.osgi.framework.eventmgr.ListenerQueue.dispatchEventSynchronous(ListenerQueue.java:148) >>>>> at >>>>> org.eclipse.osgi.internal.serviceregistry.ServiceRegistry.publishServiceEventPrivileged(ServiceRegistry.java:819) >>>>> at >>>>> org.eclipse.osgi.internal.serviceregistry.ServiceRegistry.publishServiceEvent(ServiceRegistry.java:771) >>>>> at >>>>> org.eclipse.osgi.internal.serviceregistry.ServiceRegistrationImpl.register(ServiceRegistrationImpl.java:130) >>>>> at >>>>> org.eclipse.osgi.internal.serviceregistry.ServiceRegistry.registerService(ServiceRegistry.java:214) >>>>> at >>>>> org.eclipse.osgi.framework.internal.core.BundleContextImpl.registerService(BundleContextImpl.java:433) >>>>> at >>>>> org.eclipse.osgi.framework.internal.core.BundleContextImpl.registerService(BundleContextImpl.java:451) >>>>> at >>>>> org.wso2.carbon.securevault.internal.SecretManagerInitializerComponent.activate(SecretManagerInitializerComponent.java:48) >>>>> at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) >>>>> at >>>>> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57) >>>>> at >>>>> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) >>>>> at java.lang.reflect.Method.invoke(Method.java:606) >>>>> at >>>>> org.eclipse.equinox.internal.ds.model.ServiceComponent.activate(ServiceComponent.java:260) >>>>> at >>>>> org.eclipse.equinox.internal.ds.model.ServiceComponentProp.activate(ServiceComponentProp.java:146) >>>>> at >>>>> org.eclipse.equinox.internal.ds.model.ServiceComponentProp.build(ServiceComponentProp.java:347) >>>>> at >>>>> org.eclipse.equinox.internal.ds.InstanceProcess.buildComponent(InstanceProcess.java:620) >>>>> at >>>>> org.eclipse.equinox.internal.ds.InstanceProcess.buildComponents(InstanceProcess.java:197) >>>>> at >>>>> org.eclipse.equinox.internal.ds.Resolver.buildNewlySatisfied(Resolver.java:473) >>>>> at >>>>> org.eclipse.equinox.internal.ds.Resolver.enableComponents(Resolver.java:217) >>>>> at >>>>> org.eclipse.equinox.internal.ds.SCRManager.performWork(SCRManager.java:816) >>>>> at >>>>> org.eclipse.equinox.internal.ds.SCRManager$QueuedJob.dispatch(SCRManager.java:783) >>>>> at org.eclipse.equinox.internal.ds.WorkThread.run(WorkThread.java:89) >>>>> at java.lang.Thread.run(Thread.java:745) >>>>> >>>>> -- >>>>> *Asitha Nanayakkara* >>>>> Software Engineer >>>>> WSO2, Inc. http://wso2.com/ >>>>> Mob: + 94 77 85 30 682 >>>>> >>>>> >>>>> _______________________________________________ >>>>> Dev mailing list >>>>> [email protected] >>>>> http://wso2.org/cgi-bin/mailman/listinfo/dev >>>>> >>>>> >>>> >>>> >>>> -- >>>> *Udara Rathnayake* >>>> Software Engineer >>>> WSO2 Inc. : http://wso2.com >>>> >>>> Mobile : +94 772207239 >>>> Twitter : http://twitter.com/udarakr >>>> Blog : http://udarakr.blogspot.com >>>> >>>> >> >> >> -- >> *Asitha Nanayakkara* >> Software Engineer >> WSO2, Inc. http://wso2.com/ >> Mob: + 94 77 85 30 682 >> >> > -- *Asitha Nanayakkara* Software Engineer WSO2, Inc. http://wso2.com/ Mob: + 94 77 85 30 682
_______________________________________________ Dev mailing list [email protected] http://wso2.org/cgi-bin/mailman/listinfo/dev
