+ for(var key in newTopics){
+ if(!oldTopics[key]) {
+ this._addAmqListener(key);
+ }
+ }
+ },
+
+ _feedSelector : function(changeTopicsEvent){
+ var topics = changeTopicsEvent.getData();
+ this.agentSelector.removeAll();
+ var emptyItem = new qx.ui.form.ListItem("", null, "");
+ this.agentSelector.add(emptyItem);
+ this.agentSelector.setSelected(emptyItem);
+ for(var key in topics){
+ var listItem = new qx.ui.form.ListItem(topics[key], null, key);
+ this.agentSelector.add(listItem);
+ }
+ },
+
+ _addAmqListener: function(uuid){
+ this._amqClient.addListener("slcExec", "topic://agent."+uuid+".newExecution", function(response){
+ var message = org.argeo.ria.util.Element.selectSingleNode(response, "slc:slc-execution");
+ var slcExec = new org.argeo.slc.ria.SlcExecutionMessage(message.getAttribute("uuid"));
+ slcExec.fromXml(message);
+ this.logModel.addRows([
+ [new Date().toString(), slcExec.getHost()+' ('+slcExec.getUuid()+')', slcExec.getStatus()]
+ ]);
+ }, this);