monitor service_monitor {
action onload() {
on all Subscribe() as s {
if not connected {
pendingSubscribes.append(s);
} else {
if(incrRefCount(s.subkey) {
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;
l:=on all Data() as d { process(d); }
}
action onConcludeRecovery() {
// Non-persistent service monitor is now reset to its onload state.
// Re-subscribe.
send Subscribe(i.subkey) to svcCtx;
}
}