One more thing we have missed was, mentioning providers at
master-datasources.xml
<providers>
<provider>org.wso2.carbon.ndatasource.rdbms.RDBMSDataSourceReader</provider>
<provider>org.wso2.carbon.cassandra.datareader.datasource.CassandraDataSourceReader</provider>
</providers>
*Dhanuka Ranasinghe*
Senior Software Engineer
WSO2 Inc. ; http://wso2.com
lean . enterprise . middleware
phone : +94 715381915
On Wed, Jul 30, 2014 at 11:27 AM, Asitha Nanayakkara <[email protected]>
wrote:
> 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
