Return-Path: X-Original-To: apmail-stratos-dev-archive@minotaur.apache.org Delivered-To: apmail-stratos-dev-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 33EB71152B for ; Wed, 24 Sep 2014 05:21:16 +0000 (UTC) Received: (qmail 65436 invoked by uid 500); 24 Sep 2014 05:21:15 -0000 Delivered-To: apmail-stratos-dev-archive@stratos.apache.org Received: (qmail 65386 invoked by uid 500); 24 Sep 2014 05:21:15 -0000 Mailing-List: contact dev-help@stratos.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@stratos.apache.org Delivered-To: mailing list dev@stratos.apache.org Received: (qmail 65375 invoked by uid 99); 24 Sep 2014 05:21:15 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 24 Sep 2014 05:21:15 +0000 X-ASF-Spam-Status: No, hits=1.7 required=5.0 tests=FREEMAIL_ENVFROM_END_DIGIT,HTML_MESSAGE,RCVD_IN_DNSWL_LOW,SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (athena.apache.org: domain of nirmal070125@gmail.com designates 74.125.82.174 as permitted sender) Received: from [74.125.82.174] (HELO mail-we0-f174.google.com) (74.125.82.174) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 24 Sep 2014 05:21:11 +0000 Received: by mail-we0-f174.google.com with SMTP id w62so5128099wes.33 for ; Tue, 23 Sep 2014 22:20:50 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20120113; h=mime-version:in-reply-to:references:date:message-id:subject:from:to :content-type; bh=pAsMIPfY+IWWsdBlHXbWh0tLWh/UP7u8rcDTICDnDf0=; b=TJEYwZGmEgbtcXOq0kxiTd3g+Apgr5JFuuVSiXJVv3FqYqYE47Y3a8pMUmFnwUxlwe 28oOw0LQXKGZpXAC5Dd+cuFsu8JKCzjc+OVU/eM2+rpyS/BZrXSGP0F0I8wJ+dcz4LZm L6PIJgOFOBd8vHsFQJtYv9YtM2J2lvUIO8emwZR8+4H9DbsuvcuMn7CElMCoI17Vk6d7 lIDP5z7ZSaSskbt38rY/Bv25bGxNJwwsE3nAP3ZEb0z8wjzaYpxFktJclgI5yYG5PjcB amQNWRkTxfiAuC4his4Gj0dxdNPzMxYmeZdO78J0FNXeCkz5ScMQUwT9KkR0sHtl9wYN aOCQ== MIME-Version: 1.0 X-Received: by 10.180.19.1 with SMTP id a1mr29031883wie.5.1411536050001; Tue, 23 Sep 2014 22:20:50 -0700 (PDT) Received: by 10.194.61.211 with HTTP; Tue, 23 Sep 2014 22:20:49 -0700 (PDT) In-Reply-To: References: Date: Wed, 24 Sep 2014 10:50:49 +0530 Message-ID: Subject: Re: MQTT client library for Stratos messaging component. From: Nirmal Fernando To: dev Content-Type: multipart/alternative; boundary=bcaec53d5e05d91cca0503c8d8fd X-Virus-Checked: Checked by ClamAV on apache.org --bcaec53d5e05d91cca0503c8d8fd Content-Type: text/plain; charset=UTF-8 Logged a jira https://issues.apache.org/jira/browse/STRATOS-820 On Wed, Sep 24, 2014 at 10:28 AM, Nirmal Fernando 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 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 >> 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 : gayang@wso2.com | mobile : +94 766819985 >>> >>> >> >> >> >> -- >> Best Regards, >> >> Gayan Gunarathne >> Technical Lead >> WSO2 Inc. (http://wso2.com) >> email : gayang@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/ --bcaec53d5e05d91cca0503c8d8fd Content-Type: text/html; charset=UTF-8 Content-Transfer-Encoding: quoted-printable

On Wed= , Sep 24, 2014 at 10:28 AM, Nirmal Fernando <nirmal070125@gmail.com= > wrote:
H= i Gayan,

With this PR, I am seen following error at Stra= tos back-end. I am running locally built stratos with an activemq. What am = I missing?=C2=A0

[2014-09-24 10:23:56,924]=C2=A0 INFO {org.apache.st= ratos.manager.publisher.InstanceNotificationPublisher} -=C2=A0 Publishing I= nstance Cleanup Event: [cluster] test2.php.domain

