org.xmlBlaster.util.RequestResponseDispatcher=function(){this.requestMap=new Object();this.requestIdCounter=1;this.getRequestIdNextVal=function(){return this.requestIdCounter++;},this.onResponseOrException=function(bounceId,dataReceived){var requestInfo=this.requestMap[bounceId];if(typeof requestInfo==undefined||requestInfo==null){return false;}
var deleteEntry=true;if(dataReceived!=null){if(requestInfo.timeoutId!=null)
clearTimeout(requestInfo.timeoutId);if(requestInfo.timeoutSec==org.xmlBlaster.util.RequestResponseDispatcher.FOREVER_MULTIPLE_SHOTS)
deleteEntry=false;}
if(deleteEntry)
delete this.requestMap[bounceId];if(requestInfo.responseFp!=null){requestInfo.responseFp.call(requestInfo.responseThisArg,dataReceived,requestInfo.returnObj,requestInfo);return true;}
return false;}
this.requestTimedout=function(bounceId){this.onResponseOrException(bounceId,null);}
this.registerRequest=function(bounceId_,timeoutSec_,responseFp_,responseThisArg,returnObj,silentlyDiscardOldIdentical){var bounceId=bounceId_||"";var silentlyDiscardOldIdentical=(silentlyDiscardOldIdentical===undefined)?false:silentlyDiscardOldIdentical;var timeoutSec=20;if(typeof timeoutSec_!=undefined)
timeoutSec=timeoutSec_;var responseFp=responseFp_||null;var currDispatcher=this;if(typeof returnObj==undefined)
returnObj=null;var timeoutId=null;if(timeoutSec>0){var timeoutMillis=timeoutSec*1000;timeoutId=setTimeout(function(){currDispatcher.requestTimedout(bounceId);},timeoutMillis);}
var requestInfo={bounceId:bounceId,timeoutSec:timeoutSec,timeoutId:timeoutId,responseFp:responseFp,responseThisArg:responseThisArg,returnObj:returnObj}
var isNew=this.requestMap[bounceId]===undefined;if(!isNew){if(silentlyDiscardOldIdentical){this.unregisterRequest(bounceId);}
else{throw"IllegalArgumentException: Multiple registration! org.xmlBlaster.util.RequestResponseDispatcher.registerRequest("
+bounceId+", "+timeoutSec+", "+responseFp+", "
+responseThisArg+", "+returnObj+")";}}
this.requestMap[bounceId]=requestInfo;}
this.unregisterRequest=function(bounceId){if(bounceId===undefined)
return null;requestInfo=this.requestMap[bounceId];if(requestInfo===undefined)
return null;if(requestInfo!=null&&requestInfo.timeoutId!=null)
clearTimeout(requestInfo.timeoutId);delete this.requestMap[bounceId];return requestInfo;}
this.size=function(){var count=0;for(var key in this.requestMap){count++;}
return count;}
this.clear=function(){for(var key in this.requestMap){var requestInfo=this.requestMap[key];var timeoutId=requestInfo.timeoutId;if(timeoutId!=null)
clearTimeout(timeoutId);delete this.requestMap[key];}}}
org.xmlBlaster.util.RequestResponseDispatcher.FOREVER_ONE_SHOT=0;org.xmlBlaster.util.RequestResponseDispatcher.FOREVER_MULTIPLE_SHOTS=-1;