monitor service_monitor {
action onload() {
Subscribe s;
on all Subscribe():s {
if not connected then {
pendingSubscribes.append(s);
} else {
if(incrRefCount(s.subkey) then {
send Adapter_Subscribe(s.subkey) to "output";
}
}
}
on all wait(1.0) {
send IsAdapterUp() to "output";
}
on all AdapterUp() {
connected:=true;
for s in pendingSubsscribes {
route s;
}
pendingSubscribes.clear();
}
}
}

persistent monitor eg2 {
listener l;
Instance i;
context svcCtx;
action spawnedInstance(context c) {
svcCtx:=c; // Contains anything required to recover subscription.
send Subscribe(i.subkey) to svcCtx;
Data d;
l:=on all Data():d { process(d); }
}
action onConcludeRecovery() {
// Non-persistent service monitor is now reset to its onload state.
// Re-subscribe.
send Subscribe(i.subkey) to svcCtx;
}
}