Thanks Isuru for fixing it.. On Sun, Nov 16, 2014 at 8:16 PM, Isuru Haththotuwa <[email protected]> wrote:
> 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 <[email protected]> > 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 <[email protected]> >> 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 >> >> -- >> <%2B94776442007> >> <%2B94776442007> >> Thanks and Regards, >> >> Isuru H. >> <%2B94776442007> >> +94 716 358 048 <%2B94776442007>* <http://wso2.com/>* >> >> >> * <http://wso2.com/>* >> >> >> -- Reka Thirunavukkarasu Senior Software Engineer, WSO2, Inc.:http://wso2.com, Mobile: +94776442007
