Built motion from commit 87cd5f02.|2.5.48
[motion2.git] / server / services / routing / server / applications / queue.js
index 451e6d1..303209b 100644 (file)
@@ -15,4 +15,4 @@
 // * treaties. The SOFTWARE PRODUCT is licensed, not sold.                        *
 // *                                                                       *
 // *************************************************************************
-var _0x9957=['seq-queue','ioredis','../../../../config/environment','../../../../config/logger','routing','redis','defaults','localhost','socket.io-emitter','account','queue','joinAt','emit','clone','queue_id','pick','format','%sQueuesWaitingInteractions','%s:queue:%s','%s_queue_waiting_interaction:%s','save','../../rpc/mailQueueReport','../../rpc/chatQueueReport','../../rpc/smsQueueReport','../../rpc/faxQueueReport','../../rpc/whatsappQueueReport','string','timeout\x20is\x20a\x20number','from','YYYY-MM-DD\x20HH:mm:ss','contact','list','upperFirst','channel','QueueId','InteractionId','interaction','MessageId','message','chat','WebsiteId','info','name','QueueReport','create','catch','error','waiting','accepted','body','[%s][END:QUEUE][NAME:%s]','update','update\x20queue\x20report','toLowerCase','length','[%s][QUEUE]\x20%s','join','stop','find','Queues','timeout','atimeout','end','[%s][QUEUE]\x20ROUTING\x20STOPPED','close','rules','[%s][QUEUE]\x20APPLICATION\x20END','strategy','rrmemory','beepall','[%s][QUEUE]\x20queue\x20not\x20found\x20%s','log','validate','lodash','util'];(function(_0x403890,_0x584019){var _0x980b30=function(_0x23a7af){while(--_0x23a7af){_0x403890['push'](_0x403890['shift']());}};_0x980b30(++_0x584019);}(_0x9957,0x93));var _0x7995=function(_0x6131cd,_0x4c26a1){_0x6131cd=_0x6131cd-0x0;var _0x47e916=_0x9957[_0x6131cd];return _0x47e916;};'use strict';var schema=require(_0x7995('0x0'));var _=require(_0x7995('0x1'));var util=require(_0x7995('0x2'));var seqqueue=require(_0x7995('0x3'));var moment=require('moment');var Redis=require(_0x7995('0x4'));var config=require(_0x7995('0x5'));var logger=require(_0x7995('0x6'))(_0x7995('0x7'));var strategy=require('./strategy');config[_0x7995('0x8')]=_[_0x7995('0x9')](config[_0x7995('0x8')],{'host':_0x7995('0xa'),'port':0x18eb});var io=require(_0x7995('0xb'))(new Redis(config[_0x7995('0x8')]));var attributes=['id','queue_id',_0x7995('0xc'),_0x7995('0xd'),'from',_0x7995('0xe')];function emit(_0x3116fb,_0x18c8a3,_0x35b5fe){io['to'](_0x3116fb)[_0x7995('0xf')](_0x18c8a3,_0x35b5fe);}function emitChannelQueueInteraction(_0x1e400a,_0x341672,_0x524f7b,_0x245143,_0x41c652,_0x581f22,_0xb0c872,_0x2cb37a){var _0x19a27e=_[_0x7995('0x10')](_0x524f7b);_0x19a27e[_0x7995('0x11')]=_0x2cb37a;_0x19a27e[_0x7995('0xd')]=_0x341672;_0x19a27e[_0x7995('0xc')]=_0x245143;_0x19a27e['id']=_0x41c652;if(_0x581f22){_0xb0c872[util['format']('%sQueuesWaitingInteractions',_0x1e400a)][_0x41c652]=_[_0x7995('0x12')](_0x19a27e,attributes);}else{delete _0xb0c872[util[_0x7995('0x13')](_0x7995('0x14'),_0x1e400a)][_0x41c652];}emit(util[_0x7995('0x13')](_0x7995('0x15'),_0x1e400a,_0x341672),util[_0x7995('0x13')](_0x7995('0x16'),_0x1e400a,_0x581f22?_0x7995('0x17'):'remove'),_[_0x7995('0x12')](_0x19a27e,attributes));}var rpc={'openchannelQueueReport':require('../../rpc/openchannelQueueReport'),'mailQueueReport':require(_0x7995('0x18')),'chatQueueReport':require(_0x7995('0x19')),'smsQueueReport':require(_0x7995('0x1a')),'faxQueueReport':require(_0x7995('0x1b')),'whatsappQueueReport':require(_0x7995('0x1c'))};var queue=schema({'name':{'type':_0x7995('0x1d'),'required':!![],'message':'name\x20is\x20a\x20string\x20and\x20it\x20is\x20required'},'timeout':{'type':'number','message':_0x7995('0x1e')}});function startRouting(_0x5e6f90,_0x555f74,_0x3ec178,_0x3d463e){if(_0x5e6f90&&_0x555f74&&_0x3ec178){_0x555f74['waiting']+=0x1;var _0x3a9b54={'uniqueid':_0x5e6f90,'from':_0x3ec178['body']?_0x3ec178['body'][_0x7995('0x1f')]:'','joinAt':moment()[_0x7995('0x13')](_0x7995('0x20')),'ContactId':_0x3ec178[_0x7995('0x21')]?_0x3ec178[_0x7995('0x21')]['id']:null,'ListId':_0x3ec178[_0x7995('0x22')]?_0x3ec178['list']['id']:null};_0x3a9b54[_[_0x7995('0x23')](_0x3ec178[_0x7995('0x24')])+_0x7995('0x25')]=_0x555f74['id']||null;_0x3a9b54[_[_0x7995('0x23')](_0x3ec178[_0x7995('0x24')])+_0x7995('0x26')]=_0x3ec178[_0x7995('0x27')]?_0x3ec178[_0x7995('0x27')]['id']:null;_0x3a9b54[_['upperFirst'](_0x3ec178[_0x7995('0x24')])+_0x7995('0x28')]=_0x3ec178[_0x7995('0x29')]?_0x3ec178[_0x7995('0x29')]['id']:null;_0x3a9b54[_[_0x7995('0x23')](_0x3ec178[_0x7995('0x24')])+(_0x3ec178['channel']!==_0x7995('0x2a')?'AccountId':_0x7995('0x2b'))]=_0x3ec178[_0x7995('0xc')]?_0x3ec178[_0x7995('0xc')]['id']:null;logger[_0x7995('0x2c')](util[_0x7995('0x13')]('[%s][START:QUEUE][NAME:%s]',_0x5e6f90,_0x555f74[_0x7995('0x2d')]));emitChannelQueueInteraction(_0x3ec178['channel'],_0x555f74[_0x7995('0x2d')],_0x3a9b54,_0x3ec178[_0x7995('0xc')][_0x7995('0x2d')],_0x3ec178['message']['id'],!![],_0x3d463e,_0x555f74['id']);if(rpc[_0x3ec178['channel']+'QueueReport']){return rpc[_0x3ec178[_0x7995('0x24')]+_0x7995('0x2e')][_0x7995('0x2f')](_0x3a9b54)[_0x7995('0x30')](function(_0x2e3493){logger[_0x7995('0x31')]('create\x20queue\x20report');});}}}function stopRouting(_0x481c74,_0xfa8f15,_0x5524af,_0x553671){if(_0x481c74&&_0xfa8f15){_0xfa8f15[_0x7995('0x32')]-=0x1;var _0x29fac5={'leaveAt':moment()[_0x7995('0x13')](_0x7995('0x20')),'acceptAt':moment()['format'](_0x7995('0x20')),'reason':_0x7995('0x33')};logger['info'](util['format']('[%s][STOP:QUEUE][NAME:%s]',_0x481c74,_0xfa8f15[_0x7995('0x2d')]));emitChannelQueueInteraction(_0x5524af[_0x7995('0x24')],_0xfa8f15['name'],_0x5524af[_0x7995('0x34')],_0x5524af['account'][_0x7995('0x2d')],_0x5524af[_0x7995('0x29')]['id'],![],_0x553671,_0xfa8f15['id']);if(rpc[_0x5524af[_0x7995('0x24')]+'QueueReport']){return rpc[_0x5524af['channel']+_0x7995('0x2e')]['update'](_0x481c74,_0x29fac5)['catch'](function(_0x3e99cd){logger[_0x7995('0x31')]('update\x20queue\x20report');});}}}function endRouting(_0x1baa15,_0x1922b4,_0x2b772f,_0x18667c){if(_0x1baa15&&_0x1922b4){_0x1922b4[_0x7995('0x32')]-=0x1;var _0x53002a={'leaveAt':moment()[_0x7995('0x13')](_0x7995('0x20')),'exitAt':moment()[_0x7995('0x13')](_0x7995('0x20')),'reason':'timeout'};logger[_0x7995('0x2c')](util[_0x7995('0x13')](_0x7995('0x35'),_0x1baa15,_0x1922b4[_0x7995('0x2d')]));emitChannelQueueInteraction(_0x2b772f[_0x7995('0x24')],_0x1922b4[_0x7995('0x2d')],_0x2b772f['body'],_0x2b772f[_0x7995('0xc')][_0x7995('0x2d')],_0x2b772f[_0x7995('0x29')]['id'],![],_0x18667c);if(rpc[_0x2b772f[_0x7995('0x24')]+_0x7995('0x2e')]){return rpc[_0x2b772f[_0x7995('0x24')]+_0x7995('0x2e')][_0x7995('0x36')](_0x1baa15,_0x53002a)[_0x7995('0x30')](function(_0x447981){logger[_0x7995('0x31')](_0x7995('0x37'));});}}}function handleFindQueue(_0x7b4e67){return function(_0x53cda2){return _0x53cda2['name'][_0x7995('0x38')]()===_0x7b4e67[_0x7995('0x38')]();};}exports['consequence']=function(_0x4b0855,_0x3f8522,_0x4a9fef,_0x504a33){return function(_0x23da6b){try{var _0x36e28b={'name':_0x3f8522[0x0],'timeout':_0x3f8522[0x1]};var _0x35c8ff=queue['validate'](_0x36e28b,{'typecast':!![]});if(_0x35c8ff[_0x7995('0x39')]){logger['error'](_0x7995('0x3a'),_0x4b0855,_['map'](_0x35c8ff,'message')[_0x7995('0x3b')](',\x20'));_0x23da6b[_0x7995('0x3c')]();}else{var _0xc04e5=_[_0x7995('0x3d')](_0x4a9fef[_0x504a33['channel']+_0x7995('0x3e')],handleFindQueue(_0x36e28b[_0x7995('0x2d')]));if(_0xc04e5){startRouting(_0x4b0855,_0xc04e5,_0x504a33,_0x4a9fef);var _0x31b347=(_0xc04e5[_0x7995('0x3f')]||0xa)*0x3e8;var _0x4e09b7=(_0x36e28b['timeout']||0x14)*0x3e8;var _0x1c37c6,_0x55791b;if(_0x31b347>_0x4e09b7){_0x4e09b7=_0x31b347;}var _0x23c41d=seqqueue['createQueue'](_0x31b347);_0x23c41d['id']=_0x4b0855;_0x23c41d[_0x7995('0x40')]=_0x31b347;_0x23c41d['qtimeout']=_0x4e09b7;_0x23c41d[_0x7995('0x24')]=_0x504a33[_0x7995('0x24')];_0x4a9fef['rules'][_0x4b0855]['on'](_0x7995('0x41'),function(){logger[_0x7995('0x2c')](_0x7995('0x42'),_0x4b0855);stopRouting(_0x4b0855,_0xc04e5,_0x504a33,_0x4a9fef);clearTimeout(_0x1c37c6);_0x1c37c6=undefined;_0x23c41d[_0x7995('0x43')](!![]);if(_0x4a9fef['rules'][_0x4b0855]){delete _0x4a9fef[_0x7995('0x44')][_0x4b0855];}_0x23da6b[_0x7995('0x3c')]();});_0x4a9fef[_0x7995('0x44')][_0x4b0855]['on']('complete',function(){if(_0x4a9fef[_0x7995('0x44')][_0x4b0855]){delete _0x4a9fef[_0x7995('0x44')][_0x4b0855];}});_0x1c37c6=setTimeout(function(){logger[_0x7995('0x2c')](_0x7995('0x45'),_0x4b0855);endRouting(_0x4b0855,_0xc04e5,_0x504a33,_0x4a9fef);clearTimeout(_0x1c37c6);_0x23c41d[_0x7995('0x43')](!![]);_0x23da6b['next']();},_0x4e09b7);switch(_0xc04e5[_0x7995('0x46')]){case _0x7995('0x47'):strategy['rrmemory'](_0x23c41d,_0xc04e5,_0x4a9fef,_0x504a33);break;default:strategy[_0x7995('0x48')](_0x23c41d,_0xc04e5,_0x4a9fef,_0x504a33);}}else{logger['error'](_0x7995('0x49'),_0x4b0855,_0x36e28b[_0x7995('0x2d')]);_0x23da6b[_0x7995('0x3c')]();}}}catch(_0x30e220){console[_0x7995('0x4a')](_0x30e220);logger[_0x7995('0x31')](_0x7995('0x3a'),_0x4b0855,_0x30e220['stack']);_0x23da6b[_0x7995('0x3c')]();}};};
\ No newline at end of file
+var _0xe149=['log','[%s][QUEUE]\x20%s','stack','util','moment','ioredis','../../../../config/environment','../../../../config/logger','routing','./strategy','redis','defaults','localhost','queue_id','account','queue','from','joinAt','emit','clone','%sQueuesWaitingInteractions','format','%s:queue:%s','%s_queue_waiting_interaction:%s','save','pick','../../rpc/openchannelQueueReport','../../rpc/mailQueueReport','../../rpc/chatQueueReport','../../rpc/faxQueueReport','../../rpc/whatsappQueueReport','string','name\x20is\x20a\x20string\x20and\x20it\x20is\x20required','number','timeout\x20is\x20a\x20number','waiting','YYYY-MM-DD\x20HH:mm:ss','contact','list','upperFirst','channel','QueueId','InteractionId','interaction','MessageId','message','chat','AccountId','WebsiteId','info','[%s][START:QUEUE][NAME:%s]','name','QueueReport','create','accepted','[%s][STOP:QUEUE][NAME:%s]','body','update','catch','error','update\x20queue\x20report','timeout','toLowerCase','consequence','length','map','join','stop','find','Queues','createQueue','atimeout','qtimeout','[%s][QUEUE]\x20ROUTING\x20STOPPED','close','rules','complete','[%s][QUEUE]\x20APPLICATION\x20END','next','strategy','rrmemory'];(function(_0x40ddc0,_0x41c082){var _0x1aebf1=function(_0x3ba1f6){while(--_0x3ba1f6){_0x40ddc0['push'](_0x40ddc0['shift']());}};_0x1aebf1(++_0x41c082);}(_0xe149,0xf6));var _0x9e14=function(_0x30950d,_0x2cbbee){_0x30950d=_0x30950d-0x0;var _0x13325c=_0xe149[_0x30950d];return _0x13325c;};'use strict';var schema=require('validate');var _=require('lodash');var util=require(_0x9e14('0x0'));var seqqueue=require('seq-queue');var moment=require(_0x9e14('0x1'));var Redis=require(_0x9e14('0x2'));var config=require(_0x9e14('0x3'));var logger=require(_0x9e14('0x4'))(_0x9e14('0x5'));var strategy=require(_0x9e14('0x6'));config[_0x9e14('0x7')]=_[_0x9e14('0x8')](config[_0x9e14('0x7')],{'host':_0x9e14('0x9'),'port':0x18eb});var io=require('socket.io-emitter')(new Redis(config[_0x9e14('0x7')]));var attributes=['id',_0x9e14('0xa'),_0x9e14('0xb'),_0x9e14('0xc'),_0x9e14('0xd'),_0x9e14('0xe')];function emit(_0x544c58,_0x35e68b,_0x10eab7){io['to'](_0x544c58)[_0x9e14('0xf')](_0x35e68b,_0x10eab7);}function emitChannelQueueInteraction(_0x14a944,_0x5b7f95,_0x10ee71,_0x18e9b6,_0x386423,_0x3053ae,_0x5cd27c,_0x22fd4b){var _0x1c01c4=_[_0x9e14('0x10')](_0x10ee71);_0x1c01c4[_0x9e14('0xa')]=_0x22fd4b;_0x1c01c4['queue']=_0x5b7f95;_0x1c01c4[_0x9e14('0xb')]=_0x18e9b6;_0x1c01c4['id']=_0x386423;if(_0x3053ae){_0x5cd27c[util['format'](_0x9e14('0x11'),_0x14a944)][_0x386423]=_['pick'](_0x1c01c4,attributes);}else{delete _0x5cd27c[util[_0x9e14('0x12')](_0x9e14('0x11'),_0x14a944)][_0x386423];}emit(util[_0x9e14('0x12')](_0x9e14('0x13'),_0x14a944,_0x5b7f95),util[_0x9e14('0x12')](_0x9e14('0x14'),_0x14a944,_0x3053ae?_0x9e14('0x15'):'remove'),_[_0x9e14('0x16')](_0x1c01c4,attributes));}var rpc={'openchannelQueueReport':require(_0x9e14('0x17')),'mailQueueReport':require(_0x9e14('0x18')),'chatQueueReport':require(_0x9e14('0x19')),'smsQueueReport':require('../../rpc/smsQueueReport'),'faxQueueReport':require(_0x9e14('0x1a')),'whatsappQueueReport':require(_0x9e14('0x1b'))};var queue=schema({'name':{'type':_0x9e14('0x1c'),'required':!![],'message':_0x9e14('0x1d')},'timeout':{'type':_0x9e14('0x1e'),'message':_0x9e14('0x1f')}});function startRouting(_0x2b45d8,_0x2efd09,_0x1478c6,_0x2adb53){if(_0x2b45d8&&_0x2efd09&&_0x1478c6){_0x2efd09[_0x9e14('0x20')]+=0x1;var _0x1b9397={'uniqueid':_0x2b45d8,'from':_0x1478c6['body']?_0x1478c6['body'][_0x9e14('0xd')]:'','joinAt':moment()[_0x9e14('0x12')](_0x9e14('0x21')),'ContactId':_0x1478c6[_0x9e14('0x22')]?_0x1478c6[_0x9e14('0x22')]['id']:null,'ListId':_0x1478c6[_0x9e14('0x23')]?_0x1478c6[_0x9e14('0x23')]['id']:null};_0x1b9397[_[_0x9e14('0x24')](_0x1478c6[_0x9e14('0x25')])+_0x9e14('0x26')]=_0x2efd09['id']||null;_0x1b9397[_[_0x9e14('0x24')](_0x1478c6[_0x9e14('0x25')])+_0x9e14('0x27')]=_0x1478c6[_0x9e14('0x28')]?_0x1478c6[_0x9e14('0x28')]['id']:null;_0x1b9397[_[_0x9e14('0x24')](_0x1478c6[_0x9e14('0x25')])+_0x9e14('0x29')]=_0x1478c6[_0x9e14('0x2a')]?_0x1478c6[_0x9e14('0x2a')]['id']:null;_0x1b9397[_[_0x9e14('0x24')](_0x1478c6[_0x9e14('0x25')])+(_0x1478c6[_0x9e14('0x25')]!==_0x9e14('0x2b')?_0x9e14('0x2c'):_0x9e14('0x2d'))]=_0x1478c6['account']?_0x1478c6[_0x9e14('0xb')]['id']:null;logger[_0x9e14('0x2e')](util[_0x9e14('0x12')](_0x9e14('0x2f'),_0x2b45d8,_0x2efd09[_0x9e14('0x30')]));emitChannelQueueInteraction(_0x1478c6[_0x9e14('0x25')],_0x2efd09['name'],_0x1b9397,_0x1478c6[_0x9e14('0xb')][_0x9e14('0x30')],_0x1478c6[_0x9e14('0x2a')]['id'],!![],_0x2adb53,_0x2efd09['id']);if(rpc[_0x1478c6[_0x9e14('0x25')]+'QueueReport']){return rpc[_0x1478c6[_0x9e14('0x25')]+_0x9e14('0x31')][_0x9e14('0x32')](_0x1b9397)['catch'](function(_0x3d8e7b){logger['error']('create\x20queue\x20report');});}}}function stopRouting(_0x430266,_0xb266a2,_0x38aed6,_0x1c3056){if(_0x430266&&_0xb266a2){_0xb266a2[_0x9e14('0x20')]-=0x1;var _0x537c94={'leaveAt':moment()['format'](_0x9e14('0x21')),'acceptAt':moment()['format'](_0x9e14('0x21')),'reason':_0x9e14('0x33')};logger[_0x9e14('0x2e')](util['format'](_0x9e14('0x34'),_0x430266,_0xb266a2[_0x9e14('0x30')]));emitChannelQueueInteraction(_0x38aed6[_0x9e14('0x25')],_0xb266a2['name'],_0x38aed6[_0x9e14('0x35')],_0x38aed6[_0x9e14('0xb')][_0x9e14('0x30')],_0x38aed6[_0x9e14('0x2a')]['id'],![],_0x1c3056,_0xb266a2['id']);if(rpc[_0x38aed6[_0x9e14('0x25')]+_0x9e14('0x31')]){return rpc[_0x38aed6[_0x9e14('0x25')]+'QueueReport'][_0x9e14('0x36')](_0x430266,_0x537c94)[_0x9e14('0x37')](function(_0x2c6b42){logger[_0x9e14('0x38')](_0x9e14('0x39'));});}}}function endRouting(_0x13e07c,_0x50aa8c,_0x591c5a,_0x5280de){if(_0x13e07c&&_0x50aa8c){_0x50aa8c[_0x9e14('0x20')]-=0x1;var _0x5a0db8={'leaveAt':moment()[_0x9e14('0x12')](_0x9e14('0x21')),'exitAt':moment()[_0x9e14('0x12')](_0x9e14('0x21')),'reason':_0x9e14('0x3a')};logger['info'](util[_0x9e14('0x12')]('[%s][END:QUEUE][NAME:%s]',_0x13e07c,_0x50aa8c[_0x9e14('0x30')]));emitChannelQueueInteraction(_0x591c5a[_0x9e14('0x25')],_0x50aa8c['name'],_0x591c5a[_0x9e14('0x35')],_0x591c5a['account'][_0x9e14('0x30')],_0x591c5a[_0x9e14('0x2a')]['id'],![],_0x5280de);if(rpc[_0x591c5a[_0x9e14('0x25')]+'QueueReport']){return rpc[_0x591c5a[_0x9e14('0x25')]+_0x9e14('0x31')][_0x9e14('0x36')](_0x13e07c,_0x5a0db8)[_0x9e14('0x37')](function(_0x2e83d8){logger[_0x9e14('0x38')](_0x9e14('0x39'));});}}}function handleFindQueue(_0x1c23f8){return function(_0xafc47a){return _0xafc47a[_0x9e14('0x30')][_0x9e14('0x3b')]()===_0x1c23f8[_0x9e14('0x3b')]();};}exports[_0x9e14('0x3c')]=function(_0x8770a1,_0x308017,_0x648ed8,_0x3ce978){return function(_0x2a05e4){try{var _0x19e31e={'name':_0x308017[0x0],'timeout':_0x308017[0x1]};var _0x4900eb=queue['validate'](_0x19e31e,{'typecast':!![]});if(_0x4900eb[_0x9e14('0x3d')]){logger[_0x9e14('0x38')]('[%s][QUEUE]\x20%s',_0x8770a1,_[_0x9e14('0x3e')](_0x4900eb,'message')[_0x9e14('0x3f')](',\x20'));_0x2a05e4[_0x9e14('0x40')]();}else{var _0x440049=_[_0x9e14('0x41')](_0x648ed8[_0x3ce978['channel']+_0x9e14('0x42')],handleFindQueue(_0x19e31e[_0x9e14('0x30')]));if(_0x440049){startRouting(_0x8770a1,_0x440049,_0x3ce978,_0x648ed8);var _0x4d32eb=(_0x440049[_0x9e14('0x3a')]||0xa)*0x3e8;var _0x38a1c5=(_0x19e31e[_0x9e14('0x3a')]||0x14)*0x3e8;var _0x5b90a4,_0x247eea;if(_0x4d32eb>_0x38a1c5){_0x38a1c5=_0x4d32eb;}var _0x2aeeb8=seqqueue[_0x9e14('0x43')](_0x4d32eb);_0x2aeeb8['id']=_0x8770a1;_0x2aeeb8[_0x9e14('0x44')]=_0x4d32eb;_0x2aeeb8[_0x9e14('0x45')]=_0x38a1c5;_0x2aeeb8[_0x9e14('0x25')]=_0x3ce978[_0x9e14('0x25')];_0x648ed8['rules'][_0x8770a1]['on']('end',function(){logger[_0x9e14('0x2e')](_0x9e14('0x46'),_0x8770a1);stopRouting(_0x8770a1,_0x440049,_0x3ce978,_0x648ed8);clearTimeout(_0x5b90a4);_0x5b90a4=undefined;_0x2aeeb8[_0x9e14('0x47')](!![]);if(_0x648ed8[_0x9e14('0x48')][_0x8770a1]){delete _0x648ed8['rules'][_0x8770a1];}_0x2a05e4[_0x9e14('0x40')]();});_0x648ed8[_0x9e14('0x48')][_0x8770a1]['on'](_0x9e14('0x49'),function(){if(_0x648ed8[_0x9e14('0x48')][_0x8770a1]){delete _0x648ed8['rules'][_0x8770a1];}});_0x5b90a4=setTimeout(function(){logger[_0x9e14('0x2e')](_0x9e14('0x4a'),_0x8770a1);endRouting(_0x8770a1,_0x440049,_0x3ce978,_0x648ed8);clearTimeout(_0x5b90a4);_0x2aeeb8[_0x9e14('0x47')](!![]);_0x2a05e4[_0x9e14('0x4b')]();},_0x38a1c5);switch(_0x440049[_0x9e14('0x4c')]){case _0x9e14('0x4d'):strategy['rrmemory'](_0x2aeeb8,_0x440049,_0x648ed8,_0x3ce978);break;default:strategy['beepall'](_0x2aeeb8,_0x440049,_0x648ed8,_0x3ce978);}}else{logger[_0x9e14('0x38')]('[%s][QUEUE]\x20queue\x20not\x20found\x20%s',_0x8770a1,_0x19e31e['name']);_0x2a05e4[_0x9e14('0x40')]();}}}catch(_0x1eadfa){console[_0x9e14('0x4e')](_0x1eadfa);logger['error'](_0x9e14('0x4f'),_0x8770a1,_0x1eadfa[_0x9e14('0x50')]);_0x2a05e4[_0x9e14('0x40')]();}};};
\ No newline at end of file