{"version":3,"file":"ServiceBus.cjs","mappings":";;;;;;;;;;;;;;;AASA;AAAqD;AAAA;;AAErD,SAASA,UAAU,CAACC,GAAW;EAC7B,qDAAOC,kGAAO,MAAM,IAAIC,4BAAgB,CAACF,GAAG,CAAC,CAAC,GAC5CG,MAAM,IAAGC,8CAACH,wBAAe,MAAME,MAAM,CAACE,KAAK,EAAE,CAAC,EAC/C;AACH;AAEA,MAAMC,MAAM,GAAGC,mBAAG,EAAoB;AAC/B,MAAMC,oBAAoB,GAAIR,GAAW,IAAKS,uBAA8BH,MAAM,EAApCP,UAAU,CAACC,GAAG,CAAC,CAAsB;AAAA;AAE1F,SAASU,UAAU,CAACC,SAAiB;EACnC,qDAAOV,oBAAW,WAAUW,CAAC;IAC3B,MAAMC,gBAAgB,GAAG,OAAOD,CAAC,yBAACN,MAAM,EAAQ;IAEhD,OAAO,OAAOM,CAAC,+CACbX,iGAAO,MAAMY,gBAAgB,CAACC,YAAY,CAACH,SAAS,CAAC,CAAC,GACpDI,YAAY,IAAGX,8CAACH,wBAAe,MAAMc,YAAY,CAACV,KAAK,EAAE,CAAC,EAC3D,EACF;EACH,CAAC,CAAC;AACJ;AACO,MAAMW,MAAM,GAAGT,mBAAG,EAAoB;AAAA;AAEvC,SAAUU,UAAU,CAACN,SAAiB;EAC1C,OAAOF,uBAAoCO,MAAM,EAA1CN,UAAU,CAACC,SAAS,CAAC,CAAsB;AACpD;AAEA,SAASO,YAAY,CAACP,SAAiB;EACrC,qDAAOV,oBAAW,WAAUW,CAAC;IAC3B,MAAMC,gBAAgB,GAAG,OAAOD,CAAC,yBAACN,MAAM,EAAQ;IAEhD,OAAO,OAAOM,CAAC,+CACbX,iGAAO,MAAMY,gBAAgB,CAACM,cAAc,CAACR,SAAS,CAAC,CAAC,GACtDS,CAAC,IAAGhB,8CAACH,wBAAe,MAAMmB,CAAC,CAACf,KAAK,EAAE,CAAC,EACrC,EACF;EACH,CAAC,CAAC;AACJ;AAEO,MAAMgB,QAAQ,GAAGd,mBAAG,EAAsB;AAAA;AAC3C,SAAUe,YAAY,CAACX,SAAiB;EAC5C,OAAOF,uBAAsCY,QAAQ,EAA9CH,YAAY,CAACP,SAAS,CAAC,CAAwB;AACxD;AAEM,SAAUY,YAAY,CAC1BC,QAA0E,EAC1EC,OAA8B;EAE9B,qDAAOxB,oBAAW,WAAUW,CAAC;IAC3B,MAAMc,CAAC,GAAG,OAAOd,CAAC,yBAACI,MAAM,EAAQ;IACjC,OAAO,OAAOJ,CAAC,+CAACX,wBAAe,MAAMyB,CAAC,CAACH,YAAY,CAACC,QAAQ,EAAEC,OAAO,CAAC,CAAC,EAAC;EAC1E,CAAC,CAAC;AACJ;AAEM,SAAUE,SAAS,CAAaC,KAAkC;EACtE,qDAAO3B,oBAAW,WAAUW,CAAC;IAC3B,MAAMQ,CAAC,GAAG,OAAOR,CAAC,yBAACS,QAAQ,EAAQ;IAEnC,MAAMQ,GAAG,GAAG,OAAOjB,CAAC,+CAACX,6BAAiC,EAAC;IAEvD,OAAOW,CAAC,8CACNX,iGAAO,MACLmB,CAAC,CAACO,SAAS,CAAC;MACVG,YAAY,EAAEC,GAAG,IACf9B,kHACsB4B,GAAG,GADzBD,KAAK,CAACE,YAAY,CAACC,GAAG,CAAC,CACG,EAEvBC,KAAK,CAACC,OAAO,CAACC,KAAK,CAAC;MACzBC,cAAc,EAAEC,GAAG,IAAGnC,iCACpBG,iFACsByB,GAAG,GADzBD,KAAK,CAACO,cAAc,CAACC,GAAG,CAAC,CACC;MAE5B;KACD,CAAC,CACH,GACCrB,YAAY,IAAGX,8CAACH,wBAAe,MAAMc,YAAY,CAACV,KAAK,EAAE,CAAC,EAC3D,EACF;EACH,CAAC,CAAC;AACJ;AAEA,MAAMgC,YAAY,GAAG9B,mBAAG,EAAgD;AAElE,SAAU+B,YAAY,CAAaV,KAAkC;EACzE,OAAOnB,uBAA+B4B,YAAY,EAA3CV,SAAS,CAACC,KAAK,CAAC,CAA4B;AACrD","names":["makeClient","url","tsplus_module_1","ServiceBusClient","client","tracer_1","close","Client","tsplus_module_2","LiveServiceBusClient","tsplus_module_3","makeSender","queueName","$","serviceBusClient","createSender","subscription","Sender","LiveSender","makeReceiver","createReceiver","r","Receiver","LiveReceiver","sendMessages","messages","options","s","subscribe","hndlr","env","processError","err","catch","console","error","processMessage","msg","SubscribeTag","Subscription"],"sourceRoot":"","sources":["../../_src/services/ServiceBus.ts"],"sourcesContent":[null]}