You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@stratos.apache.org by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2014/09/24 07:20:34 UTC

[jira] [Commented] (STRATOS-820) Error when publishing tenant subscribed event

    [ https://issues.apache.org/jira/browse/STRATOS-820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14145912#comment-14145912 ] 

ASF GitHub Bot commented on STRATOS-820:
----------------------------------------

Github user nirmal070125 commented on the pull request:

    https://github.com/apache/stratos/pull/50#issuecomment-56625991
  
    I solved merge conflicts and integrated this PR. Thanks Gayan.
    
    However, later found that this PR has introduced a regression https://issues.apache.org/jira/browse/STRATOS-820 
    
    Gayan, could you please send another PR to solve this regression issue?


> Error when publishing tenant subscribed event
> ---------------------------------------------
>
>                 Key: STRATOS-820
>                 URL: https://issues.apache.org/jira/browse/STRATOS-820
>             Project: Stratos
>          Issue Type: Bug
>          Components: Stratos Manager
>            Reporter: Nirmal Fernando
>            Assignee: Gayan Gunarathne
>            Priority: Blocker
>             Fix For: 4.1.0 M1
>
>
> With https://github.com/apache/stratos/pull/50 PR, I am seen following error at Stratos back-end. I am running locally built stratos with an activemq. 
> [2014-09-24 10:23:56,924]  INFO {org.apache.stratos.manager.publisher.InstanceNotificationPublisher} -  Publishing Instance Cleanup Event: [cluster] test2.php.domain
> [2014-09-24 10:24:21,031] ERROR {org.apache.stratos.messaging.broker.publish.TopicPublisher} -  Error while publishing to the topic: tenant/#
> Client is connected (32100)
> 	at org.eclipse.paho.client.mqttv3.internal.ExceptionHelper.createMqttException(ExceptionHelper.java:27)
> 	at org.eclipse.paho.client.mqttv3.MqttAsyncClient.connect(MqttAsyncClient.java:452)
> 	at org.eclipse.paho.client.mqttv3.MqttClient.connect(MqttClient.java:236)
> 	at org.eclipse.paho.client.mqttv3.MqttClient.connect(MqttClient.java:229)
> 	at org.apache.stratos.messaging.broker.publish.TopicPublisher.publish(TopicPublisher.java:82)
> 	at org.apache.stratos.messaging.broker.publish.EventPublisher.publish(EventPublisher.java:51)
> 	at org.apache.stratos.messaging.broker.publish.EventPublisher.publish(EventPublisher.java:45)
> 	at org.apache.stratos.manager.subscription.utils.CartridgeSubscriptionUtils$TenantSubscribedEventPublisher.run(CartridgeSubscriptionUtils.java:174)
> 	at org.apache.stratos.manager.subscription.utils.CartridgeSubscriptionUtils$1.execute(CartridgeSubscriptionUtils.java:191)
> 	at org.apache.stratos.manager.subscription.utils.CartridgeSubscriptionUtils.publishTenantSubscribedEvent(CartridgeSubscriptionUtils.java:195)
> 	at org.apache.stratos.manager.manager.CartridgeSubscriptionManager.registerCartridgeSubscription(CartridgeSubscriptionManager.java:357)
> 	at org.apache.stratos.manager.manager.CartridgeSubscriptionManager.subscribeToCartridgeWithProperties(CartridgeSubscriptionManager.java:150)
> 	at org.apache.stratos.rest.endpoint.services.ServiceUtils.subscribe(ServiceUtils.java:991)
> 	at org.apache.stratos.rest.endpoint.services.StratosAdmin.subscribe(StratosAdmin.java:401)
> 	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> 	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
> 	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
> 	at java.lang.reflect.Method.invoke(Method.java:597)
> 	at org.apache.cxf.service.invoker.AbstractInvoker.performInvocation(AbstractInvoker.java:180)
> 	at org.apache.cxf.service.invoker.AbstractInvoker.invoke(AbstractInvoker.java:96)
> 	at org.apache.cxf.jaxrs.JAXRSInvoker.invoke(JAXRSInvoker.java:194)
> 	at org.apache.cxf.jaxrs.JAXRSInvoker.invoke(JAXRSInvoker.java:100)
> 	at org.apache.cxf.interceptor.ServiceInvokerInterceptor$1.run(ServiceInvokerInterceptor.java:57)
> 	at org.apache.cxf.interceptor.ServiceInvokerInterceptor.handleMessage(ServiceInvokerInterceptor.java:93)
> 	at org.apache.cxf.phase.PhaseInterceptorChain.doIntercept(PhaseInterceptorChain.java:271)
> 	at org.apache.cxf.transport.ChainInitiationObserver.onMessage(ChainInitiationObserver.java:121)
> 	at org.apache.cxf.transport.http.AbstractHTTPDestination.invoke(AbstractHTTPDestination.java:239)
> 	at org.apache.cxf.transport.servlet.ServletController.invokeDestination(ServletController.java:223)
> 	at org.apache.cxf.transport.servlet.ServletController.invoke(ServletController.java:203)
> 	at org.apache.cxf.transport.servlet.ServletController.invoke(ServletController.java:137)
> 	at org.apache.cxf.transport.servlet.CXFNonSpringServlet.invoke(CXFNonSpringServlet.java:159)
> 	at org.apache.cxf.transport.servlet.AbstractHTTPServlet.handleRequest(AbstractHTTPServlet.java:286)
> 	at org.apache.cxf.transport.servlet.AbstractHTTPServlet.service(AbstractHTTPServlet.java:264)
> 	at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:305)
> 	at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:210)
> 	at org.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:222)
> 	at org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:123)
> 	at org.apache.catalina.authenticator.AuthenticatorBase.invoke(AuthenticatorBase.java:472)
> 	at org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:171)
> 	at org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:99)
> 	at org.wso2.carbon.tomcat.ext.valves.CompositeValve.continueInvocation(CompositeValve.java:178)
> 	at org.wso2.carbon.tomcat.ext.valves.CarbonTomcatValve$1.invoke(CarbonTomcatValve.java:47)
> 	at org.wso2.carbon.webapp.mgt.TenantLazyLoaderValve.invoke(TenantLazyLoaderValve.java:56)
> 	at org.wso2.carbon.tomcat.ext.valves.TomcatValveContainer.invokeValves(TomcatValveContainer.java:47)
> 	at org.wso2.carbon.tomcat.ext.valves.CompositeValve.invoke(CompositeValve.java:141)
> 	at org.wso2.carbon.tomcat.ext.valves.CarbonStuckThreadDetectionValve.invoke(CarbonStuckThreadDetectionValve.java:156)
> 	at org.apache.catalina.valves.AccessLogValve.invoke(AccessLogValve.java:936)
> 	at org.wso2.carbon.tomcat.ext.valves.CarbonContextCreatorValve.invoke(CarbonContextCreatorValve.java:52)
> 	at org.apache.catalina.core.StandardEngineValve.invoke(StandardEngineValve.java:118)
> 	at org.apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:407)
> 	at org.apache.coyote.http11.AbstractHttp11Processor.process(AbstractHttp11Processor.java:1004)
> 	at org.apache.coyote.AbstractProtocol$AbstractConnectionHandler.process(AbstractProtocol.java:589)
> 	at org.apache.tomcat.util.net.NioEndpoint$SocketProcessor.run(NioEndpoint.java:1653)
> 	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
> 	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
> 	at java.lang.Thread.run(Thread.java:695)
> [2014-09-24 10:24:21,051]  INFO {org.apache.stratos.messaging.broker.publish.TopicPublisher} -  Will try to re-publish in 60 sec



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)