I'll remove it Gayan. Thanks. On Thu, Sep 25, 2014 at 9:52 AM, Gayan Gunarathne <gay...@wso2.com> wrote:
> Yeah Nirmal, Seems it mistakenly added.I think we can remove this. > > Thanks, > Gayan > > On Thu, Sep 25, 2014 at 9:26 AM, Nirmal Fernando <nirmal070...@gmail.com> > wrote: > >> Hi Gayan, >> >> I think we have mistakenly added a git sub module >> https://github.com/apache/stratos/tree/docker-integration/tools/cartridge_agent >> ? Could you please check? >> >> On Wed, Sep 24, 2014 at 4:22 PM, Gayan Gunarathne <gay...@wso2.com> >> wrote: >> >>> This is resolved. >>> >>> Pull request : https://github.com/apache/stratos/pull/58 >>> Commit ID : d789aa66ca55b9fda0662865fce818c390a4f043 >>> >>> I also updated the JIRA(STRATOS-820 >>> <https://issues.apache.org/jira/browse/STRATOS-820>) >>> >>> Thanks, >>> Gayan >>> >>> On Wed, Sep 24, 2014 at 10:50 AM, Nirmal Fernando < >>> nirmal070...@gmail.com> wrote: >>> >>>> Logged a jira https://issues.apache.org/jira/browse/STRATOS-820 >>>> >>>> On Wed, Sep 24, 2014 at 10:28 AM, Nirmal Fernando < >>>> nirmal070...@gmail.com> wrote: >>>> >>>>> Hi Gayan, >>>>> >>>>> With this PR, I am seen following error at Stratos back-end. I am >>>>> running locally built stratos with an activemq. What am I missing? >>>>> >>>>> [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 >>>>> >>>>> On Mon, Sep 22, 2014 at 2:39 PM, Gayan Gunarathne <gay...@wso2.com> >>>>> wrote: >>>>> >>>>>> Hi All, >>>>>> >>>>>> I have changed the Stratos messaging model to support MQTT. >>>>>> >>>>>> Please find the pull request for this. >>>>>> >>>>>> https://github.com/apache/stratos/pull/47 >>>>>> >>>>>> >>>>>> Also I have updated the relevant JIRA(STRATOS-791) as well. >>>>>> >>>>>> Thanks, >>>>>> Gayan >>>>>> >>>>>> >>>>>> On Thu, Sep 11, 2014 at 12:58 PM, Gayan Gunarathne <gay...@wso2.com> >>>>>> wrote: >>>>>> >>>>>>> Hi All, >>>>>>> >>>>>>> Based on the discussion[1] and our initial research, we are going to >>>>>>> use the following client library for the Stratos MQTT based message >>>>>>> component. >>>>>>> >>>>>>> http://www.eclipse.org/paho/ >>>>>>> >>>>>>> We have done initial research[2] of the functionality of that >>>>>>> library with both java[3] and python[4]. >>>>>>> >>>>>>> Please feel free to share if you have any thoughts on this. >>>>>>> >>>>>>> >>>>>>> [1] Messaging protocol with Stratos python cartridge agent >>>>>>> [2] https://github.com/gayangunarathne/MQTT-Pub-Sub >>>>>>> [3] https://repo.eclipse.org/content/repositories/paho-releases/ >>>>>>> [4] http://www.eclipse.org/paho/clients/python/ >>>>>>> >>>>>>> Thanks, >>>>>>> Gayan >>>>>>> >>>>>>> >>>>>>> >>>>>>> -- >>>>>>> Best Regards, >>>>>>> >>>>>>> Gayan Gunarathne >>>>>>> Technical Lead >>>>>>> WSO2 Inc. (http://wso2.com) >>>>>>> email : gay...@wso2.com | mobile : +94 766819985 >>>>>>> >>>>>>> >>>>>> >>>>>> >>>>>> >>>>>> -- >>>>>> Best Regards, >>>>>> >>>>>> Gayan Gunarathne >>>>>> Technical Lead >>>>>> WSO2 Inc. (http://wso2.com) >>>>>> email : gay...@wso2.com | mobile : +94 766819985 >>>>>> >>>>>> >>>>> >>>>> >>>>> >>>>> -- >>>>> Best Regards, >>>>> Nirmal >>>>> >>>>> Nirmal Fernando. >>>>> PPMC Member & Committer of Apache Stratos, >>>>> Senior Software Engineer, WSO2 Inc. >>>>> >>>>> Blog: http://nirmalfdo.blogspot.com/ >>>>> >>>> >>>> >>>> >>>> -- >>>> Best Regards, >>>> Nirmal >>>> >>>> Nirmal Fernando. >>>> PPMC Member & Committer of Apache Stratos, >>>> Senior Software Engineer, WSO2 Inc. >>>> >>>> Blog: http://nirmalfdo.blogspot.com/ >>>> >>> >>> >>> >>> -- >>> Best Regards, >>> >>> Gayan Gunarathne >>> Technical Lead >>> WSO2 Inc. (http://wso2.com) >>> email : gay...@wso2.com | mobile : +94 766819985 >>> >>> >> >> >> >> -- >> Best Regards, >> Nirmal >> >> Nirmal Fernando. >> PPMC Member & Committer of Apache Stratos, >> Senior Software Engineer, WSO2 Inc. >> >> Blog: http://nirmalfdo.blogspot.com/ >> > > > > -- > Best Regards, > > Gayan Gunarathne > Technical Lead > WSO2 Inc. (http://wso2.com) > email : gay...@wso2.com | mobile : +94 766819985 > > -- Best Regards, Nirmal Nirmal Fernando. PPMC Member & Committer of Apache Stratos, Senior Software Engineer, WSO2 Inc. Blog: http://nirmalfdo.blogspot.com/
