stratos-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Nirmal Fernando <nirmal070...@gmail.com>
Subject Re: MQTT client library for Stratos messaging component.
Date Wed, 24 Sep 2014 05:20:49 GMT
Logged a jira https://issues.apache.org/jira/browse/STRATOS-820

On Wed, Sep 24, 2014 at 10:28 AM, Nirmal Fernando <nirmal070125@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 <gayang@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 <gayang@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  : 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/

Mime
View raw message