[2014-09-24 10:24:= 21,031] ERROR {org.apache.stratos.messaging.broker.publish.TopicPublisher} = -=C2=A0 Error while publishing to the topic: tenant/#

Client is connecte= d (32100)

at org.eclipse.paho.client.mqttv3.internal.Excep= tionHelper.createMqttException(ExceptionHelper.java:27)

at org.eclipse.paho.client.mqttv3.MqttAsyncClien= t.connect(MqttAsyncClient.java:452)

at org.eclipse.paho.client.mqttv3.MqttClient.con= nect(MqttClient.java:236)

at org.eclipse.paho.client.mqttv3.MqttClient.con= nect(MqttClient.java:229)

at org.apache.stratos.messaging.broker.publish.T= opicPublisher.publish(TopicPublisher.java:82)

at org.apache.stratos.messaging.broker.publish.E= ventPublisher.publish(EventPublisher.java:51)

at org.apache.stratos.messaging.broker.publish.E= ventPublisher.publish(EventPublisher.java:45)

at org.apache.stratos.manager.subscription.utils= .CartridgeSubscriptionUtils$TenantSubscribedEventPublisher.run(CartridgeSub= scriptionUtils.java:174)

at org.apache.stratos.manager.subscription.utils= .CartridgeSubscriptionUtils$1.execute(CartridgeSubscriptionUtils.java:191)<= /p>

at org.apache.stratos.manager.subscription.utils= .CartridgeSubscriptionUtils.publishTenantSubscribedEvent(CartridgeSubscript= ionUtils.java:195)

at org.apache.stratos.manager.manager.CartridgeS= ubscriptionManager.registerCartridgeSubscription(CartridgeSubscriptionManag= er.java:357)

at org.apache.stratos.manager.manager.CartridgeS= ubscriptionManager.subscribeToCartridgeWithProperties(CartridgeSubscription= Manager.java:150)

at org.apache.stratos.rest.endpoint.services.Ser= viceUtils.subscribe(ServiceUtils.java:991)

at org.apache.stratos.rest.endpoint.services.Str= atosAdmin.subscribe(StratosAdmin.java:401)

at sun.reflect.NativeMethodAccessorImpl.invoke0(= Native Method)

at sun.reflect.NativeMethodAccessorImpl.invoke(N= ativeMethodAccessorImpl.java:39)

at sun.reflect.DelegatingMethodAccessorImpl.invo= ke(DelegatingMethodAccessorImpl.java:25)

at java.lang.reflect.Method.invoke(Method.java:5= 97)

at org.apache.cxf.service.invoker.AbstractInvoke= r.performInvocation(AbstractInvoker.java:180)

at org.apache.cxf.service.invoker.AbstractInvoke= r.invoke(AbstractInvoker.java:96)

at org.apache.cxf.jaxrs.JAXRSInvoker.invoke(JAXR= SInvoker.java:194)

at org.apache.cxf.jaxrs.JAXRSInvoker.invoke(JAXR= SInvoker.java:100)

at org.apache.cxf.interceptor.ServiceInvokerInte= rceptor$1.run(ServiceInvokerInterceptor.java:57)

at org.apache.cxf.interceptor.ServiceInvokerInte= rceptor.handleMessage(ServiceInvokerInterceptor.java:93)

at org.apache.cxf.phase.PhaseInterceptorChain.do= Intercept(PhaseInterceptorChain.java:271)

at org.apache.cxf.transport.ChainInitiationObser= ver.onMessage(ChainInitiationObserver.java:121)

at org.apache.cxf.transport.http.AbstractHTTPDes= tination.invoke(AbstractHTTPDestination.java:239)

at org.apache.cxf.transport.servlet.ServletContr= oller.invokeDestination(ServletController.java:223)

at org.apache.cxf.transport.servlet.ServletContr= oller.invoke(ServletController.java:203)

at org.apache.cxf.transport.servlet.ServletContr= oller.invoke(ServletController.java:137)

at org.apache.cxf.transport.servlet.CXFNonSpring= Servlet.invoke(CXFNonSpringServlet.java:159)

at org.apache.cxf.transport.servlet.AbstractHTTP= Servlet.handleRequest(AbstractHTTPServlet.java:286)

at org.apache.cxf.transport.servlet.AbstractHTTP= Servlet.service(AbstractHTTPServlet.java:264)

