stratos-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Isuru Haththotuwa <isu...@apache.org>
Subject Re: [Discuss] Messaging Component Improvements
Date Sun, 16 Nov 2014 14:46:01 GMT
The problem was in the MqttTopicConnector class, which was using the wrong
topic name to set as a message property. Fixed it now.

On Sun, Nov 16, 2014 at 5:15 PM, Reka Thirunavukkarasu <reka@wso2.com>
wrote:

> Hi Imesh,
>
> I'm getting the following exception while trying with the fresh pack.
> Topology is not getting initialized due to this..It seems that the correct
> Event name is not getting set for a particular event. Am i missing anything?
>
> [2014-11-16 17:04:33,059] ERROR
> {org.apache.stratos.messaging.message.receiver.topology.TopologyEventMessageDelegator}
> -  Failed to retrieve topology event message
>
> java.lang.RuntimeException: Failed to process message using available
> message processors: [type] org.apache.stratos.messaging.event.topology.#
> [body] {"topology":{"serviceMap":{},"initialized":false}}
>
> at
> org.apache.stratos.messaging.message.processor.topology.MemberTerminatedMessageProcessor.process(MemberTerminatedMessageProcessor.java:70)
>
> at
> org.apache.stratos.messaging.message.processor.topology.MemberSuspendedMessageProcessor.process(MemberSuspendedMessageProcessor.java:69)
>
> at
> org.apache.stratos.messaging.message.processor.topology.MemberMaintenanceModeProcessor.process(MemberMaintenanceModeProcessor.java:66)
>
> at
> org.apache.stratos.messaging.message.processor.topology.MemberReadyToShutdownMessageProcessor.process(MemberReadyToShutdownMessageProcessor.java:65)
>
> at
> org.apache.stratos.messaging.message.processor.topology.MemberActivatedMessageProcessor.process(MemberActivatedMessageProcessor.java:69)
>
> at
> org.apache.stratos.messaging.message.processor.topology.MemberStartedMessageProcessor.process(MemberStartedMessageProcessor.java:69)
>
> at
> org.apache.stratos.messaging.message.processor.topology.InstanceSpawnedMessageProcessor.process(InstanceSpawnedMessageProcessor.java:65)
>
> at
> org.apache.stratos.messaging.message.processor.topology.ClusterTerminatingProcessor.process(ClusterTerminatingProcessor.java:72)
>
> at
> org.apache.stratos.messaging.message.processor.topology.ClusterResetMessageProcessor.process(ClusterResetMessageProcessor.java:71)
>
> at
> org.apache.stratos.messaging.message.processor.topology.ClusterTerminatedProcessor.process(ClusterTerminatedProcessor.java:72)
>
> at
> org.apache.stratos.messaging.message.processor.topology.ClusterRemovedMessageProcessor.process(ClusterRemovedMessageProcessor.java:65)
>
> at
> org.apache.stratos.messaging.message.processor.topology.ClusterInActivateProcessor.process(ClusterInActivateProcessor.java:72)
>
> at
> org.apache.stratos.messaging.message.processor.topology.ClusterActivatedProcessor.process(ClusterActivatedProcessor.java:72)
>
> at
> org.apache.stratos.messaging.message.processor.topology.ClusterCreatedMessageProcessor.process(ClusterCreatedMessageProcessor.java:65)
>
> at
> org.apache.stratos.messaging.message.processor.topology.ApplicationClustersRemovedMessageProcessor.process(ApplicationClustersRemovedMessageProcessor.java:63)
>
> at
> org.apache.stratos.messaging.message.processor.topology.ApplicationClustersCreatedMessageProcessor.process(ApplicationClustersCreatedMessageProcessor.java:67)
>
> at
> org.apache.stratos.messaging.message.processor.topology.ServiceRemovedMessageProcessor.process(ServiceRemovedMessageProcessor.java:64)
>
> at
> org.apache.stratos.messaging.message.processor.topology.ServiceCreatedMessageProcessor.process(ServiceCreatedMessageProcessor.java:65)
>
> at
> org.apache.stratos.messaging.message.processor.topology.CompleteTopologyMessageProcessor.process(CompleteTopologyMessageProcessor.java:75)
>
> at
> org.apache.stratos.messaging.message.processor.MessageProcessorChain.process(MessageProcessorChain.java:60)
>
> at
> org.apache.stratos.messaging.message.receiver.topology.TopologyEventMessageDelegator.run(TopologyEventMessageDelegator.java:73)
>
> at java.lang.Thread.run(Thread.java:695)
>
> [2014-11-16 17:04:34,744] ERROR
> {org.apache.stratos.messaging.message.receiver.topology.TopologyEventMessageDelegator}
> -  Failed to retrieve topology event message
>
> java.lang.RuntimeException: Failed to process message using available
> message processors: [type] org.apache.stratos.messaging.event.topology.#
> [body] {"topology":{"serviceMap":{},"initialized":false}}
>
> at
> org.apache.stratos.messaging.message.processor.topology.MemberTerminatedMessageProcessor.process(MemberTerminatedMessageProcessor.java:70)
>
> at
> org.apache.stratos.messaging.message.processor.topology.MemberSuspendedMessageProcessor.process(MemberSuspendedMessageProcessor.java:69)
>
> at
> org.apache.stratos.messaging.message.processor.topology.MemberMaintenanceModeProcessor.process(MemberMaintenanceModeProcessor.java:66)
>
> at
> org.apache.stratos.messaging.message.processor.topology.MemberReadyToShutdownMessageProcessor.process(MemberReadyToShutdownMessageProcessor.java:65)
>
> at
> org.apache.stratos.messaging.message.processor.topology.MemberActivatedMessageProcessor.process(MemberActivatedMessageProcessor.java:69)
>
> at
> org.apache.stratos.messaging.message.processor.topology.MemberStartedMessageProcessor.process(MemberStartedMessageProcessor.java:69)
>
> at
> org.apache.stratos.messaging.message.processor.topology.InstanceSpawnedMessageProcessor.process(InstanceSpawnedMessageProcessor.java:65)
>
> at
> org.apache.stratos.messaging.message.processor.topology.ClusterTerminatingProcessor.process(ClusterTerminatingProcessor.java:72)
>
> at
> org.apache.stratos.messaging.message.processor.topology.ClusterResetMessageProcessor.process(ClusterResetMessageProcessor.java:71)
>
> at
> org.apache.stratos.messaging.message.processor.topology.ClusterTerminatedProcessor.process(ClusterTerminatedProcessor.java:72)
>
> at
> org.apache.stratos.messaging.message.processor.topology.ClusterRemovedMessageProcessor.process(ClusterRemovedMessageProcessor.java:65)
>
> at
> org.apache.stratos.messaging.message.processor.topology.ClusterInActivateProcessor.process(ClusterInActivateProcessor.java:72)
>
> at
> org.apache.stratos.messaging.message.processor.topology.ClusterActivatedProcessor.process(ClusterActivatedProcessor.java:72)
>
> at
> org.apache.stratos.messaging.message.processor.topology.ClusterCreatedMessageProcessor.process(ClusterCreatedMessageProcessor.java:65)
>
> at
> org.apache.stratos.messaging.message.processor.topology.ApplicationClustersRemovedMessageProcessor.process(ApplicationClustersRemovedMessageProcessor.java:63)
>
> at
> org.apache.stratos.messaging.message.processor.topology.ApplicationClustersCreatedMessageProcessor.process(ApplicationClustersCreatedMessageProcessor.java:67)
>
> at
> org.apache.stratos.messaging.message.processor.topology.ServiceRemovedMessageProcessor.process(ServiceRemovedMessageProcessor.java:64)
>
> at
> org.apache.stratos.messaging.message.processor.topology.ServiceCreatedMessageProcessor.process(ServiceCreatedMessageProcessor.java:65)
>
> at
> org.apache.stratos.messaging.message.processor.topology.CompleteTopologyMessageProcessor.process(CompleteTopologyMessageProcessor.java:75)
>
> at
> org.apache.stratos.messaging.message.processor.MessageProcessorChain.process(MessageProcessorChain.java:60)
>
> at
> org.apache.stratos.messaging.message.receiver.topology.TopologyEventMessageDelegator.run(TopologyEventMessageDelegator.java:73)
>
> at java.lang.Thread.run(Thread.java:695)
>
> [2014-11-16 17:04:33,059] ERROR
> {org.apache.stratos.messaging.message.receiver.topology.TopologyEventMessageDelegator}
> -  Failed to retrieve topology event message
>
> java.lang.RuntimeException: Failed to process message using available
> message processors: [type] org.apache.stratos.messaging.event.topology.#
> [body] {"topology":{"serviceMap":{},"initialized":false}}
>
> at
> org.apache.stratos.messaging.message.processor.topology.MemberTerminatedMessageProcessor.process(MemberTerminatedMessageProcessor.java:70)
>
> at
> org.apache.stratos.messaging.message.processor.topology.MemberSuspendedMessageProcessor.process(MemberSuspendedMessageProcessor.java:69)
>
> at
> org.apache.stratos.messaging.message.processor.topology.MemberMaintenanceModeProcessor.process(MemberMaintenanceModeProcessor.java:66)
>
> at
> org.apache.stratos.messaging.message.processor.topology.MemberReadyToShutdownMessageProcessor.process(MemberReadyToShutdownMessageProcessor.java:65)
>
> at
> org.apache.stratos.messaging.message.processor.topology.MemberActivatedMessageProcessor.process(MemberActivatedMessageProcessor.java:69)
>
> at
> org.apache.stratos.messaging.message.processor.topology.MemberStartedMessageProcessor.process(MemberStartedMessageProcessor.java:69)
>
> at
> org.apache.stratos.messaging.message.processor.topology.InstanceSpawnedMessageProcessor.process(InstanceSpawnedMessageProcessor.java:65)
>
> at
> org.apache.stratos.messaging.message.processor.topology.ClusterTerminatingProcessor.process(ClusterTerminatingProcessor.java:72)
>
> at
> org.apache.stratos.messaging.message.processor.topology.ClusterResetMessageProcessor.process(ClusterResetMessageProcessor.java:71)
>
> at
> org.apache.stratos.messaging.message.processor.topology.ClusterTerminatedProcessor.process(ClusterTerminatedProcessor.java:72)
>
> at
> org.apache.stratos.messaging.message.processor.topology.ClusterRemovedMessageProcessor.process(ClusterRemovedMessageProcessor.java:65)
>
> at
> org.apache.stratos.messaging.message.processor.topology.ClusterInActivateProcessor.process(ClusterInActivateProcessor.java:72)
>
> at
> org.apache.stratos.messaging.message.processor.topology.ClusterActivatedProcessor.process(ClusterActivatedProcessor.java:72)
>
> at
> org.apache.stratos.messaging.message.processor.topology.ClusterCreatedMessageProcessor.process(ClusterCreatedMessageProcessor.java:65)
>
> at
> org.apache.stratos.messaging.message.processor.topology.ApplicationClustersRemovedMessageProcessor.process(ApplicationClustersRemovedMessageProcessor.java:63)
>
> at
> org.apache.stratos.messaging.message.processor.topology.ApplicationClustersCreatedMessageProcessor.process(ApplicationClustersCreatedMessageProcessor.java:67)
>
> at
> org.apache.stratos.messaging.message.processor.topology.ServiceRemovedMessageProcessor.process(ServiceRemovedMessageProcessor.java:64)
>
> at
> org.apache.stratos.messaging.message.processor.topology.ServiceCreatedMessageProcessor.process(ServiceCreatedMessageProcessor.java:65)
>
> at
> org.apache.stratos.messaging.message.processor.topology.CompleteTopologyMessageProcessor.process(CompleteTopologyMessageProcessor.java:75)
>
> at
> org.apache.stratos.messaging.message.processor.MessageProcessorChain.process(MessageProcessorChain.java:60)
>
> at
> org.apache.stratos.messaging.message.receiver.topology.TopologyEventMessageDelegator.run(TopologyEventMessageDelegator.java:73)
>
> at java.lang.Thread.run(Thread.java:695)
>
> [2014-11-16 17:04:50,815] ERROR
> {org.apache.stratos.messaging.message.receiver.applications.ApplicationsEventMessageDelegator}
> -  Failed to retrieve application status event message
>
> java.lang.RuntimeException: Failed to process message using available
> message processors: [type]
> org.apache.stratos.messaging.event.applications.# [body]
> {"applications":{"applicationMap":{},"initialized":false}}
>
> at
> org.apache.stratos.messaging.message.processor.applications.ApplicationTerminatedMessageProcessor.process(ApplicationTerminatedMessageProcessor.java:76)
>
> at
> org.apache.stratos.messaging.message.processor.applications.CompleteApplicationsMessageProcessor.process(CompleteApplicationsMessageProcessor.java:69)
>
> at
> org.apache.stratos.messaging.message.processor.applications.ApplicationTerminatingMessageProcessor.process(ApplicationTerminatingMessageProcessor.java:72)
>
> at
> org.apache.stratos.messaging.message.processor.applications.ApplicationInactivatedMessageProcessor.process(ApplicationInactivatedMessageProcessor.java:72)
>
> at
> org.apache.stratos.messaging.message.processor.applications.ApplicationCreatedMessageProcessor.process(ApplicationCreatedMessageProcessor.java:67)
>
> at
> org.apache.stratos.messaging.message.processor.applications.ApplicationActivatedMessageProcessor.process(ApplicationActivatedMessageProcessor.java:72)
>
> at
> org.apache.stratos.messaging.message.processor.applications.GroupTerminatingProcessor.process(GroupTerminatingProcessor.java:69)
>
> at
> org.apache.stratos.messaging.message.processor.applications.GroupTerminatedProcessor.process(GroupTerminatedProcessor.java:69)
>
> at
> org.apache.stratos.messaging.message.processor.applications.GroupInActivateProcessor.process(GroupInActivateProcessor.java:69)
>
> at
> org.apache.stratos.messaging.message.processor.applications.GroupActivatedProcessor.process(GroupActivatedProcessor.java:69)
>
> at
> org.apache.stratos.messaging.message.processor.applications.GroupResetProcessor.process(GroupResetProcessor.java:69)
>
> at
> org.apache.stratos.messaging.message.processor.MessageProcessorChain.process(MessageProcessorChain.java:60)
>
> at
> org.apache.stratos.messaging.message.receiver.applications.ApplicationsEventMessageDelegator.run(ApplicationsEventMessageDelegator.java:70)
>
> at java.lang.Thread.run(Thread.java:695)
>
> [2014-11-16 17:05:22,147] ERROR
> {org.apache.stratos.messaging.message.receiver.applications.ApplicationsEventMessageDelegator}
> -  Failed to retrieve application status event message
>
>
> On Sat, Nov 15, 2014 at 11:50 AM, Imesh Gunaratne <imesh@apache.org>
> wrote:
>
>> Hi Devs,
>>
>> I have now done following improvements in the messaging components:
>>
>> Message Listeners are Directly Coupled with MQTT Library and Using
>> ActiveMQ TextMessage as the Message domain class
>> https://issues.apache.org/jira/browse/STRATOS-967
>>
>> Introduce an Abstraction between the Message Broker Transport and
>> Messaging Component Implementation
>> https://issues.apache.org/jira/browse/STRATOS-968
>>
>> Thanks
>>
>>
>>
>>
>> --
>> Imesh Gunaratne
>>
>> Technical Lead, WSO2
>> Committer & PMC Member, Apache Stratos
>>
>
>
>
> --
> Reka Thirunavukkarasu
> Senior Software Engineer,
> WSO2, Inc.:http://wso2.com,
> Mobile: +94776442007
>
> --
> Thanks and Regards,
>
> Isuru H.
> +94 716 358 048* <http://wso2.com/>*
>
>
> * <http://wso2.com/>*
>
>
>

Mime
View raw message