Built motion from commit d9028345.|2.5.43
[motion2.git] / server / services / routing / server / applications / queue.js
index 248b550..efdccf3 100644 (file)
@@ -15,4 +15,4 @@
 // * treaties. The SOFTWARE PRODUCT is licensed, not sold.                        *
 // *                                                                       *
 // *************************************************************************
-var _0x8d37=['%s_queue_waiting_interaction:%s','remove','../../rpc/mailQueueReport','../../rpc/chatQueueReport','../../rpc/smsQueueReport','../../rpc/faxQueueReport','../../rpc/whatsappQueueReport','name\x20is\x20a\x20string\x20and\x20it\x20is\x20required','number','timeout\x20is\x20a\x20number','waiting','body','list','channel','QueueId','upperFirst','interaction','MessageId','message','chat','AccountId','WebsiteId','[%s][START:QUEUE][NAME:%s]','name','create\x20queue\x20report','YYYY-MM-DD\x20HH:mm:ss','accepted','info','[%s][STOP:QUEUE][NAME:%s]','QueueReport','error','timeout','[%s][END:QUEUE][NAME:%s]','update','catch','update\x20queue\x20report','toLowerCase','consequence','length','[%s][QUEUE]\x20%s','join','stop','find','Queues','createQueue','qtimeout','end','[%s][QUEUE]\x20ROUTING\x20STOPPED','close','rules','complete','[%s][QUEUE]\x20APPLICATION\x20END','next','strategy','rrmemory','beepall','[%s][QUEUE]\x20queue\x20not\x20found\x20%s','log','stack','validate','lodash','util','seq-queue','moment','../../../../config/environment','../../../../config/logger','routing','./strategy','redis','defaults','localhost','queue_id','account','queue','from','joinAt','emit','clone','%sQueuesWaitingInteractions','pick','format','%s:queue:%s'];(function(_0x1fc122,_0x5e2c17){var _0xa2cb13=function(_0x263b13){while(--_0x263b13){_0x1fc122['push'](_0x1fc122['shift']());}};_0xa2cb13(++_0x5e2c17);}(_0x8d37,0x1d5));var _0x78d3=function(_0x264e85,_0x2b1b65){_0x264e85=_0x264e85-0x0;var _0x4bcaeb=_0x8d37[_0x264e85];return _0x4bcaeb;};'use strict';var schema=require(_0x78d3('0x0'));var _=require(_0x78d3('0x1'));var util=require(_0x78d3('0x2'));var seqqueue=require(_0x78d3('0x3'));var moment=require(_0x78d3('0x4'));var Redis=require('ioredis');var config=require(_0x78d3('0x5'));var logger=require(_0x78d3('0x6'))(_0x78d3('0x7'));var strategy=require(_0x78d3('0x8'));config[_0x78d3('0x9')]=_[_0x78d3('0xa')](config[_0x78d3('0x9')],{'host':_0x78d3('0xb'),'port':0x18eb});var io=require('socket.io-emitter')(new Redis(config[_0x78d3('0x9')]));var attributes=['id',_0x78d3('0xc'),_0x78d3('0xd'),_0x78d3('0xe'),_0x78d3('0xf'),_0x78d3('0x10')];function emit(_0x44ef49,_0x2a11b5,_0x2fee2c){io['to'](_0x44ef49)[_0x78d3('0x11')](_0x2a11b5,_0x2fee2c);}function emitChannelQueueInteraction(_0x358678,_0x17e275,_0x2a9a87,_0x165c73,_0x2cc7c3,_0x1075de,_0x1fd377,_0x4d229a){var _0x57c685=_[_0x78d3('0x12')](_0x2a9a87);_0x57c685[_0x78d3('0xc')]=_0x4d229a;_0x57c685['queue']=_0x17e275;_0x57c685[_0x78d3('0xd')]=_0x165c73;_0x57c685['id']=_0x2cc7c3;if(_0x1075de){_0x1fd377[util['format'](_0x78d3('0x13'),_0x358678)][_0x2cc7c3]=_[_0x78d3('0x14')](_0x57c685,attributes);}else{delete _0x1fd377[util[_0x78d3('0x15')](_0x78d3('0x13'),_0x358678)][_0x2cc7c3];}emit(util[_0x78d3('0x15')](_0x78d3('0x16'),_0x358678,_0x17e275),util[_0x78d3('0x15')](_0x78d3('0x17'),_0x358678,_0x1075de?'save':_0x78d3('0x18')),_[_0x78d3('0x14')](_0x57c685,attributes));}var rpc={'openchannelQueueReport':require('../../rpc/openchannelQueueReport'),'mailQueueReport':require(_0x78d3('0x19')),'chatQueueReport':require(_0x78d3('0x1a')),'smsQueueReport':require(_0x78d3('0x1b')),'faxQueueReport':require(_0x78d3('0x1c')),'whatsappQueueReport':require(_0x78d3('0x1d'))};var queue=schema({'name':{'type':'string','required':!![],'message':_0x78d3('0x1e')},'timeout':{'type':_0x78d3('0x1f'),'message':_0x78d3('0x20')}});function startRouting(_0x454455,_0x2e9783,_0x5723d8,_0x1abc79){if(_0x454455&&_0x2e9783&&_0x5723d8){_0x2e9783[_0x78d3('0x21')]+=0x1;var _0x2fa1a9={'uniqueid':_0x454455,'from':_0x5723d8[_0x78d3('0x22')]?_0x5723d8['body'][_0x78d3('0xf')]:'','joinAt':moment()['format']('YYYY-MM-DD\x20HH:mm:ss'),'ContactId':_0x5723d8['contact']?_0x5723d8['contact']['id']:null,'ListId':_0x5723d8[_0x78d3('0x23')]?_0x5723d8[_0x78d3('0x23')]['id']:null};_0x2fa1a9[_['upperFirst'](_0x5723d8[_0x78d3('0x24')])+_0x78d3('0x25')]=_0x2e9783['id']||null;_0x2fa1a9[_[_0x78d3('0x26')](_0x5723d8[_0x78d3('0x24')])+'InteractionId']=_0x5723d8[_0x78d3('0x27')]?_0x5723d8[_0x78d3('0x27')]['id']:null;_0x2fa1a9[_[_0x78d3('0x26')](_0x5723d8[_0x78d3('0x24')])+_0x78d3('0x28')]=_0x5723d8[_0x78d3('0x29')]?_0x5723d8['message']['id']:null;_0x2fa1a9[_[_0x78d3('0x26')](_0x5723d8[_0x78d3('0x24')])+(_0x5723d8[_0x78d3('0x24')]!==_0x78d3('0x2a')?_0x78d3('0x2b'):_0x78d3('0x2c'))]=_0x5723d8[_0x78d3('0xd')]?_0x5723d8['account']['id']:null;logger['info'](util[_0x78d3('0x15')](_0x78d3('0x2d'),_0x454455,_0x2e9783['name']));emitChannelQueueInteraction(_0x5723d8[_0x78d3('0x24')],_0x2e9783[_0x78d3('0x2e')],_0x2fa1a9,_0x5723d8[_0x78d3('0xd')][_0x78d3('0x2e')],_0x5723d8[_0x78d3('0x29')]['id'],!![],_0x1abc79,_0x2e9783['id']);if(rpc[_0x5723d8['channel']+'QueueReport']){return rpc[_0x5723d8[_0x78d3('0x24')]+'QueueReport']['create'](_0x2fa1a9)['catch'](function(_0x26a8ab){logger['error'](_0x78d3('0x2f'));});}}}function stopRouting(_0xd90225,_0x133a4a,_0x11bd3a,_0x58ec61){if(_0xd90225&&_0x133a4a){_0x133a4a[_0x78d3('0x21')]-=0x1;var _0x150fe9={'leaveAt':moment()[_0x78d3('0x15')](_0x78d3('0x30')),'acceptAt':moment()[_0x78d3('0x15')]('YYYY-MM-DD\x20HH:mm:ss'),'reason':_0x78d3('0x31')};logger[_0x78d3('0x32')](util['format'](_0x78d3('0x33'),_0xd90225,_0x133a4a[_0x78d3('0x2e')]));emitChannelQueueInteraction(_0x11bd3a['channel'],_0x133a4a[_0x78d3('0x2e')],_0x11bd3a[_0x78d3('0x22')],_0x11bd3a[_0x78d3('0xd')]['name'],_0x11bd3a[_0x78d3('0x29')]['id'],![],_0x58ec61,_0x133a4a['id']);if(rpc[_0x11bd3a[_0x78d3('0x24')]+_0x78d3('0x34')]){return rpc[_0x11bd3a[_0x78d3('0x24')]+_0x78d3('0x34')]['update'](_0xd90225,_0x150fe9)['catch'](function(_0x4244c3){logger[_0x78d3('0x35')]('update\x20queue\x20report');});}}}function endRouting(_0x491f00,_0x2c9a2e,_0x3a95f3,_0x1c1f04){if(_0x491f00&&_0x2c9a2e){_0x2c9a2e[_0x78d3('0x21')]-=0x1;var _0xe04647={'leaveAt':moment()['format'](_0x78d3('0x30')),'exitAt':moment()[_0x78d3('0x15')](_0x78d3('0x30')),'reason':_0x78d3('0x36')};logger[_0x78d3('0x32')](util[_0x78d3('0x15')](_0x78d3('0x37'),_0x491f00,_0x2c9a2e[_0x78d3('0x2e')]));emitChannelQueueInteraction(_0x3a95f3[_0x78d3('0x24')],_0x2c9a2e[_0x78d3('0x2e')],_0x3a95f3[_0x78d3('0x22')],_0x3a95f3[_0x78d3('0xd')][_0x78d3('0x2e')],_0x3a95f3['message']['id'],![],_0x1c1f04);if(rpc[_0x3a95f3[_0x78d3('0x24')]+_0x78d3('0x34')]){return rpc[_0x3a95f3[_0x78d3('0x24')]+_0x78d3('0x34')][_0x78d3('0x38')](_0x491f00,_0xe04647)[_0x78d3('0x39')](function(_0x4dc386){logger['error'](_0x78d3('0x3a'));});}}}function handleFindQueue(_0x513ce9){return function(_0x1601ab){return _0x1601ab[_0x78d3('0x2e')][_0x78d3('0x3b')]()===_0x513ce9[_0x78d3('0x3b')]();};}exports[_0x78d3('0x3c')]=function(_0x5b921,_0x49e7eb,_0x4eeacc,_0x19c396){return function(_0x3f7fba){try{var _0x176f78={'name':_0x49e7eb[0x0],'timeout':_0x49e7eb[0x1]};var _0xae2b7e=queue[_0x78d3('0x0')](_0x176f78,{'typecast':!![]});if(_0xae2b7e[_0x78d3('0x3d')]){logger['error'](_0x78d3('0x3e'),_0x5b921,_['map'](_0xae2b7e,_0x78d3('0x29'))[_0x78d3('0x3f')](',\x20'));_0x3f7fba[_0x78d3('0x40')]();}else{var _0x1dd7c8=_[_0x78d3('0x41')](_0x4eeacc[_0x19c396[_0x78d3('0x24')]+_0x78d3('0x42')],handleFindQueue(_0x176f78[_0x78d3('0x2e')]));if(_0x1dd7c8){startRouting(_0x5b921,_0x1dd7c8,_0x19c396,_0x4eeacc);var _0x212e3b=(_0x1dd7c8[_0x78d3('0x36')]||0xa)*0x3e8;var _0x2e005f=(_0x176f78[_0x78d3('0x36')]||0x14)*0x3e8;var _0x14ba18,_0x30e731;if(_0x212e3b>_0x2e005f){_0x2e005f=_0x212e3b;}var _0x303866=seqqueue[_0x78d3('0x43')](_0x212e3b);_0x303866['id']=_0x5b921;_0x303866['atimeout']=_0x212e3b;_0x303866[_0x78d3('0x44')]=_0x2e005f;_0x303866[_0x78d3('0x24')]=_0x19c396[_0x78d3('0x24')];_0x4eeacc['rules'][_0x5b921]['on'](_0x78d3('0x45'),function(){logger[_0x78d3('0x32')](_0x78d3('0x46'),_0x5b921);stopRouting(_0x5b921,_0x1dd7c8,_0x19c396,_0x4eeacc);clearTimeout(_0x14ba18);_0x14ba18=undefined;_0x303866[_0x78d3('0x47')](!![]);if(_0x4eeacc[_0x78d3('0x48')][_0x5b921]){delete _0x4eeacc[_0x78d3('0x48')][_0x5b921];}_0x3f7fba[_0x78d3('0x40')]();});_0x4eeacc[_0x78d3('0x48')][_0x5b921]['on'](_0x78d3('0x49'),function(){if(_0x4eeacc[_0x78d3('0x48')][_0x5b921]){delete _0x4eeacc[_0x78d3('0x48')][_0x5b921];}});_0x14ba18=setTimeout(function(){logger[_0x78d3('0x32')](_0x78d3('0x4a'),_0x5b921);endRouting(_0x5b921,_0x1dd7c8,_0x19c396,_0x4eeacc);clearTimeout(_0x14ba18);_0x303866[_0x78d3('0x47')](!![]);_0x3f7fba[_0x78d3('0x4b')]();},_0x2e005f);switch(_0x1dd7c8[_0x78d3('0x4c')]){case _0x78d3('0x4d'):strategy[_0x78d3('0x4d')](_0x303866,_0x1dd7c8,_0x4eeacc,_0x19c396);break;default:strategy[_0x78d3('0x4e')](_0x303866,_0x1dd7c8,_0x4eeacc,_0x19c396);}}else{logger['error'](_0x78d3('0x4f'),_0x5b921,_0x176f78[_0x78d3('0x2e')]);_0x3f7fba[_0x78d3('0x40')]();}}}catch(_0x3049e8){console[_0x78d3('0x50')](_0x3049e8);logger[_0x78d3('0x35')]('[%s][QUEUE]\x20%s',_0x5b921,_0x3049e8[_0x78d3('0x51')]);_0x3f7fba[_0x78d3('0x40')]();}};};
\ No newline at end of file
+var _0x81cb=['stop','complete','[%s][QUEUE]\x20APPLICATION\x20END','next','strategy','rrmemory','beepall','log','[%s][QUEUE]\x20%s','stack','validate','lodash','seq-queue','moment','../../../../config/environment','../../../../config/logger','routing','./strategy','defaults','socket.io-emitter','redis','queue_id','account','queue','from','joinAt','emit','format','pick','%s:queue:%s','save','remove','../../rpc/openchannelQueueReport','../../rpc/mailQueueReport','../../rpc/chatQueueReport','../../rpc/faxQueueReport','../../rpc/whatsappQueueReport','string','number','timeout\x20is\x20a\x20number','waiting','body','contact','list','upperFirst','channel','InteractionId','interaction','MessageId','message','chat','AccountId','WebsiteId','[%s][START:QUEUE][NAME:%s]','name','QueueReport','create','catch','error','YYYY-MM-DD\x20HH:mm:ss','accepted','info','[%s][STOP:QUEUE][NAME:%s]','update','update\x20queue\x20report','timeout','[%s][END:QUEUE][NAME:%s]','toLowerCase','consequence','length','map','join','find','createQueue','atimeout','qtimeout','rules','end','[%s][QUEUE]\x20ROUTING\x20STOPPED','close'];(function(_0x3772d2,_0x23a7cb){var _0x3a67e7=function(_0x141c60){while(--_0x141c60){_0x3772d2['push'](_0x3772d2['shift']());}};_0x3a67e7(++_0x23a7cb);}(_0x81cb,0xaa));var _0xb81c=function(_0x3dd15e,_0x1f0015){_0x3dd15e=_0x3dd15e-0x0;var _0x231fd0=_0x81cb[_0x3dd15e];return _0x231fd0;};'use strict';var schema=require(_0xb81c('0x0'));var _=require(_0xb81c('0x1'));var util=require('util');var seqqueue=require(_0xb81c('0x2'));var moment=require(_0xb81c('0x3'));var Redis=require('ioredis');var config=require(_0xb81c('0x4'));var logger=require(_0xb81c('0x5'))(_0xb81c('0x6'));var strategy=require(_0xb81c('0x7'));config['redis']=_[_0xb81c('0x8')](config['redis'],{'host':'localhost','port':0x18eb});var io=require(_0xb81c('0x9'))(new Redis(config[_0xb81c('0xa')]));var attributes=['id',_0xb81c('0xb'),_0xb81c('0xc'),_0xb81c('0xd'),_0xb81c('0xe'),_0xb81c('0xf')];function emit(_0x14b1bf,_0x250dd4,_0x38bd0b){io['to'](_0x14b1bf)[_0xb81c('0x10')](_0x250dd4,_0x38bd0b);}function emitChannelQueueInteraction(_0xe05faf,_0x44dfb2,_0x1b2a92,_0x48ba50,_0x29a6f2,_0x388a50,_0x33c240,_0x60aa8e){var _0x2e8242=_['clone'](_0x1b2a92);_0x2e8242[_0xb81c('0xb')]=_0x60aa8e;_0x2e8242['queue']=_0x44dfb2;_0x2e8242[_0xb81c('0xc')]=_0x48ba50;_0x2e8242['id']=_0x29a6f2;if(_0x388a50){_0x33c240[util[_0xb81c('0x11')]('%sQueuesWaitingInteractions',_0xe05faf)][_0x29a6f2]=_[_0xb81c('0x12')](_0x2e8242,attributes);}else{delete _0x33c240[util[_0xb81c('0x11')]('%sQueuesWaitingInteractions',_0xe05faf)][_0x29a6f2];}emit(util[_0xb81c('0x11')](_0xb81c('0x13'),_0xe05faf,_0x44dfb2),util[_0xb81c('0x11')]('%s_queue_waiting_interaction:%s',_0xe05faf,_0x388a50?_0xb81c('0x14'):_0xb81c('0x15')),_['pick'](_0x2e8242,attributes));}var rpc={'openchannelQueueReport':require(_0xb81c('0x16')),'mailQueueReport':require(_0xb81c('0x17')),'chatQueueReport':require(_0xb81c('0x18')),'smsQueueReport':require('../../rpc/smsQueueReport'),'faxQueueReport':require(_0xb81c('0x19')),'whatsappQueueReport':require(_0xb81c('0x1a'))};var queue=schema({'name':{'type':_0xb81c('0x1b'),'required':!![],'message':'name\x20is\x20a\x20string\x20and\x20it\x20is\x20required'},'timeout':{'type':_0xb81c('0x1c'),'message':_0xb81c('0x1d')}});function startRouting(_0xfab47b,_0x1d970c,_0x3ca373,_0x19f6c6){if(_0xfab47b&&_0x1d970c&&_0x3ca373){_0x1d970c[_0xb81c('0x1e')]+=0x1;var _0x4f09d7={'uniqueid':_0xfab47b,'from':_0x3ca373[_0xb81c('0x1f')]?_0x3ca373[_0xb81c('0x1f')][_0xb81c('0xe')]:'','joinAt':moment()[_0xb81c('0x11')]('YYYY-MM-DD\x20HH:mm:ss'),'ContactId':_0x3ca373[_0xb81c('0x20')]?_0x3ca373['contact']['id']:null,'ListId':_0x3ca373[_0xb81c('0x21')]?_0x3ca373[_0xb81c('0x21')]['id']:null};_0x4f09d7[_[_0xb81c('0x22')](_0x3ca373[_0xb81c('0x23')])+'QueueId']=_0x1d970c['id']||null;_0x4f09d7[_['upperFirst'](_0x3ca373[_0xb81c('0x23')])+_0xb81c('0x24')]=_0x3ca373[_0xb81c('0x25')]?_0x3ca373[_0xb81c('0x25')]['id']:null;_0x4f09d7[_[_0xb81c('0x22')](_0x3ca373[_0xb81c('0x23')])+_0xb81c('0x26')]=_0x3ca373[_0xb81c('0x27')]?_0x3ca373[_0xb81c('0x27')]['id']:null;_0x4f09d7[_[_0xb81c('0x22')](_0x3ca373[_0xb81c('0x23')])+(_0x3ca373[_0xb81c('0x23')]!==_0xb81c('0x28')?_0xb81c('0x29'):_0xb81c('0x2a'))]=_0x3ca373[_0xb81c('0xc')]?_0x3ca373[_0xb81c('0xc')]['id']:null;logger['info'](util['format'](_0xb81c('0x2b'),_0xfab47b,_0x1d970c[_0xb81c('0x2c')]));emitChannelQueueInteraction(_0x3ca373['channel'],_0x1d970c[_0xb81c('0x2c')],_0x4f09d7,_0x3ca373[_0xb81c('0xc')]['name'],_0x3ca373[_0xb81c('0x27')]['id'],!![],_0x19f6c6,_0x1d970c['id']);if(rpc[_0x3ca373['channel']+_0xb81c('0x2d')]){return rpc[_0x3ca373['channel']+_0xb81c('0x2d')][_0xb81c('0x2e')](_0x4f09d7)[_0xb81c('0x2f')](function(_0x548fe2){logger[_0xb81c('0x30')]('create\x20queue\x20report');});}}}function stopRouting(_0x2765c1,_0x317ed5,_0x59776a,_0x74ff46){if(_0x2765c1&&_0x317ed5){_0x317ed5[_0xb81c('0x1e')]-=0x1;var _0x3ad282={'leaveAt':moment()['format'](_0xb81c('0x31')),'acceptAt':moment()[_0xb81c('0x11')](_0xb81c('0x31')),'reason':_0xb81c('0x32')};logger[_0xb81c('0x33')](util[_0xb81c('0x11')](_0xb81c('0x34'),_0x2765c1,_0x317ed5[_0xb81c('0x2c')]));emitChannelQueueInteraction(_0x59776a[_0xb81c('0x23')],_0x317ed5[_0xb81c('0x2c')],_0x59776a['body'],_0x59776a[_0xb81c('0xc')]['name'],_0x59776a['message']['id'],![],_0x74ff46,_0x317ed5['id']);if(rpc[_0x59776a[_0xb81c('0x23')]+'QueueReport']){return rpc[_0x59776a[_0xb81c('0x23')]+'QueueReport'][_0xb81c('0x35')](_0x2765c1,_0x3ad282)[_0xb81c('0x2f')](function(_0x4db161){logger[_0xb81c('0x30')](_0xb81c('0x36'));});}}}function endRouting(_0x399c62,_0x5e94bf,_0x3f57e2,_0x24c430){if(_0x399c62&&_0x5e94bf){_0x5e94bf[_0xb81c('0x1e')]-=0x1;var _0x3c97f7={'leaveAt':moment()['format'](_0xb81c('0x31')),'exitAt':moment()[_0xb81c('0x11')](_0xb81c('0x31')),'reason':_0xb81c('0x37')};logger[_0xb81c('0x33')](util[_0xb81c('0x11')](_0xb81c('0x38'),_0x399c62,_0x5e94bf[_0xb81c('0x2c')]));emitChannelQueueInteraction(_0x3f57e2['channel'],_0x5e94bf['name'],_0x3f57e2['body'],_0x3f57e2['account']['name'],_0x3f57e2[_0xb81c('0x27')]['id'],![],_0x24c430);if(rpc[_0x3f57e2['channel']+_0xb81c('0x2d')]){return rpc[_0x3f57e2[_0xb81c('0x23')]+_0xb81c('0x2d')][_0xb81c('0x35')](_0x399c62,_0x3c97f7)[_0xb81c('0x2f')](function(_0x57c3e8){logger[_0xb81c('0x30')](_0xb81c('0x36'));});}}}function handleFindQueue(_0x56102c){return function(_0x597ff9){return _0x597ff9['name'][_0xb81c('0x39')]()===_0x56102c[_0xb81c('0x39')]();};}exports[_0xb81c('0x3a')]=function(_0x1dff58,_0x42ad54,_0x23eff4,_0x5962d3){return function(_0x4070cd){try{var _0x5513d0={'name':_0x42ad54[0x0],'timeout':_0x42ad54[0x1]};var _0x17dde0=queue[_0xb81c('0x0')](_0x5513d0,{'typecast':!![]});if(_0x17dde0[_0xb81c('0x3b')]){logger[_0xb81c('0x30')]('[%s][QUEUE]\x20%s',_0x1dff58,_[_0xb81c('0x3c')](_0x17dde0,'message')[_0xb81c('0x3d')](',\x20'));_0x4070cd['stop']();}else{var _0x28e76b=_[_0xb81c('0x3e')](_0x23eff4[_0x5962d3[_0xb81c('0x23')]+'Queues'],handleFindQueue(_0x5513d0[_0xb81c('0x2c')]));if(_0x28e76b){startRouting(_0x1dff58,_0x28e76b,_0x5962d3,_0x23eff4);var _0x5f581c=(_0x28e76b[_0xb81c('0x37')]||0xa)*0x3e8;var _0x2896a7=(_0x5513d0[_0xb81c('0x37')]||0x14)*0x3e8;var _0x487ff1,_0x3c7136;if(_0x5f581c>_0x2896a7){_0x2896a7=_0x5f581c;}var _0xbc5256=seqqueue[_0xb81c('0x3f')](_0x5f581c);_0xbc5256['id']=_0x1dff58;_0xbc5256[_0xb81c('0x40')]=_0x5f581c;_0xbc5256[_0xb81c('0x41')]=_0x2896a7;_0xbc5256[_0xb81c('0x23')]=_0x5962d3[_0xb81c('0x23')];_0x23eff4[_0xb81c('0x42')][_0x1dff58]['on'](_0xb81c('0x43'),function(){logger['info'](_0xb81c('0x44'),_0x1dff58);stopRouting(_0x1dff58,_0x28e76b,_0x5962d3,_0x23eff4);clearTimeout(_0x487ff1);_0x487ff1=undefined;_0xbc5256[_0xb81c('0x45')](!![]);if(_0x23eff4[_0xb81c('0x42')][_0x1dff58]){delete _0x23eff4[_0xb81c('0x42')][_0x1dff58];}_0x4070cd[_0xb81c('0x46')]();});_0x23eff4['rules'][_0x1dff58]['on'](_0xb81c('0x47'),function(){if(_0x23eff4['rules'][_0x1dff58]){delete _0x23eff4[_0xb81c('0x42')][_0x1dff58];}});_0x487ff1=setTimeout(function(){logger[_0xb81c('0x33')](_0xb81c('0x48'),_0x1dff58);endRouting(_0x1dff58,_0x28e76b,_0x5962d3,_0x23eff4);clearTimeout(_0x487ff1);_0xbc5256[_0xb81c('0x45')](!![]);_0x4070cd[_0xb81c('0x49')]();},_0x2896a7);switch(_0x28e76b[_0xb81c('0x4a')]){case _0xb81c('0x4b'):strategy['rrmemory'](_0xbc5256,_0x28e76b,_0x23eff4,_0x5962d3);break;default:strategy[_0xb81c('0x4c')](_0xbc5256,_0x28e76b,_0x23eff4,_0x5962d3);}}else{logger[_0xb81c('0x30')]('[%s][QUEUE]\x20queue\x20not\x20found\x20%s',_0x1dff58,_0x5513d0['name']);_0x4070cd[_0xb81c('0x46')]();}}}catch(_0x15404a){console[_0xb81c('0x4d')](_0x15404a);logger[_0xb81c('0x30')](_0xb81c('0x4e'),_0x1dff58,_0x15404a[_0xb81c('0x4f')]);_0x4070cd[_0xb81c('0x46')]();}};};
\ No newline at end of file