Really sorry Reka, I just saw the mail. Thanks Isuru for the fix. On Sun, Nov 16, 2014 at 10:12 PM, Reka Thirunavukkarasu <[email protected]> wrote:
> 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 > > > -- Imesh Gunaratne Technical Lead, WSO2 Committer & PMC Member, Apache Stratos
