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 > > -- > Thanks and Regards, > > Isuru H. > +94 716 358 048* <http://wso2.com/>* > > > * <http://wso2.com/>* > > >
