MerchantStoreService

package com.apama.card.offers;

monitor MerchantStoreService {
	
	dictionary<string, sequence<MerchantStore> > merchantstores;
	
	action onload() {
		
		MerchantStore ms;
		on all MerchantStore():ms {
			if not merchantstores.hasKey(ms.merchantname) then {
				merchantstores.add(ms.merchantname, new sequence<MerchantStore>);				
			}
			merchantstores[ms.merchantname].append(ms); 			               
		}
		
		LookupMerchants lm;
		on all LookupMerchants():lm {
			if merchantstores.hasKey(lm.merchantname) then {
				MerchantStore ms := new MerchantStore;
				for ms in merchantstores[lm.merchantname] {
					if ms.locality = lm.locality then {
						MerchantLookupResults lr := new MerchantLookupResults;
						lr.correlationid := lm.correlationid;
						lr.ms := ms;
						log lr.toString();
						route lr;
					}
				}
			}
		}
		
	}
	
}