at org.apache.catalina.core.ApplicationFilterCha= in.internalDoFilter(ApplicationFilterChain.java:305)

at org.apache.catalina.core.ApplicationFilterCha= in.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.Authenticat= orBase.invoke(AuthenticatorBase.java:472)

at org.apache.catalina.core.StandardHostValve.in= voke(StandardHostValve.java:171)

at org.apache.catalina.valves.ErrorReportValve.i= nvoke(ErrorReportValve.java:99)

at org.wso2.carbon.tomcat.ext.valves.CompositeVa= lve.continueInvocation(CompositeValve.java:178)

at org.wso2.carbon.tomcat.ext.valves.CarbonTomca= tValve$1.invoke(CarbonTomcatValve.java:47)

at org.wso2.carbon.webapp.mgt.TenantLazyLoaderVa= lve.invoke(TenantLazyLoaderValve.java:56)

at org.wso2.carbon.tomcat.ext.valves.TomcatValve= Container.invokeValves(TomcatValveContainer.java:47)

at org.wso2.carbon.tomcat.ext.valves.CompositeVa= lve.invoke(CompositeValve.java:141)

at org.wso2.carbon.tomcat.ext.valves.CarbonStuck= ThreadDetectionValve.invoke(CarbonStuckThreadDetectionValve.java:156)

at org.apache.catalina.valves.AccessLogValve.inv= oke(AccessLogValve.java:936)

at org.wso2.carbon.tomcat.ext.valves.CarbonConte= xtCreatorValve.invoke(CarbonContextCreatorValve.java:52)

at org.apache.catalina.core.StandardEngineValve.= invoke(StandardEngineValve.java:118)

at org.apache.catalina.connector.CoyoteAdapter.s= ervice(CoyoteAdapter.java:407)

at org.apache.coyote.http11.AbstractHttp11Proces= sor.process(AbstractHttp11Processor.java:1004)

at org.apache.coyote.AbstractProtocol$AbstractCo= nnectionHandler.process(AbstractProtocol.java:589)

at org.apache.tomcat.util.net.NioEndpoint$Socket= Processor.run(NioEndpoint.java:1653)

at java.util.concurrent.ThreadPoolExecutor$Worke= r.runTask(ThreadPoolExecutor.java:895)

at java.util.concurrent.ThreadPoolExecutor$Worke= r.run(ThreadPoolExecutor.java:918)

at java.lang.Thread.run(Thread.java:695)

[2014-09-24 10:24:= 21,051]=C2=A0 INFO {org.apache.stratos.messaging.broker.publish.TopicPublis= her} -=C2=A0 Will try to re-publish in 60 sec


On Mon, = Sep 22, 2014 at 2:39 PM, Gayan Gunarathne <gayang@wso2.com> wr= ote:
Hi All,
=C2=A0<= /div>
I have changed the Stratos messaging model to support MQTT.
=

Please find the pull request for this.



Also I have updated the relevant JIRA(STRATOS-791) as = well.

Thanks,
Gayan

=

O= n Thu, Sep 11, 2014 at 12:58 PM, Gayan Gunarathne <gayang@wso2.com> wrote:
Hi All= ,

Based on the discussion[1] and our initial resea= rch, 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]=C2=A0Messaging protocol with Stratos python cartridge agent
[2]=C2=A0https://github.com/gayangunarathne/MQTT-Pub-Sub

Thanks,
Gayan



--=C2=A0
Best Regards,

Gayan Gunarathne
Technical Lead
WSO2 Inc. (http://wso2.com)
email=C2=A0 : gayang@wso2.com=C2=A0 = | mobile : +94 766819985
= =C2=A0



--
Best Regards,

Gayan Gunarathne
Technica= l Lead
WSO2 Inc. <= span style=3D"font-family:arial,helvetica,sans-serif">(http://wso2.com)
=
email=C2=A0 : gayang@wso2.com=C2=A0 | mobile : +94 766819985
=C2=A0
=



<= /div>--
Best Regards,
Nirmal

Nirmal Fernando.
PPMC Member & Commi= tter of Apache Stratos,
Senior Software Engineer, WSO2 Inc.

=



--
Best Regards,
Nirmal

Nirmal Fernando.
PPMC Member & C= ommitter of Apache Stratos,
Senior Software Engineer, WSO2 Inc.
=
--bcaec53d5e05d91cca0503c8d8fd--