You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@stratos.apache.org by Imesh Gunaratne <im...@apache.org> on 2014/11/15 07:20:57 UTC
[Discuss] Messaging Component Improvements
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
Re: [Discuss] Messaging Component Improvements
Posted by Imesh Gunaratne <im...@apache.org>.
Really sorry Reka, I just saw the mail. Thanks Isuru for the fix.
On Sun, Nov 16, 2014 at 10:12 PM, Reka Thirunavukkarasu <re...@wso2.com>
wrote:
> Thanks Isuru for fixing it..
>
> On Sun, Nov 16, 2014 at 8:16 PM, Isuru Haththotuwa <is...@apache.org>
> 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 <re...@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 <im...@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
>>>
>>> --
>>> <%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
Re: [Discuss] Messaging Component Improvements
Posted by Reka Thirunavukkarasu <re...@wso2.com>.
Thanks Isuru for fixing it..
On Sun, Nov 16, 2014 at 8:16 PM, Isuru Haththotuwa <is...@apache.org>
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 <re...@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 <im...@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
>>
>> --
>> <%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
Re: [Discuss] Messaging Component Improvements
Posted by Isuru Haththotuwa <is...@apache.org>.
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 <re...@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 <im...@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/>*
>
>
>
Re: [Discuss] Messaging Component Improvements
Posted by Reka Thirunavukkarasu <re...@wso2.com>.
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 <im...@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