Re: Getting the service name a particular memberId belongs to in Topology

2014-11-14 Thread Udara Liyanage
Hi Chamila, Topology is structured in Service - > Cluster -> Member way. That is why it has to iterate services in order to get members. On Sat, Nov 15, 2014 at 11:57 AM, Imesh Gunaratne wrote: > We could introduce a map to handle this. > > On Fri, Nov 14, 2014 at 11:45 PM, Chamila De Alwis >

Re: [Messaging] Refactoring the Event Listeners

2014-11-14 Thread Udara Liyanage
Hi, While going through the code I tried to understand what the threads are doing, StratosManagerTopologyEventReceiver creates TopologyEventReceiver and add event listerns - Not an iterative process. See the run method just keep on sleeping while terminates become true TopologyEventReceiver cre

Re: Un-subscribe cartridge takes 60+ sec

2014-11-14 Thread Imesh Gunaratne
Hi Jeffrey, Seems like mqtt-client 1.0.0 maven artifact is not still published: https://repo.eclipse.org/content/repositories/paho-releases/org/eclipse/paho/mqtt-client/ Thanks On Sat, Nov 15, 2014 at 12:36 AM, Jeffrey Nguyen (jeffrngu) < jeffr...@cisco.com> wrote: > > Thanks Udara and Isuru f

Re: Getting the service name a particular memberId belongs to in Topology

