Hi All,
We have written two CEP extensions to load a model from the registry using
WS-API, transformer and function. Our extensions work fine when CEP is in
a stable mode.
but after CEP restarts CEP tries to execute our extensions in its beginning
state. at that time registry was refusing our request. due to that reason
we got this following error,but Registry was available at that time.
- ERROR - {EventProcessorDeployer} Execution plan is not deployed and
in inactive state : NERExecutionPlan.xml
org.wso2.carbon.event.processor.core.exception.ExecutionPlanConfigurationException:
Invalid query specified, java.net.ConnectException: Connection refused
This error occurs only for one execution plan (NERExecutionPlan) which we
used our transformer. Other execution plan (ClassifyingExecutionPlan)
perfectly works in the beginning state also. both extensions are using
models from the registry.
We have tried threads but it didn't work.we hold the Extension thread till
another thread reconnects to the registry and pass the file. then CEP
didn't start properly :(
if we release the Extension thread, then file not be loaded.
Is there any proper way to solve this?
We load models in the init method. As per my understanding CEP execute init
methods in the beginning state. If we load models in processEvent method we
can neglect these errors. but It's not a proper way.
Please how can we figure out this.
Please find the attached error messages and execution plans files.
Thanks,
Madhawa
--
*Madhawa Gunasekara*
Software Engineering Intern
WSO2 Inc.; http://wso2.com
lean.enterprise.middleware
mobile: +94 719411002
[2014-11-14 03:28:36,296] ERROR - {EventProcessorDeployer} Execution plan is
not deployed and in inactive state : NERExecutionPlan.xml
org.wso2.carbon.event.processor.core.exception.ExecutionPlanConfigurationException:
Invalid query specified, java.net.ConnectException: Connection refused
at
org.wso2.carbon.event.processor.core.internal.CarbonEventProcessorService.addExecutionPlanConfiguration(CarbonEventProcessorService.java:333)
at
org.wso2.carbon.event.processor.core.EventProcessorDeployer.processDeploy(EventProcessorDeployer.java:138)
at
org.wso2.carbon.event.processor.core.EventProcessorDeployer.deploy(EventProcessorDeployer.java:75)
at
org.apache.axis2.deployment.repository.util.DeploymentFileData.deploy(DeploymentFileData.java:136)
at
org.apache.axis2.deployment.DeploymentEngine.doDeploy(DeploymentEngine.java:807)
at
org.apache.axis2.deployment.repository.util.WSInfoList.update(WSInfoList.java:144)
at
org.apache.axis2.deployment.RepositoryListener.update(RepositoryListener.java:377)
at
org.apache.axis2.deployment.RepositoryListener.checkServices(RepositoryListener.java:254)
at
org.apache.axis2.deployment.DeploymentEngine.loadServices(DeploymentEngine.java:135)
at
org.wso2.carbon.core.CarbonAxisConfigurator.deployServices(CarbonAxisConfigurator.java:559)
at
org.wso2.carbon.core.internal.DeploymentServerStartupObserver.completingServerStartup(DeploymentServerStartupObserver.java:48)
at
org.wso2.carbon.core.internal.CarbonCoreServiceComponent.notifyBefore(CarbonCoreServiceComponent.java:233)
at
org.wso2.carbon.core.internal.StartupFinalizerServiceComponent.completeInitialization(StartupFinalizerServiceComponent.java:182)
at
org.wso2.carbon.core.internal.StartupFinalizerServiceComponent.serviceChanged(StartupFinalizerServiceComponent.java:285)
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.server.admin.internal.ServerAdminServiceComponent.activate(ServerAdminServiceComponent.java:106)
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:601)
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.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.core.init.CarbonServerManager.initializeCarbon(CarbonServerManager.java:517)
at
org.wso2.carbon.core.init.CarbonServerManager.start(CarbonServerManager.java:219)
at
org.wso2.carbon.core.internal.CarbonCoreServiceComponent.activate(CarbonCoreServiceComponent.java:89)
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:601)
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.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.equinox.http.servlet.internal.Activator.registerHttpService(Activator.java:81)
at
org.eclipse.equinox.http.servlet.internal.Activator.addProxyServlet(Activator.java:60)
at
org.eclipse.equinox.http.servlet.internal.ProxyServlet.init(ProxyServlet.java:40)
at
org.wso2.carbon.tomcat.ext.servlet.DelegationServlet.init(DelegationServlet.java:38)
at
org.apache.catalina.core.StandardWrapper.initServlet(StandardWrapper.java:1279)
at
org.apache.catalina.core.StandardWrapper.loadServlet(StandardWrapper.java:1192)
at
org.apache.catalina.core.StandardWrapper.load(StandardWrapper.java:1087)
at
org.apache.catalina.core.StandardContext.loadOnStartup(StandardContext.java:5210)
at
org.apache.catalina.core.StandardContext.startInternal(StandardContext.java:5493)
at org.apache.catalina.util.LifecycleBase.start(LifecycleBase.java:150)
at
org.apache.catalina.core.ContainerBase$StartChild.call(ContainerBase.java:1559)
at
org.apache.catalina.core.ContainerBase$StartChild.call(ContainerBase.java:1549)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:334)
at java.util.concurrent.FutureTask.run(FutureTask.java:166)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1110)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:603)
at java.lang.Thread.run(Thread.java:722)
Caused by: java.lang.RuntimeException: java.net.ConnectException: Connection
refused
at
org.apache.abdera.protocol.client.AbderaClient.execute(AbderaClient.java:805)
at
org.apache.abdera.protocol.client.AbderaClient.head(AbderaClient.java:224)
at
org.wso2.carbon.registry.app.RemoteRegistry.resourceExists(RemoteRegistry.java:436)
at
org.wso2.siddhi.extension.nlp.ModelLoader.retrieveModel(ModelLoader.java:99)
at
org.wso2.siddhi.extension.nlp.ner.LocationRecognizer.init(LocationRecognizer.java:203)
at
org.wso2.siddhi.core.query.processor.transform.TransformProcessor.initTransformProcessor(TransformProcessor.java:117)
at
org.wso2.siddhi.core.util.parser.StreamParser.updateQueryEventSourceOutDefinition(StreamParser.java:512)
at
org.wso2.siddhi.core.query.creator.BasicQueryCreator.updateQueryEventSourceList(BasicQueryCreator.java:46)
at
org.wso2.siddhi.core.query.creator.QueryCreator.init(QueryCreator.java:66)
at
org.wso2.siddhi.core.query.creator.BasicQueryCreator.<init>(BasicQueryCreator.java:40)
at
org.wso2.siddhi.core.query.creator.QueryCreatorFactiory.constructQueryCreator(QueryCreatorFactiory.java:40)
at org.wso2.siddhi.core.query.QueryManager.<init>(QueryManager.java:72)
at org.wso2.siddhi.core.SiddhiManager.addQuery(SiddhiManager.java:289)
at
org.wso2.siddhi.core.SiddhiManager.addExecutionPlan(SiddhiManager.java:304)
at
org.wso2.carbon.event.processor.core.internal.CarbonEventProcessorService.addExecutionPlanConfiguration(CarbonEventProcessorService.java:331)
... 85 more
Caused by: java.net.ConnectException: Connection refused
at java.net.PlainSocketImpl.socketConnect(Native Method)
at
java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:339)
at
java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:200)
at
java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:182)
at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:391)
at java.net.Socket.connect(Socket.java:579)
at sun.security.ssl.SSLSocketImpl.connect(SSLSocketImpl.java:612)
at sun.security.ssl.SSLSocketImpl.<init>(SSLSocketImpl.java:445)
at
sun.security.ssl.SSLSocketFactoryImpl.createSocket(SSLSocketFactoryImpl.java:140)
at
org.apache.commons.httpclient.protocol.SSLProtocolSocketFactory.createSocket(SSLProtocolSocketFactory.java:82)
at
org.apache.commons.httpclient.protocol.SSLProtocolSocketFactory.createSocket(SSLProtocolSocketFactory.java:127)
at
org.apache.commons.httpclient.HttpConnection.open(HttpConnection.java:707)
at
org.apache.commons.httpclient.MultiThreadedHttpConnectionManager$HttpConnectionAdapter.open(MultiThreadedHttpConnectionManager.java:1361)
at
org.apache.commons.httpclient.HttpMethodDirector.executeWithRetry(HttpMethodDirector.java:387)
at
org.apache.commons.httpclient.HttpMethodDirector.executeMethod(HttpMethodDirector.java:171)
at
org.apache.commons.httpclient.HttpClient.executeMethod(HttpClient.java:397)
at
org.apache.commons.httpclient.HttpClient.executeMethod(HttpClient.java:323)
at
org.apache.abdera.protocol.client.AbderaClient.execute(AbderaClient.java:791)
... 99 more
madhawa30@madhawa30-TECRA-M11:~/WSO2Products/wso2cep-4.0.0-SNAPSHOT/bin$
./wso2server.sh
JAVA_HOME environment variable is set to /usr/local/java/jdk1.7.0_03
CARBON_HOME environment variable is set to
/home/madhawa30/WSO2Products/wso2cep-4.0.0-SNAPSHOT
log4j:WARN No appenders could be found for logger
(org.apache.axiom.util.stax.dialect.StAXDialectDetector).
log4j:WARN Please initialize the log4j system properly.
log4j:WARN See http://logging.apache.org/log4j/1.2/faq.html#noconfig for more
info.
[2014-11-14 03:28:19,616] INFO - {CarbonCoreActivator} Starting WSO2 Carbon...
[2014-11-14 03:28:19,620] INFO - {CarbonCoreActivator} Operating System :
Linux 3.11.0-26-generic, amd64
[2014-11-14 03:28:19,620] INFO - {CarbonCoreActivator} Java Home :
/usr/local/java/jdk1.7.0_03/jre
[2014-11-14 03:28:19,620] INFO - {CarbonCoreActivator} Java Version :
1.7.0_03
[2014-11-14 03:28:19,620] INFO - {CarbonCoreActivator} Java VM :
Java HotSpot(TM) 64-Bit Server VM 22.1-b02,Oracle Corporation
[2014-11-14 03:28:19,620] INFO - {CarbonCoreActivator} Carbon Home :
/home/madhawa30/WSO2Products/wso2cep-4.0.0-SNAPSHOT
[2014-11-14 03:28:19,621] INFO - {CarbonCoreActivator} Java Temp Dir :
/home/madhawa30/WSO2Products/wso2cep-4.0.0-SNAPSHOT/tmp
[2014-11-14 03:28:19,621] INFO - {CarbonCoreActivator} User :
madhawa30, en-US, Asia/Colombo
[2014-11-14 03:28:19,762] WARN - {ValidationResultPrinter} Carbon is
configured to use the default keystore (wso2carbon.jks). To maximize security
when deploying to a production environment, configure a new keystore with a
unique password in the production server profile.
[2014-11-14 03:28:19,846] INFO - {AgentHolder} Agent created !
[2014-11-14 03:28:19,867] INFO - {AgentDS} Successfully deployed Agent Client
[2014-11-14 03:28:19,916] INFO - {ConsumerKafkaServiceDS} Successfully
deployed the KafkaConsumer input event adaptor service
[2014-11-14 03:28:19,996] INFO - {KafkaOutputEventAdaptorServiceDS}
Successfully deployed the Kafka output event adaptor service
[2014-11-14 03:28:21,790] INFO - {CarbonRemoteUserStoreDSComponent} Carbon
Remote User Store activated successfully.
[2014-11-14 03:28:21,914] WARN - {RegistryConfigurationProcessor} Could not
find the handler class
org.wso2.jaggery.scxml.registry.handlers.JaggeryExecutorHandler. This handler
will not be registered. All handler and filter classes should be in the class
path of the Registry.
[2014-11-14 03:28:22,028] INFO - {EmbeddedRegistryService} Configured
Registry in 111ms
[2014-11-14 03:28:22,147] INFO - {RegistryCoreServiceComponent} Registry Mode
: READ-WRITE
[2014-11-14 03:28:22,950] INFO - {DataBridgeDS} Successfully deployed Agent
Server
[2014-11-14 03:28:22,956] INFO - {EventStreamConfigurationHelper} The
stream-manager-config.xml can not found
[2014-11-14 03:28:23,041] INFO - {HAManagementServer} CEP HA Management
Thrift Server started on 192.168.1.104:11224
[2014-11-14 03:28:23,469] INFO - {UserStoreMgtDSComponent} Carbon
UserStoreMgtDSComponent activated successfully.
[2014-11-14 03:28:32,232] INFO - {TaglibUriRule} Nov 14, 2014 3:28:32 AM
org.apache.catalina.startup.TaglibUriRule body
INFO: TLD skipped. URI: http://tiles.apache.org/tags-tiles is already defined
[2014-11-14 03:28:32,696] INFO - {ClusterBuilder} Clustering has been disabled
[2014-11-14 03:28:32,894] INFO - {UserStoreConfigurationDeployer} User Store
Configuration Deployer initiated.
[2014-11-14 03:28:32,933] INFO - {TCPTransportSender} TCP Sender started
[2014-11-14 03:28:33,186] INFO - {ModuleDeployer} Deploying module:
addressing-1.6.1-wso2v11-20141003.221230-650 -
file:/home/madhawa30/WSO2Products/wso2cep-4.0.0-SNAPSHOT/repository/deployment/client/modules/addressing-1.6.1-wso2v11-20141003.221230-650.mar
[2014-11-14 03:28:33,191] INFO - {ModuleDeployer} Deploying module:
rampart-1.6.1-wso2v11 -
file:/home/madhawa30/WSO2Products/wso2cep-4.0.0-SNAPSHOT/repository/deployment/client/modules/rampart-1.6.1-wso2v11.mar
[2014-11-14 03:28:33,193] INFO - {MailTransportSender} MAILTO Sender started
[2014-11-14 03:28:33,202] INFO - {TCPTransportSender} TCP Sender started
[2014-11-14 03:28:33,913] INFO - {DeploymentInterceptor} Deploying Axis2
service: EventSimulatorAdminService {super-tenant}
[2014-11-14 03:28:33,913] INFO - {DeploymentEngine} Deploying Web service:
org.wso2.carbon.event.simulator.admin-2.0.0.SNAPSHOT -
[2014-11-14 03:28:34,920] INFO - {DeploymentEngine} Deploying Web service:
org.wso2.carbon.tryit-4.3.0.SNAPSHOT -
[2014-11-14 03:28:35,191] INFO - {CarbonServerManager} Repository :
/home/madhawa30/WSO2Products/wso2cep-4.0.0-SNAPSHOT/repository/deployment/server/
[2014-11-14 03:28:35,195] INFO - {FileEventAdaptorServiceHolder} File input
event adaptor waiting for dependent configurations to load
[2014-11-14 03:28:35,196] INFO - {KafkaEventAdaptorServiceHolder} Kafka input
event adaptor waiting for dependent configurations to load
[2014-11-14 03:28:35,309] INFO - {PermissionUpdater} Permission cache updated
for tenant -1234
[2014-11-14 03:28:35,420] INFO - {ThriftDataReceiver} Thrift Server started
at 192.168.1.104
[2014-11-14 03:28:35,428] INFO - {ThriftDataReceiver} Thrift SSL port : 7711
[2014-11-14 03:28:35,432] INFO - {ThriftDataReceiver} Thrift port : 7611
[2014-11-14 03:28:35,441] INFO - {EmailEventAdaptorServiceDS} Email input
event adaptor waiting for dependent configurations to load
[2014-11-14 03:28:35,453] INFO - {JMSEventAdaptorServiceHolder} JMS input
event adaptor waiting for dependent configurations to load
[2014-11-14 03:28:35,472] INFO - {MQTTEventAdaptorServiceValueHolder} MQTT
input event adaptor waiting for dependent configurations to load
[2014-11-14 03:28:35,580] INFO - {IdentityCoreServiceComponent} Identity
Database schema initialization check was skipped since 'setup' variable was not
given during startup
[2014-11-14 03:28:35,685] INFO - {HttpsTransportListener} HTTPS port :
9443
[2014-11-14 03:28:35,685] INFO - {HttpTransportListener} HTTP port :
9763
[2014-11-14 03:28:35,892] INFO - {EventJunction} Producer added to the
junction. Stream:classifiedStream:1.0.0
[2014-11-14 03:28:35,895] INFO - {EventJunction} Consumer added to the
junction. Stream:preprocessedStream:1.0.0
[2014-11-14 03:28:35,895] INFO - {EventProcessorDeployer} Execution plan is
deployed successfully and in active state : ClassifyingExecutionPlan
[2014-11-14 03:28:35,899] INFO - {OutputEventAdaptorDeployer} Output Event
Adaptor successfully deployed and in active state : DefaultLoggerOutputAdaptor
[2014-11-14 03:28:35,902] INFO - {InputEventAdaptorDeployer} Input Event
Adaptor deployed successfully and in active state : DefaultWSO2EventInputAdaptor
[2014-11-14 03:28:35,907] INFO - {EventFormatterDeployer} Event Formatter
deployment held back and in inactive state : EmailEventFormatter.xml, waiting
for dependency : emailAdapter
[2014-11-14 03:28:35,950] INFO - {EventJunction} Producer added to the
junction. Stream:uiFeedStream:1.0.0
[2014-11-14 03:28:35,953] INFO - {EventJunction} Consumer added to the
junction. Stream:transformedStream:1.0.0
[2014-11-14 03:28:35,953] INFO - {EventProcessorDeployer} Execution plan is
deployed successfully and in active state : GeocodingExecutionPlan
[2014-11-14 03:28:35,954] INFO - {OutputEventAdaptorDeployer} Output Event
Adaptor successfully deployed and in active state : MysqlTwitterTextAdaptor
[2014-11-14 03:28:36,296] ERROR - {EventProcessorDeployer} Execution plan is
not deployed and in inactive state : NERExecutionPlan.xml
org.wso2.carbon.event.processor.core.exception.ExecutionPlanConfigurationException:
Invalid query specified, java.net.ConnectException: Connection refused
at
org.wso2.carbon.event.processor.core.internal.CarbonEventProcessorService.addExecutionPlanConfiguration(CarbonEventProcessorService.java:333)
at
org.wso2.carbon.event.processor.core.EventProcessorDeployer.processDeploy(EventProcessorDeployer.java:138)
at
org.wso2.carbon.event.processor.core.EventProcessorDeployer.deploy(EventProcessorDeployer.java:75)
at
org.apache.axis2.deployment.repository.util.DeploymentFileData.deploy(DeploymentFileData.java:136)
at
org.apache.axis2.deployment.DeploymentEngine.doDeploy(DeploymentEngine.java:807)
at
org.apache.axis2.deployment.repository.util.WSInfoList.update(WSInfoList.java:144)
at
org.apache.axis2.deployment.RepositoryListener.update(RepositoryListener.java:377)
at
org.apache.axis2.deployment.RepositoryListener.checkServices(RepositoryListener.java:254)
at
org.apache.axis2.deployment.DeploymentEngine.loadServices(DeploymentEngine.java:135)
at
org.wso2.carbon.core.CarbonAxisConfigurator.deployServices(CarbonAxisConfigurator.java:559)
at
org.wso2.carbon.core.internal.DeploymentServerStartupObserver.completingServerStartup(DeploymentServerStartupObserver.java:48)
at
org.wso2.carbon.core.internal.CarbonCoreServiceComponent.notifyBefore(CarbonCoreServiceComponent.java:233)
at
org.wso2.carbon.core.internal.StartupFinalizerServiceComponent.completeInitialization(StartupFinalizerServiceComponent.java:182)
at
org.wso2.carbon.core.internal.StartupFinalizerServiceComponent.serviceChanged(StartupFinalizerServiceComponent.java:285)
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.server.admin.internal.ServerAdminServiceComponent.activate(ServerAdminServiceComponent.java:106)
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:601)
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.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.core.init.CarbonServerManager.initializeCarbon(CarbonServerManager.java:517)
at
org.wso2.carbon.core.init.CarbonServerManager.start(CarbonServerManager.java:219)
at
org.wso2.carbon.core.internal.CarbonCoreServiceComponent.activate(CarbonCoreServiceComponent.java:89)
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:601)
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.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.equinox.http.servlet.internal.Activator.registerHttpService(Activator.java:81)
at
org.eclipse.equinox.http.servlet.internal.Activator.addProxyServlet(Activator.java:60)
at
org.eclipse.equinox.http.servlet.internal.ProxyServlet.init(ProxyServlet.java:40)
at
org.wso2.carbon.tomcat.ext.servlet.DelegationServlet.init(DelegationServlet.java:38)
at
org.apache.catalina.core.StandardWrapper.initServlet(StandardWrapper.java:1279)
at
org.apache.catalina.core.StandardWrapper.loadServlet(StandardWrapper.java:1192)
at
org.apache.catalina.core.StandardWrapper.load(StandardWrapper.java:1087)
at
org.apache.catalina.core.StandardContext.loadOnStartup(StandardContext.java:5210)
at
org.apache.catalina.core.StandardContext.startInternal(StandardContext.java:5493)
at org.apache.catalina.util.LifecycleBase.start(LifecycleBase.java:150)
at
org.apache.catalina.core.ContainerBase$StartChild.call(ContainerBase.java:1559)
at
org.apache.catalina.core.ContainerBase$StartChild.call(ContainerBase.java:1549)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:334)
at java.util.concurrent.FutureTask.run(FutureTask.java:166)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1110)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:603)
at java.lang.Thread.run(Thread.java:722)
Caused by: java.lang.RuntimeException: java.net.ConnectException: Connection
refused
at
org.apache.abdera.protocol.client.AbderaClient.execute(AbderaClient.java:805)
at
org.apache.abdera.protocol.client.AbderaClient.head(AbderaClient.java:224)
at
org.wso2.carbon.registry.app.RemoteRegistry.resourceExists(RemoteRegistry.java:436)
at
org.wso2.siddhi.extension.nlp.ModelLoader.retrieveModel(ModelLoader.java:99)
at
org.wso2.siddhi.extension.nlp.ner.LocationRecognizer.init(LocationRecognizer.java:203)
at
org.wso2.siddhi.core.query.processor.transform.TransformProcessor.initTransformProcessor(TransformProcessor.java:117)
at
org.wso2.siddhi.core.util.parser.StreamParser.updateQueryEventSourceOutDefinition(StreamParser.java:512)
at
org.wso2.siddhi.core.query.creator.BasicQueryCreator.updateQueryEventSourceList(BasicQueryCreator.java:46)
at
org.wso2.siddhi.core.query.creator.QueryCreator.init(QueryCreator.java:66)
at
org.wso2.siddhi.core.query.creator.BasicQueryCreator.<init>(BasicQueryCreator.java:40)
at
org.wso2.siddhi.core.query.creator.QueryCreatorFactiory.constructQueryCreator(QueryCreatorFactiory.java:40)
at org.wso2.siddhi.core.query.QueryManager.<init>(QueryManager.java:72)
at org.wso2.siddhi.core.SiddhiManager.addQuery(SiddhiManager.java:289)
at
org.wso2.siddhi.core.SiddhiManager.addExecutionPlan(SiddhiManager.java:304)
at
org.wso2.carbon.event.processor.core.internal.CarbonEventProcessorService.addExecutionPlanConfiguration(CarbonEventProcessorService.java:331)
... 85 more
Caused by: java.net.ConnectException: Connection refused
at java.net.PlainSocketImpl.socketConnect(Native Method)
at
java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:339)
at
java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:200)
at
java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:182)
at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:391)
at java.net.Socket.connect(Socket.java:579)
at sun.security.ssl.SSLSocketImpl.connect(SSLSocketImpl.java:612)
at sun.security.ssl.SSLSocketImpl.<init>(SSLSocketImpl.java:445)
at
sun.security.ssl.SSLSocketFactoryImpl.createSocket(SSLSocketFactoryImpl.java:140)
at
org.apache.commons.httpclient.protocol.SSLProtocolSocketFactory.createSocket(SSLProtocolSocketFactory.java:82)
at
org.apache.commons.httpclient.protocol.SSLProtocolSocketFactory.createSocket(SSLProtocolSocketFactory.java:127)
at
org.apache.commons.httpclient.HttpConnection.open(HttpConnection.java:707)
at
org.apache.commons.httpclient.MultiThreadedHttpConnectionManager$HttpConnectionAdapter.open(MultiThreadedHttpConnectionManager.java:1361)
at
org.apache.commons.httpclient.HttpMethodDirector.executeWithRetry(HttpMethodDirector.java:387)
at
org.apache.commons.httpclient.HttpMethodDirector.executeMethod(HttpMethodDirector.java:171)
at
org.apache.commons.httpclient.HttpClient.executeMethod(HttpClient.java:397)
at
org.apache.commons.httpclient.HttpClient.executeMethod(HttpClient.java:323)
at
org.apache.abdera.protocol.client.AbderaClient.execute(AbderaClient.java:791)
... 99 more
from preprocessedStream
select OpenNLP:Categorise(convertedText,"/en-doccat.bin") as
category,convertedText,createdAt
insert into tempStream;
from tempStream[isMatch('Feed',category)]
select convertedText, createdAt
insert into classifiedStream;
from
classifiedStream#transform.OpenNLP:getRecognizedLocations(convertedText,4,"/en-location.bin")
select * insert into templocationStream;
from
classifiedStream#transform.OpenNLP:getRecognizedNameEntities(convertedText,1,"/en-trafficlevel.bin")
select * insert into temptrafficlevelStream;
from S1=classifiedStream, S2=temptrafficlevelStream, S3=templocationStream
select S1.createdAt as time, S2.nameElement1 as trafficLevel, S3.location1Name
as location1, S3.location2Name as location2, S3.location3Name as location3,
S3.location4Name as location4
insert into locationsStream;
_______________________________________________
Dev mailing list
Dev@wso2.org
http://wso2.org/cgi-bin/mailman/listinfo/dev
