<node name="sendQueue">

<attribute name="queue" value="[]" />

<attribute name="workingitem" />

<attribute name="lock" value="true"/>

<remotecall name="remote" funcname="action" remotecontext="$once{canvas.eventrpc}" />

<method name="enqueue" args="para">

<![CDATA[

this.lock=true;

var inserted=false;

for(var k=0;k<queue.length;k++){

if (queue[k].action==para.action

&& queue[k].event.uuid==para.event.uuid){

queue.splice(k, 1, para);

inserted=true;

debug.write("spliced!");

break;

}

}

if (!inserted)

queue.push(para);

this.lock=false;

debug.write("enqueued", queue);

]]>

</method>

<method event="oninit">

if(!this['del'])

this.del = new LzDelegate(this, "work");

</method>

<method name="work">

if (this.lock || !queue.length){

nextQueue();

return;

}

workingitem = queue.shift();

debug.write("remotecall",workingitem);

this.remote.invoke(Array(workingitem));

</method>

<method name="nextQueue" event="ondata" reference="remote">

LzTimer.addTimer(this.del, 3000);

</method>

<method name="retry" event="onerror" reference="remote"

args="err">

debug.write("unshifting cause",err);

queue.unshift(workingitem);

workingitem=null;

LzTimer.addTimer(this.del, 10000);

</method>

</node>

<node name="receiveQueue">

<remotecall name="remote" funcname="getEvents" remotecontext="$once{canvas.eventrpc}">

<method event="ondata" args="d">

debug.write("do merge!"); //TODO add merge method

parent.plan();

</method>

</remotecall>

<method name="getParam">

return {year:2005, month:10}; //TODO build query args

</method>

<method event="oninit">

if(!this['del'])

this.del = new LzDelegate(this, "work");

</method>

<method name="work">

this.remote.invoke(Array(getParam()));

</method>

<method name="plan">

LzTimer.addTimer(this.del, 500000);

</method>

</node>