2014-11-14 Thread Imesh Gunaratne
We could introduce a map to handle this. On Fri, Nov 14, 2014 at 11:45 PM, Chamila De Alwis wrote: > Hi, > > Is there a direct way of doing $subject other than iterating through all > the services from topology.getServices()? > > Service memberService = null; > for (Service service: topology.get

Re: Reduce the Cartridge agent waiting time for the Complete Topology

2014-11-14 Thread Imesh Gunaratne
Yes exactly, the complete topology event publisher might need to wait for certain time period (may be few seconds) for complete topology request messages before publishing. Otherwise it may publish the same message number of times unnecessarily. On Fri, Nov 14, 2014 at 11:37 PM, Udara Liyanage wr

[Discuss] Messaging Component Improvements

2014-11-14 Thread Imesh Gunaratne
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 T

[jira] [Updated] (STRATOS-967) Message Listeners are Directly Coupled with MQTT Library and Using ActiveMQ TextMessage as the Message domain class

2014-11-14 Thread Imesh Gunaratne (JIRA)
[ https://issues.apache.org/jira/browse/STRATOS-967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Imesh Gunaratne updated STRATOS-967: Summary: Message Listeners are Directly Coupled with MQTT Library and Using ActiveMQ TextMe

[jira] [Resolved] (STRATOS-968) Introduce an Abstraction between Message Broker Transport and Messaging Component Implementation

2014-11-14 Thread Imesh Gunaratne (JIRA)
[ https://issues.apache.org/jira/browse/STRATOS-968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Imesh Gunaratne resolved STRATOS-968. - Resolution: Fixed > Introduce an Abstraction between Message Broker Transport and Messagi

[jira] [Commented] (STRATOS-968) Introduce an Abstraction between Message Broker Transport and Messaging Component Implementation

2014-11-14 Thread Imesh Gunaratne (JIRA)
[ https://issues.apache.org/jira/browse/STRATOS-968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14213405#comment-14213405 ] Imesh Gunaratne commented on STRATOS-968: - Fixed with commit revision: 87ab43d0bf

[jira] [Updated] (STRATOS-968) Introduce an Abstraction between Message Broker Transport and Messaging Component Implementation

2014-11-14 Thread Imesh Gunaratne (JIRA)
[ https://issues.apache.org/jira/browse/STRATOS-968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Imesh Gunaratne updated STRATOS-968: Fix Version/s: 4.1.0 M5 > Introduce an Abstraction between Message Broker Transport and Mes

[jira] [Updated] (STRATOS-968) Introduce an Abstraction between Message Broker Transport and Messaging Component Implementation

2014-11-14 Thread Imesh Gunaratne (JIRA)
[ https://issues.apache.org/jira/browse/STRATOS-968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Imesh Gunaratne updated STRATOS-968: Description: Currently in the messaging component there is no abstraction found between the

[jira] [Created] (STRATOS-968) Introduce an Abstraction between Message Broker Transport and Messaging Component Implementation

2014-11-14 Thread Imesh Gunaratne (JIRA)
Imesh Gunaratne created STRATOS-968: --- Summary: Introduce an Abstraction between Message Broker Transport and Messaging Component Implementation Key: STRATOS-968 URL: https://issues.apache.org/jira/browse/STRATOS

[jira] [Resolved] (STRATOS-967) Message Listeners are Directly Coupled with MQTT Library

2014-11-14 Thread Imesh Gunaratne (JIRA)
[ https://issues.apache.org/jira/browse/STRATOS-967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Imesh Gunaratne resolved STRATOS-967. - Resolution: Fixed Fixed with commit revision: 87ab43d0bf43373d813483494c551e8f69b7a4f8 >

[jira] [Updated] (STRATOS-967) Message Listeners are Directly Coupled with MQTT Library

2014-11-14 Thread Imesh Gunaratne (JIRA)
[ https://issues.apache.org/jira/browse/STRATOS-967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Imesh Gunaratne updated STRATOS-967: Description: With the introduction of MQTT in the messaging component all the message list

[jira] [Updated] (STRATOS-967) Message Listeners are Directly Coupled with MQTT Library

2014-11-14 Thread Imesh Gunaratne (JIRA)
[ https://issues.apache.org/jira/browse/STRATOS-967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Imesh Gunaratne updated STRATOS-967: Issue Type: Improvement (was: Bug) > Message Listeners are Directly Coupled with MQTT Libr

[jira] [Updated] (STRATOS-967) Message Listeners are Directly Coupled with MQTT Library

2014-11-14 Thread Imesh Gunaratne (JIRA)
[ https://issues.apache.org/jira/browse/STRATOS-967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Imesh Gunaratne updated STRATOS-967: Description: With the introduction of MQTT in the messaging component all the message list

[jira] [Updated] (STRATOS-967) Message Listeners are Directly Coupled with MQTT Library

2014-11-14 Thread Imesh Gunaratne (JIRA)
[ https://issues.apache.org/jira/browse/STRATOS-967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Imesh Gunaratne updated STRATOS-967: Fix Version/s: 4.1.0 M5 > Message Listeners are Directly Coupled with MQTT Library > --

[jira] [Created] (STRATOS-967) Message Listeners are Directly Coupled with MQTT Library

2014-11-14 Thread Imesh Gunaratne (JIRA)
Imesh Gunaratne created STRATOS-967: --- Summary: Message Listeners are Directly Coupled with MQTT Library Key: STRATOS-967 URL: https://issues.apache.org/jira/browse/STRATOS-967 Project: Stratos

Re: Integration Test for Apache Stratos

2014-11-14 Thread Imesh Gunaratne
Thanks for looking into this Vishanth. IMO we should first try to implement something very basic which could do the following: - Have a test configuration file - Get the latest stratos package - Run the stratos installer (this should start a new stratos environment) - Deploy artifacts - At each st

[jira] [Resolved] (STRATOS-966) Inconsistency in parameter definition in REST API coding

2014-11-14 Thread Udara Liyanage (JIRA)
[ https://issues.apache.org/jira/browse/STRATOS-966?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Udara Liyanage resolved STRATOS-966. Resolution: Fixed fixed in 3576551e7f50353b83995085c94eaf178d103bc3 > Inconsistency in par

[Grouping][enhancing event definition] - group definition, groupId - adding group definition, instance Id to instance events

2014-11-14 Thread Martin Eppel (meppel)
In the grouping specification we also discussed adding a group definition and a group id to the instance events (InstanceActivatedEvent, InstanceMaintenanceModeEvent, InstanceReadyToShutdownEvent, InstanceStartedEvent). The group definition would identify something like the group type (=== alia

[jira] [Created] (STRATOS-966) Inconsistency in parameter definition in REST API coding

2014-11-14 Thread Mariangela Hills (JIRA)
Mariangela Hills created STRATOS-966: Summary: Inconsistency in parameter definition in REST API coding Key: STRATOS-966 URL: https://issues.apache.org/jira/browse/STRATOS-966 Project: Stratos

Re: Un-subscribe cartridge takes 60+ sec

2014-11-14 Thread Jeffrey Nguyen (jeffrngu)
Thanks Udara and Isuru for your replies. I like the approach of doing retry with incremental delay Hi Imesh, Please go ahead and implement this fix and also take care of the mqtt-client upgrade. Thanks, -Jeffrey From: Imesh Gunaratne mailto:im...@apache.org>> Reply-To: "dev@stratos.apache.

Re: [Messaging] Refactoring the Event Listeners

2014-11-14 Thread Imesh Gunaratne
Yes, better to do this improvement in all the message broker topic listeners. On Fri, Nov 14, 2014 at 1:36 PM, Chamila De Alwis wrote: > Hi, > > Furthermore, it seems this is a pattern followed all over Stratos, where > each component has a {component}{topic}EventReceiver runnable. Shouldn't we

Re: Un-subscribe cartridge takes 60+ sec

2014-11-14 Thread Imesh Gunaratne
Hi Jeffrey, Thanks for bringing this up. I was thinking about this issue sometime back and thought that may be we could start the retry interval with a small value and then increase it step by step depending on the number of continuous failures. I noticed this approach in Gmail. I can do a quick

Getting the service name a particular memberId belongs to in Topology

2014-11-14 Thread Chamila De Alwis
Hi, Is there a direct way of doing $subject other than iterating through all the services from topology.getServices()? Service memberService = null; for (Service service: topology.getServices()){ Cluster cluster = service.getCluster(clusterId); if (cluster != null) { if (cluster.g

Re: Reduce the Cartridge agent waiting time for the Complete Topology

2014-11-14 Thread Udara Liyanage
Hi, When a message is sent it is received by all subscribers. So we don't need to send multiple times for multiple requests, isn't it Imesh? Touched, not typed. Erroneous words are a feature, not a typo. On Nov 14, 2014 11:15 PM, "Imesh Gunaratne" wrote: > Hi Reka, > > On Fri, Nov 14, 2014 at

Re: Reduce the Cartridge agent waiting time for the Complete Topology

2014-11-14 Thread Imesh Gunaratne
Hi Reka, On Fri, Nov 14, 2014 at 11:56 AM, Reka Thirunavukkarasu wrote: Since we have CA also listening to Topology now, CA is taking ~1 minute to receive the complete Topology as we send the Complete Topology in every 1 min. Can we reduce this by introducing a new topic where CA can publish an

Re: Assigning floating IPs to any interfaces of our choice

2014-11-14 Thread Rajkumar Rajaratnam
Update; On Fri, Nov 14, 2014 at 3:44 PM, Rajkumar Rajaratnam wrote: > Update; > > Currently facing an issue with upstream openstack-neutron-1.8.1.jar. > > When I see the MANIFEST.MF file of openstack-neutron-1.8.1.jar, it > contains ${jclouds.version} in lot of places instead of actual version.

Re: Integration Test for Apache Stratos

2014-11-14 Thread Chamila De Alwis
Hi Vishanth, On Fri, Nov 14, 2014 at 5:25 PM, Vishanth Balasubramaniam < vishan...@wso2.com> wrote: > A remote Openstack or EC2 instance will be used as the environment for the > setup. > Can containers be also included, at a later stage if not possible initially? For common scenarios I think th

Re: Integration Test for Apache Stratos

2014-11-14 Thread Udara Liyanage
Hi Vishanth, Please send a PR by adding your scripts under /tools then others also can have a look. On Fri, Nov 14, 2014 at 5:38 PM, Vishanth Balasubramaniam < vishan...@wso2.com> wrote: > Hi Udara, > > No I haven't committed the changes to stratos. Currently doing some parts > manually, once th

Re: Integration Test for Apache Stratos

2014-11-14 Thread Vishanth Balasubramaniam
Hi Udara, No I haven't committed the changes to stratos. Currently doing some parts manually, once that is completely I will commit it. And yes I am scp-ing the necessary packs. Then will also look into sending the log file back to the user's machine. Thanks On Fri, Nov 14, 2014 at 5:32 PM, Uda

Re: [Grouping] Issue with dependencies in nested grouping scenario (termination)

2014-11-14 Thread Reka Thirunavukkarasu
Hi Martin, I could get only the simple two dependent clusters working..When i tried with your sample, i got few issues..I'm in the middle of testing the fix to make it working.. I will do more testing on this and update you.. Thanks, Reka On Fri, Nov 14, 2014 at 10:55 AM, Reka Thirunavukkarasu

Re: Integration Test for Apache Stratos

2014-11-14 Thread Udara Liyanage
Hi Vishanth, Have you committed the changes to Stratos? You have to scp cartridge agent and LB also. It is better if the script scp the log file back into the user's machine when the test is complete. On Fri, Nov 14, 2014 at 5:25 PM, Vishanth Balasubramaniam < vishan...@wso2.com> wrote: > Hi De

Integration Test for Apache Stratos

2014-11-14 Thread Vishanth Balasubramaniam
Hi Devs, Currently I am working on writing a script that will be used for an end to end testing where the devs can use this script to do an integration test after a build. Here I will provide the updates and progress on the work and expect suggestions and feedback. To give an overview, the basic

[jira] [Updated] (STRATOS-965) Application can not be undeployed when moniter creation is failed

2014-11-14 Thread Isuru Haththotuwa (JIRA)
[ https://issues.apache.org/jira/browse/STRATOS-965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Isuru Haththotuwa updated STRATOS-965: -- Fix Version/s: (was: 4.1.0) 4.1.0 Alpha > Application can not be

[jira] [Assigned] (STRATOS-965) Application can not be undeployed when moniter creation is failed

2014-11-14 Thread Isuru Haththotuwa (JIRA)
[ https://issues.apache.org/jira/browse/STRATOS-965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Isuru Haththotuwa reassigned STRATOS-965: - Assignee: Isuru Haththotuwa > Application can not be undeployed when moniter cre

[jira] [Commented] (STRATOS-965) Application can not be undeployed when moniter creation is failed

2014-11-14 Thread Isuru Haththotuwa (JIRA)
[ https://issues.apache.org/jira/browse/STRATOS-965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14212137#comment-14212137 ] Isuru Haththotuwa commented on STRATOS-965: --- Fixed in commit d1897ebd5634276104

[jira] [Updated] (STRATOS-965) Application can not be undeployed when moniter creation is failed

2014-11-14 Thread Isuru Haththotuwa (JIRA)
[ https://issues.apache.org/jira/browse/STRATOS-965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Isuru Haththotuwa updated STRATOS-965: -- Fix Version/s: 4.1.0 > Application can not be undeployed when moniter creation is faile

Re: Assigning floating IPs to any interfaces of our choice

2014-11-14 Thread Rajkumar Rajaratnam
Update; Currently facing an issue with upstream openstack-neutron-1.8.1.jar. When I see the MANIFEST.MF file of openstack-neutron-1.8.1.jar, it contains ${jclouds.version} in lot of places instead of actual version. Due to this carbon feature installation is failing. Because it is processing MANI

Re: [Messaging] Refactoring the Event Listeners

2014-11-14 Thread Chamila De Alwis
Hi, Furthermore, it seems this is a pattern followed all over Stratos, where each component has a {component}{topic}EventReceiver runnable. Shouldn't we consider them too? If we do, then this will be a major test task. Regards, Chamila de Alwis Software Engineer | WSO2 | +94772207163 Blog: code.