Observed the same issue while publishing events clustered CEP setup. However, it has happened only for 1 CEP node. Please find related jira at [1]:
[1]: https://wso2.org/jira/browse/CEP-738 Shashika Ubhayaratne Associate Technical Lead - QA WSO2 Inc: http://www.wso2.com/ Mobile: +94773383831 On Thu, Feb 27, 2014 at 4:09 PM, Shavantha Weerasinghe <[email protected]> wrote: > Hi All > When testing ESB,CEP integration initially flow works but after a > change on CEP side was done the below exception continuously comes. > JIRA is https://wso2.org/jira/browse/CEP-674 > > > 2014-02-27 10:04:39,266] INFO - {DataBridge} admin connected > [2014-02-27 10:04:39,272] ERROR - {DefaultRealmService} Tenant domain > has not been set in CarbonContext > java.lang.NullPointerException: Tenant domain has not been set in > CarbonContext > at > org.wso2.carbon.caching.impl.CacheManagerFactoryImpl.getCacheManager(CacheManagerFactoryImpl.java:79) > at > org.wso2.carbon.user.core.tenant.TenantCache.getTenantCache(TenantCache.java:39) > at > org.wso2.carbon.user.core.tenant.TenantCache.getValueFromCache(TenantCache.java:77) > at > org.wso2.carbon.user.core.tenant.JDBCTenantManager.getTenant(JDBCTenantManager.java:290) > at > org.wso2.carbon.user.core.tenant.JDBCTenantManager.getTenant(JDBCTenantManager.java:54) > at > org.wso2.carbon.user.core.common.DefaultRealmService.getTenantUserRealm(DefaultRealmService.java:159) > at > org.wso2.carbon.registry.core.session.UserRegistry.init(UserRegistry.java:266) > at > org.wso2.carbon.registry.core.session.UserRegistry.<init>(UserRegistry.java:226) > at > org.wso2.carbon.registry.core.session.UserRegistry.<init>(UserRegistry.java:205) > at > org.wso2.carbon.registry.core.jdbc.EmbeddedRegistryService.getUserRegistry(EmbeddedRegistryService.java:427) > at > org.wso2.carbon.registry.core.jdbc.EmbeddedRegistryService.getSystemRegistry(EmbeddedRegistryService.java:292) > at > org.wso2.carbon.registry.core.jdbc.EmbeddedRegistryService.getGovernanceSystemRegistry(EmbeddedRegistryService.java:517) > at > org.wso2.carbon.databridge.streamdefn.registry.datastore.RegistryStreamDefinitionStore.getAllStreamDefinitionsFromStore(RegistryStreamDefinitionStore.java:123) > at > org.wso2.carbon.databridge.core.definitionstore.AbstractStreamDefinitionStore.getAllStreamDefinitions(AbstractStreamDefinitionStore.java:53) > at > org.wso2.carbon.databridge.core.internal.EventDispatcher.initDomainNameStreamTypeHolderCache(EventDispatcher.java:255) > at > org.wso2.carbon.databridge.core.internal.EventDispatcher.getStreamDefinitionHolder(EventDispatcher.java:222) > at > org.wso2.carbon.databridge.core.internal.EventDispatcher.publish(EventDispatcher.java:200) > at org.wso2.carbon.databridge.core.DataBridge.publish(DataBridge.java:183) > at > org.wso2.carbon.databridge.receiver.thrift.service.ThriftSecureEventTransmissionServiceImpl.publish(ThriftSecureEventTransmissionServiceImpl.java:127) > at > org.wso2.carbon.databridge.commons.thrift.service.secure.ThriftSecureEventTransmissionService$Processor$publish.getResult(ThriftSecureEventTransmissionService.java:648) > at > org.wso2.carbon.databridge.commons.thrift.service.secure.ThriftSecureEventTransmissionService$Processor$publish.getResult(ThriftSecureEventTransmissionService.java:636) > at org.apache.thrift.ProcessFunction.process(ProcessFunction.java:32) > at org.apache.thrift.TBaseProcessor.process(TBaseProcessor.java:34) > at > org.apache.thrift.server.TThreadPoolServer$WorkerProcess.run(TThreadPoolServer.java:176) > at > java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886) > at > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908) > at java.lang.Thread.run(Thread.java:662) > [2014-02-27 10:04:39,274] ERROR - {UserRegistry} An error occurred > while obtaining the user realm for the tenant: -1. > [2014-02-27 10:04:39,274] ERROR - {RegistryStreamDefinitionStore} > Error in retrieving streamDefinitions from the registry > org.wso2.carbon.registry.core.exceptions.RegistryException: An error > occurred while obtaining the user realm for the tenant: -1. > at > org.wso2.carbon.registry.core.session.UserRegistry.init(UserRegistry.java:282) > at > org.wso2.carbon.registry.core.session.UserRegistry.<init>(UserRegistry.java:226) > at > org.wso2.carbon.registry.core.session.UserRegistry.<init>(UserRegistry.java:205) > at > org.wso2.carbon.registry.core.jdbc.EmbeddedRegistryService.getUserRegistry(EmbeddedRegistryService.java:427) > at > org.wso2.carbon.registry.core.jdbc.EmbeddedRegistryService.getSystemRegistry(EmbeddedRegistryService.java:292) > at > org.wso2.carbon.registry.core.jdbc.EmbeddedRegistryService.getGovernanceSystemRegistry(EmbeddedRegistryService.java:517) > at > org.wso2.carbon.databridge.streamdefn.registry.datastore.RegistryStreamDefinitionStore.getAllStreamDefinitionsFromStore(RegistryStreamDefinitionStore.java:123) > at > org.wso2.carbon.databridge.core.definitionstore.AbstractStreamDefinitionStore.getAllStreamDefinitions(AbstractStreamDefinitionStore.java:53) > at > org.wso2.carbon.databridge.core.internal.EventDispatcher.initDomainNameStreamTypeHolderCache(EventDispatcher.java:255) > at > org.wso2.carbon.databridge.core.internal.EventDispatcher.getStreamDefinitionHolder(EventDispatcher.java:222) > at > org.wso2.carbon.databridge.core.internal.EventDispatcher.publish(EventDispatcher.java:200) > at org.wso2.carbon.databridge.core.DataBridge.publish(DataBridge.java:183) > at > org.wso2.carbon.databridge.receiver.thrift.service.ThriftSecureEventTransmissionServiceImpl.publish(ThriftSecureEventTransmissionServiceImpl.java:127) > at > org.wso2.carbon.databridge.commons.thrift.service.secure.ThriftSecureEventTransmissionService$Processor$publish.getResult(ThriftSecureEventTransmissionService.java:648) > at > org.wso2.carbon.databridge.commons.thrift.service.secure.ThriftSecureEventTransmissionService$Processor$publish.getResult(ThriftSecureEventTransmissionService.java:636) > at org.apache.thrift.ProcessFunction.process(ProcessFunction.java:32) > at org.apache.thrift.TBaseProcessor.process(TBaseProcessor.java:34) > at > org.apache.thrift.server.TThreadPoolServer$WorkerProcess.run(TThreadPoolServer.java:176) > at > java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886) > at > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908) > at java.lang.Thread.run(Thread.java:662) > Caused by: org.wso2.carbon.user.api.UserStoreException: Tenant domain > has not been set in CarbonContext > at > org.wso2.carbon.user.core.common.DefaultRealmService.getTenantUserRealm(DefaultRealmService.java:177) > at > org.wso2.carbon.registry.core.session.UserRegistry.init(UserRegistry.java:266) > ... 20 more > Caused by: java.lang.NullPointerException: Tenant domain has not been > set in CarbonContext > at > org.wso2.carbon.caching.impl.CacheManagerFactoryImpl.getCacheManager(CacheManagerFactoryImpl.java:79) > at > org.wso2.carbon.user.core.tenant.TenantCache.getTenantCache(TenantCache.java:39) > at > org.wso2.carbon.user.core.tenant.TenantCache.getValueFromCache(TenantCache.java:77) > at > org.wso2.carbon.user.core.tenant.JDBCTenantManager.getTenant(JDBCTenantManager.java:290) > at > org.wso2.carbon.user.core.tenant.JDBCTenantManager.getTenant(JDBCTenantManager.java:54) > at > org.wso2.carbon.user.core.common.DefaultRealmService.getTenantUserRealm(DefaultRealmService.java:159) > ... 21 more > Shavantha Weerasinghe > Senior Software Engineer QA > WSO2, Inc. > lean.enterprise.middleware. > http://wso2.com > http://wso2.org > Tel : 94 11 214 5345 > Fax :94 11 2145300 _______________________________________________ Dev mailing list [email protected] http://wso2.org/cgi-bin/mailman/listinfo/dev
