Find this useful? Enter your email to receive occasional updates for securing PHP code.

Signing you up...

Thank you for signing up!

PHP Decode

<?php namespace cG9jr\e4h94\QVRli\vdEfy\ODFNv\SIZ1R; use CG9Jr\e4H94\QVrLi\Exception\Inva..

Decoded Output download

<?php
 namespace cG9jr\e4h94\QVRli\vdEfy\ODFNv\SIZ1R; use CG9Jr\e4H94\QVrLi\Exception\InvalidArgumentException; use cg9jr\e4h94\QVrlI\Exception\LogicException; use Cg9jr\e4h94\qVRLi\Exception\jyl2W; class XyUb1 { private const E5l_W = ["x-delay", "x-expires", "x-max-length", "x-max-length-bytes", "x-max-priority", "x-message-ttl"]; private const xUyeu = ["host", "port", "vhost", "user", "login", "password", "queues", "exchange", "delay", "auto_setup", "retry", "persistent", "frame_max", "channel_max", "heartbeat", "read_timeout", "write_timeout", "confirm_timeout", "connect_timeout", "rpc_timeout", "cacert", "cert", "key", "verify", "sasl_method", "connection_name"]; private const HZ3Zy = ["binding_keys", "binding_arguments", "flags", "arguments"]; private const uD2_B = ["name", "type", "default_publish_routing_key", "flags", "arguments"]; private AmqpFactory $OlSwv; private mixed $HqnaV; private mixed $BKTGv; private \AMQPChannel $ltrrV; private \AMQPExchange $NwGSo; private array $dWNnO = []; private \AMQPExchange $CSnXL; private int $rURfm = 0; public function __construct(#[\SensitiveParameter] private array $apJsK, private array $pNusd, private array $YgMwr, ?AmqpFactory $SMW_0 = null) { goto JhbTr; rWB2J: gk_xA: goto Jj8f2; JhbTr: if (\extension_loaded("amqp")) { goto gk_xA; } goto EZAfG; Jj8f2: $this->CMea3 = array_replace_recursive(["delay" => ["exchange_name" => "delays", "queue_name_pattern" => "delay_%exchange_name%_%routing_key%_%delay%"]], $apJsK); goto AAVIs; vQiGJ: $this->OlSwv = $SMW_0 ?? new DWs9g(); goto QoK03; EZAfG: throw new LogicException(sprintf("You cannot use the "%s" as the "amqp" extension is not installed.", __CLASS__)); goto rWB2J; AAVIs: $this->HqnaV = $this->BKTGv = $apJsK["auto_setup"] ?? true; goto vQiGJ; QoK03: } public static function J6Gjw(#[\SensitiveParameter] string $YJYm5, array $tafGL = [], ?AmqpFactory $SMW_0 = null) : self { goto RfBbI; Aijkn: lsAN2: goto XGp_K; Cm2jx: $FBRGm["password"] = rawurldecode($jZIYt["pass"]); goto oRwZ3; t1maj: throw new InvalidArgumentException("The given AMQP DSN is invalid."); goto ywf4B; evlkm: throw new InvalidArgumentException("No CA certificate has been provided. Set "amqp.cacert" in your php.ini or pass the "cacert" parameter in the DSN to use SSL. Alternatively, you can use amqp:// to use without SSL."); goto SgRil; oRwZ3: eIXjX: goto OlltW; AqH73: $jZIYt = []; goto lvGpJ; O_xkr: unset($FBRGm["queues"], $FBRGm["exchange"]); goto JInv_; UvvGY: return new Br_fb($FBRGm, $pNusd, $YgMwr, $SMW_0); goto j9TG1; SlhZI: BR_fb::EAm3_($FBRGm); goto dfC1u; Xav20: $FBRGm["auto_setup"] = filter_var($FBRGm["auto_setup"], \FILTER_VALIDATE_BOOL); goto Aijkn; Oay1g: pQwrm: goto ASe2Z; gx47O: $tchlg = $DHf4j ? 5671 : 5672; goto ojSa2; whKQ3: $FBRGm["login"] = rawurldecode($jZIYt["user"]); goto Oay1g; GnOJ2: if ($DHf4j) { goto JKcqs; } goto fj1VO; RfBbI: if (!(false === ($jZIYt = parse_url($YJYm5)))) { goto vUUgQ; } goto mzU8E; EWckY: parse_str($jZIYt["query"] ?? '', $yhxfE); goto gx47O; lvGpJ: vUUgQ: goto r01XA; ojSa2: $FBRGm = array_replace_recursive(["host" => $jZIYt["host"] ?? "localhost", "port" => $jZIYt["port"] ?? $tchlg, "vhost" => isset($BC0cR[0]) ? urldecode($BC0cR[0]) : "/", "exchange" => ["name" => $j8txZ]], $tafGL, $yhxfE); goto SlhZI; Wp685: $BC0cR = isset($jZIYt["path"]) ? explode("/", trim($jZIYt["path"], "/")) : []; goto xdvrY; JInv_: if (!isset($FBRGm["auto_setup"])) { goto lsAN2; } goto Xav20; k0lqm: $YgMwr = $FBRGm["queues"]; goto O_xkr; XGp_K: $YgMwr = array_map(function ($ORjji) { goto dgcpq; D16w1: if (!\is_array($ORjji["arguments"] ?? false)) { goto Ohw1L; } goto aMxjv; aMxjv: $ORjji["arguments"] = bR_Fb::RGUxi($ORjji["arguments"]); goto nzmK_; dgcpq: if (\is_array($ORjji)) { goto YTRL5; } goto nO0Z_; gx4ee: YTRL5: goto D16w1; poPcO: return $ORjji; goto trvgK; nzmK_: Ohw1L: goto poPcO; nO0Z_: $ORjji = []; goto gx4ee; trvgK: }, $YgMwr); goto GnOJ2; r01XA: $DHf4j = str_starts_with($YJYm5, "amqps://"); goto Wp685; dfC1u: if (!isset($jZIYt["user"])) { goto pQwrm; } goto whKQ3; LesXH: eYftd: goto V62yx; mzU8E: if (\in_array($YJYm5, ["amqp://", "amqps://"])) { goto txGFj; } goto t1maj; fj1VO: unset($FBRGm["cacert"], $FBRGm["cert"], $FBRGm["key"], $FBRGm["verify"]); goto TLi2m; ywf4B: txGFj: goto AqH73; no_4L: if (!($DHf4j && !Br_FB::Sdu1h($FBRGm))) { goto NchvE; } goto evlkm; xdvrY: $j8txZ = $BC0cR[1] ?? "messages"; goto EWckY; SgRil: NchvE: goto UvvGY; ASe2Z: if (!isset($jZIYt["pass"])) { goto eIXjX; } goto Cm2jx; OlltW: if (isset($FBRGm["queues"])) { goto eYftd; } goto yHweM; yHweM: $FBRGm["queues"][$j8txZ] = []; goto LesXH; V62yx: $pNusd = $FBRGm["exchange"]; goto k0lqm; TLi2m: JKcqs: goto no_4L; j9TG1: } private static function eaM3_(array $tafGL) : void { goto sdAkA; jDXdc: throw new LogicException(sprintf("Invalid exchange option(s) "%s" passed to the AMQP Messenger transport.", implode("", "", $O0tBV))); goto n9iuz; FL_vW: RONoF: goto fLjj3; uhafC: if (!\is_array($tafGL["queues"] ?? false)) { goto YQ5FO; } goto izB7m; n9iuz: krSx1: goto tbHii; izB7m: foreach ($tafGL["queues"] as $qNJgw) { goto jl4aJ; QqKP1: throw new LogicException(sprintf("Invalid queue option(s) "%s" passed to the AMQP Messenger transport.", implode("", "", $m4SBt))); goto hDMQO; wOsnx: DJq3Z: goto IgA_q; F3Bwj: gn5PJ: goto Q9OAd; IgA_q: if (!(0 < \count($m4SBt = array_diff(array_keys($qNJgw), bR_fb::HZ3Zy)))) { goto TVQWO; } goto QqKP1; jl4aJ: if (\is_array($qNJgw)) { goto DJq3Z; } goto j1Nhs; j1Nhs: goto gn5PJ; goto wOsnx; hDMQO: TVQWO: goto F3Bwj; Q9OAd: } goto FL_vW; OhX71: throw new LogicException(sprintf("Invalid option(s) "%s" passed to the AMQP Messenger transport.", implode("", "", $F5my1))); goto KR7pp; sdAkA: if (!(0 < \count($F5my1 = array_diff(array_keys($tafGL), bR_fB::xUyeu)))) { goto YDAwv; } goto OhX71; KR7pp: YDAwv: goto uhafC; nEJMC: if (!(\is_array($tafGL["exchange"] ?? false) && 0 < \count($O0tBV = array_diff(array_keys($tafGL["exchange"]), bR_fb::uD2_B)))) { goto krSx1; } goto jDXdc; fLjj3: YQ5FO: goto nEJMC; tbHii: } private static function rGUXI(array $ukf5F) : array { goto jzjoY; jzjoY: foreach (bR_fB::E5l_W as $GuFmK) { goto kISDA; UOK6L: HJ1M3: goto jXrNk; eDS0s: y5l6x: goto kXv6A; hsjbQ: throw new InvalidArgumentException(sprintf("Integer expected for queue argument "%s", "%s" given.", $GuFmK, get_debug_type($ukf5F[$GuFmK]))); goto S3hJD; im8FQ: $ukf5F[$GuFmK] = (int) $ukf5F[$GuFmK]; goto UOK6L; kXv6A: if (is_numeric($ukf5F[$GuFmK])) { goto hSuGj; } goto hsjbQ; S3hJD: hSuGj: goto im8FQ; ELJ7i: goto HJ1M3; goto eDS0s; kISDA: if (\array_key_exists($GuFmK, $ukf5F)) { goto y5l6x; } goto ELJ7i; jXrNk: } goto QVtuI; QVtuI: QjOhR: goto f25Ma; f25Ma: return $ukf5F; goto N0QvI; N0QvI: } private static function sDu1H(array $FBRGm) : bool { return isset($FBRGm["cacert"]) && '' !== $FBRGm["cacert"] || '' !== \ini_get("amqp.cacert"); } public function z84u_(string $sLamJ, array $yUNSd = [], int $foDAt = 0, ?AmqpStamp $N2kIq = null) : void { goto x4DNq; PJq2D: rfo9V: goto dQ_A0; x4DNq: $this->gXyYt(); goto Dr5FN; DEIIE: $this->gWPuP(); goto PJq2D; dQ_A0: $this->c0Qte(function () use($sLamJ, $yUNSd, $foDAt, $N2kIq) { goto BzqXk; hKpOo: return; goto tMYK_; tMYK_: Y_2NS: goto mpxks; BzqXk: if (!(0 !== $foDAt)) { goto Y_2NS; } goto lR2OR; lR2OR: $this->kPTTM($sLamJ, $yUNSd, $foDAt, $N2kIq); goto hKpOo; mpxks: $this->GCkQh($this->R0zZc(), $sLamJ, $this->mUgau($N2kIq), $yUNSd, $N2kIq); goto MATw7; MATw7: }); goto nEbpO; Dr5FN: if (!$this->HqnaV) { goto rfo9V; } goto DEIIE; nEbpO: } public function p3uSl() : int { return array_sum(array_map(fn($I1vwJ) => $this->iBNtf($I1vwJ)->dlnnp(), $this->ExExP())); } private function kPtTM(string $sLamJ, array $yUNSd, int $mFEaW, ?AmqpStamp $N2kIq = null) : void { goto fY7Ff; iACa8: $this->Zn_fW($mFEaW, $hSfgq, $j0wVR); goto BGIbJ; fY7Ff: $hSfgq = $this->MUgAU($N2kIq); goto JRENP; BGIbJ: $this->gCKqH($this->caShB(), $sLamJ, $this->Lnnfg($mFEaW, $hSfgq, $j0wVR), $yUNSd, $N2kIq); goto WP3J1; JRENP: $j0wVR = $N2kIq ? $N2kIq->Qm6jM() : false; goto iACa8; WP3J1: } private function gCkqh(\UMD8p $lmlYY, string $sLamJ, ?string $hSfgq = null, array $yUNSd = [], ?AmqpStamp $N2kIq = null) : void { goto l6syv; qOWbL: $nG7Mg["timestamp"] ??= time(); goto NpDIb; aZr_h: $this->dMNAH()->KMQ7a((float) $this->CMea3["confirm_timeout"]); goto UfSQg; UfSQg: JHvpb: goto cvWlk; SgR_F: if (!('' !== ($this->CMea3["confirm_timeout"] ?? ''))) { goto JHvpb; } goto aZr_h; NpDIb: $this->rURfm = time(); goto oLzDZ; oLzDZ: $lmlYY->Z84U_($sLamJ, $hSfgq, $N2kIq ? $N2kIq->getFlags() : \coUJw, $nG7Mg); goto SgR_F; l6syv: $nG7Mg = $N2kIq ? $N2kIq->getAttributes() : []; goto JUOox; JUOox: $nG7Mg["headers"] = array_merge($nG7Mg["headers"] ?? [], $yUNSd); goto C1079; C1079: $nG7Mg["delivery_mode"] ??= 2; goto qOWbL; cvWlk: } private function Zn_FW(int $mFEaW, ?string $hSfgq, bool $j0wVR) : void { goto FLQ0D; IWKKD: $this->e9NUh(); goto SU87c; Lh14w: $qNJgw->DlNnp(); goto bpw0z; ir3eT: $qNJgw = $this->QQnhD($mFEaW, $hSfgq, $j0wVR); goto Lh14w; SU87c: U1ewP: goto ir3eT; bpw0z: $qNJgw->bind($this->CMea3["delay"]["exchange_name"], $this->LNnfG($mFEaW, $hSfgq, $j0wVR)); goto iDxxZ; FLQ0D: if (!$this->BKTGv) { goto U1ewP; } goto IWKKD; iDxxZ: } private function cASHb() : \AMQPExchange { goto j1zwI; Smnwc: $this->CSnXL->setType(\iLFPj); goto s8J1d; s8J1d: $this->CSnXL->setFlags(\JiDE3); goto N4qvI; RkYio: return $this->CSnXL; goto RPt01; j1zwI: if (isset($this->CSnXL)) { goto H2uKX; } goto QxXwL; ZkON6: $this->CSnXL->MvxVE($this->CMea3["delay"]["exchange_name"]); goto Smnwc; QxXwL: $this->CSnXL = $this->OlSwv->Z82t9($this->dMnAh()); goto ZkON6; N4qvI: H2uKX: goto RkYio; RPt01: } private function qQnHd(int $mFEaW, ?string $hSfgq, bool $j0wVR) : \AMQPQueue { goto Lti3m; Lti3m: $qNJgw = $this->OlSwv->KKWcR($this->DmNAh()); goto in46a; bgOvY: $qNJgw->setFlags(\JiDE3); goto cgcT2; in46a: $qNJgw->MVXve($this->lNnFg($mFEaW, $hSfgq, $j0wVR)); goto bgOvY; jKQLR: return $qNJgw; goto MRm82; cgcT2: $qNJgw->kIvCH(array_merge(["x-message-ttl" => $mFEaW, "x-expires" => $mFEaW + 10000, "x-dead-letter-exchange" => $j0wVR ? '' : $this->eN44Y["name"], "x-dead-letter-routing-key" => $hSfgq ?? ''], $this->CMea3["delay"]["arguments"] ?? [])); goto jKQLR; MRm82: } private function LnNFG(int $mFEaW, ?string $XjBWY, bool $j0wVR) : string { $PtEx6 = $j0wVR ? "_retry" : "_delay"; return str_replace(["%delay%", "%exchange_name%", "%routing_key%"], [$mFEaW, $this->eN44Y["name"], $XjBWY ?? ''], $this->CMea3["delay"]["queue_name_pattern"]) . $PtEx6; } public function get(string $I1vwJ) : ?\AMQPEnvelope { goto Jp0pa; rkluK: AgMVm: goto wVVe6; Jp0pa: $this->GxYyt(); goto t716n; R6I8Z: return null; goto Aa53Z; wVVe6: if (!(false !== ($cc2RO = $this->ibNTF($I1vwJ)->get()))) { goto v5hS3; } goto EDTfb; EDTfb: return $cc2RO; goto Y2KDn; t716n: if (!$this->HqnaV) { goto AgMVm; } goto ix5y5; ix5y5: $this->gWPup(); goto rkluK; Y2KDn: v5hS3: goto R6I8Z; Aa53Z: } public function vKhAE(\MZ4fB $cc2RO, string $I1vwJ) : bool { return $this->IBNtf($I1vwJ)->vkhAE($cc2RO->IWki_()) ?? true; } public function jBbI8(\MZ4FB $cc2RO, string $I1vwJ, int $ZzGz6 = \coUJw) : bool { return $this->ibntf($I1vwJ)->jBbi8($cc2RO->IwKi_(), $ZzGz6) ?? true; } public function VIqrQ() : void { $this->GwPUp(); $this->e9NUH(); } private function gWPuP() : void { goto eNQLo; DIoqW: $this->HqnaV = false; goto QUG46; ZIMs8: Q7Pty: goto DIoqW; eNQLo: $this->R0ZzC()->jt4fy(); goto cobkx; cobkx: foreach ($this->mn60e as $I1vwJ => $T2tiy) { goto MSP1o; orfGo: uwLUz: goto N1xgM; iD06M: foreach ($T2tiy["binding_keys"] ?? [null] as $PpM0B) { $this->ibNtf($I1vwJ)->bind($this->eN44Y["name"], $PpM0B, $T2tiy["binding_arguments"] ?? []); KO1rb: } goto n33lj; MSP1o: $this->IbNTF($I1vwJ)->dlNNP(); goto iD06M; n33lj: xSd5R: goto orfGo; N1xgM: } goto ZIMs8; QUG46: } private function e9nuH() : void { $this->CAShb()->jT4fY(); $this->BKTGv = false; } public function exExP() : array { return array_keys($this->mn60e); } public function dMnah() : \AMQPChannel { goto pdrSZ; gQ4f3: $this->ltrrV = $this->OlSwv->j8e4U($J81Xq); goto KezKg; Q_rEO: if (0 < ($this->CMea3["heartbeat"] ?? 0) && time() > $this->rURfm + 2 * $this->CMea3["heartbeat"]) { goto sTtBg; } goto gKIRu; gKIRu: goto FCoFs; goto deyP2; pUY_i: try { $J81Xq->{$ThLNy}(); } catch (\HK_qL $eVwLO) { throw new \hn0hT("Could not connect to the AMQP server. Please verify the provided DSN.", 0, $eVwLO); } goto gQ4f3; pdrSZ: if (!isset($this->ltrrV)) { goto jo30H; } goto Q_rEO; eS6gJ: $this->ltrrV->WmCKg()->{$Voewm}(); goto vihNP; bPWEY: $this->ltrrV->YC8oW(static fn(): bool => false, static fn() => throw new JYL2W("Message publication failed due to a negative acknowledgment (nack) from the broker.")); goto uKEj4; tONZD: $J81Xq = $this->OlSwv->AF6Nz($this->CMea3); goto DFL5p; vihNP: FCoFs: goto xp7o4; kJzR8: $this->ltrrV->vkUyF(); goto bPWEY; D4Zsn: goto FCoFs; goto eNLt_; fqtFa: $Voewm = "true" === ($this->CMea3["persistent"] ?? "false") ? "pdisconnect" : "disconnect"; goto eS6gJ; uKEj4: f1bQL: goto Tk6CP; deyP2: jo30H: goto tONZD; xp7o4: return $this->ltrrV; goto IPFsS; Tk6CP: $this->rURfm = time(); goto D4Zsn; KezKg: if (!('' !== ($this->CMea3["confirm_timeout"] ?? ''))) { goto f1bQL; } goto kJzR8; DFL5p: $ThLNy = "true" === ($this->CMea3["persistent"] ?? "false") ? "pconnect" : "connect"; goto pUY_i; eNLt_: sTtBg: goto fqtFa; IPFsS: } public function ibnTf(string $I1vwJ) : \AMQPQueue { goto v1pq2; cd9RM: $sguol->mvxVE($I1vwJ); goto iAie4; v1pq2: if (isset($this->dWNnO[$I1vwJ])) { goto RdNFZ; } goto CkdbU; nacWe: p2Y37: goto S3wRd; S3wRd: $this->dWNnO[$I1vwJ] = $sguol; goto wD6A5; hbvYP: return $this->dWNnO[$I1vwJ]; goto bwXlR; wD6A5: RdNFZ: goto hbvYP; pExFh: if (!isset($T2tiy["arguments"])) { goto p2Y37; } goto gmvpd; MDJoJ: $sguol = $this->OlSwv->kKWcr($this->dmNAH()); goto cd9RM; iAie4: $sguol->setFlags($T2tiy["flags"] ?? \JiDE3); goto pExFh; gmvpd: $sguol->KIVCh($T2tiy["arguments"]); goto nacWe; CkdbU: $T2tiy = $this->mn60e[$I1vwJ] ?? []; goto MDJoJ; bwXlR: } public function r0Zzc() : \AMQPExchange { goto iWWk6; oU2qV: DnJ2I: goto OHELJ; ZfGj8: if (!isset($this->eN44Y["arguments"])) { goto tdtMB; } goto T0kn4; rlSs8: $this->NwGSo->setType($this->eN44Y["type"] ?? \fdp_k); goto bgcCk; YU2fA: $this->NwGSo = $this->OlSwv->Z82t9($this->DMNAh()); goto fGPx2; OHELJ: return $this->NwGSo; goto UKniX; iWWk6: if (isset($this->NwGSo)) { goto DnJ2I; } goto YU2fA; fGPx2: $this->NwGSo->mvxvE($this->eN44Y["name"]); goto rlSs8; T0kn4: $this->NwGSo->KIvcH($this->eN44Y["arguments"]); goto uKCzT; bgcCk: $this->NwGSo->setFlags($this->eN44Y["flags"] ?? \JiDE3); goto ZfGj8; uKCzT: tdtMB: goto oU2qV; UKniX: } private function GXyyt() : void { goto UxaEJ; LP8pB: $this->UtZ8S(); goto rq1gN; UxaEJ: if ($this->dMNAh()->Lzh47()) { goto eM0m3; } goto LP8pB; rq1gN: eM0m3: goto D2KZQ; D2KZQ: } private function UTZ8s() : void { unset($this->ltrrV, $this->NwGSo, $this->CSnXL); $this->dWNnO = []; } private function srInY() : ?string { return $this->eN44Y["default_publish_routing_key"] ?? null; } public function AoC8b() : void { foreach ($this->exeXP() as $I1vwJ) { $this->IbnTf($I1vwJ)->BqJyl(); jCmZd: } SlKwe: } private function MUgAU(?AmqpStamp $N2kIq) : ?string { return $N2kIq?->getRoutingKey() ?? $this->SrinY(); } private function C0Qte(callable $UHshO) : void { goto CG_mY; jHmgC: retry: goto vgbtI; Xe6a2: $O2ktm = 0; goto jHmgC; CG_mY: $Z14TX = 3; goto Xe6a2; vgbtI: try { $UHshO(); } catch (\hK_ql $eVwLO) { goto WX1Zt; Um2ks: PnCCz: goto ddpHf; ddpHf: throw $eVwLO; goto B_kBu; WX1Zt: if (!(++$O2ktm <= $Z14TX)) { goto PnCCz; } goto qnfs0; dCpX3: goto retry; goto Um2ks; qnfs0: $this->utz8S(); goto dCpX3; B_kBu: } goto Cpolv; Cpolv: } } ?>

Did this file decode correctly?

Original Code

<?php
 namespace cG9jr\e4h94\QVRli\vdEfy\ODFNv\SIZ1R; use CG9Jr\e4H94\QVrLi\Exception\InvalidArgumentException; use cg9jr\e4h94\QVrlI\Exception\LogicException; use Cg9jr\e4h94\qVRLi\Exception\jyl2W; class XyUb1 { private const E5l_W = ["\x78\55\x64\x65\x6c\x61\x79", "\x78\x2d\145\x78\x70\x69\162\145\163", "\x78\x2d\x6d\141\x78\55\154\145\x6e\147\164\150", "\170\x2d\x6d\141\170\55\154\x65\x6e\147\164\x68\x2d\x62\171\x74\x65\x73", "\170\x2d\155\x61\x78\x2d\160\162\x69\x6f\162\x69\164\x79", "\x78\55\155\x65\x73\x73\x61\x67\x65\55\x74\164\x6c"]; private const xUyeu = ["\x68\157\163\x74", "\x70\x6f\162\x74", "\166\x68\x6f\x73\164", "\x75\163\x65\x72", "\154\157\x67\x69\156", "\160\141\163\x73\167\157\x72\x64", "\161\x75\145\x75\145\x73", "\145\170\x63\150\x61\156\147\145", "\x64\145\x6c\141\x79", "\141\165\x74\157\137\163\145\164\165\x70", "\162\145\x74\x72\x79", "\x70\145\162\x73\151\x73\164\x65\x6e\164", "\x66\162\x61\x6d\145\x5f\155\141\x78", "\143\x68\141\x6e\156\x65\x6c\137\x6d\x61\170", "\150\x65\141\x72\x74\142\x65\x61\x74", "\162\x65\x61\144\137\x74\x69\155\x65\157\165\x74", "\167\x72\151\164\x65\137\164\151\x6d\145\157\165\x74", "\x63\157\x6e\x66\x69\x72\155\x5f\164\x69\x6d\x65\x6f\165\164", "\143\157\x6e\x6e\145\x63\164\x5f\164\151\155\x65\x6f\165\164", "\x72\160\143\x5f\164\151\x6d\x65\157\165\x74", "\x63\x61\143\145\162\164", "\143\x65\162\x74", "\153\x65\171", "\x76\x65\x72\151\146\x79", "\163\141\x73\x6c\x5f\155\145\164\150\x6f\144", "\143\x6f\156\x6e\x65\x63\164\151\157\x6e\137\156\141\x6d\x65"]; private const HZ3Zy = ["\x62\151\156\144\151\156\147\137\153\x65\171\x73", "\x62\151\156\144\x69\x6e\x67\x5f\141\162\x67\165\155\145\x6e\164\163", "\x66\154\141\147\163", "\x61\162\147\x75\155\x65\x6e\164\163"]; private const uD2_B = ["\x6e\x61\155\x65", "\x74\x79\160\145", "\144\145\x66\141\165\x6c\x74\x5f\160\x75\142\x6c\x69\163\150\x5f\162\157\x75\x74\151\156\147\137\153\x65\171", "\146\154\141\x67\x73", "\141\x72\147\x75\155\145\x6e\x74\163"]; private AmqpFactory $OlSwv; private mixed $HqnaV; private mixed $BKTGv; private \AMQPChannel $ltrrV; private \AMQPExchange $NwGSo; private array $dWNnO = []; private \AMQPExchange $CSnXL; private int $rURfm = 0; public function __construct(#[\SensitiveParameter] private array $apJsK, private array $pNusd, private array $YgMwr, ?AmqpFactory $SMW_0 = null) { goto JhbTr; rWB2J: gk_xA: goto Jj8f2; JhbTr: if (\extension_loaded("\x61\x6d\161\160")) { goto gk_xA; } goto EZAfG; Jj8f2: $this->CMea3 = array_replace_recursive(["\144\145\154\x61\171" => ["\x65\170\143\150\141\156\x67\145\x5f\156\141\x6d\x65" => "\144\145\x6c\x61\171\x73", "\x71\x75\145\165\x65\x5f\x6e\x61\155\x65\137\x70\141\x74\164\145\x72\156" => "\144\x65\x6c\141\x79\x5f\45\x65\170\143\x68\x61\156\147\145\x5f\156\x61\155\145\45\x5f\x25\162\x6f\165\x74\x69\x6e\147\137\x6b\x65\171\45\x5f\x25\x64\x65\x6c\x61\171\45"]], $apJsK); goto AAVIs; vQiGJ: $this->OlSwv = $SMW_0 ?? new DWs9g(); goto QoK03; EZAfG: throw new LogicException(sprintf("\131\x6f\165\40\143\141\x6e\x6e\157\x74\40\x75\163\145\40\164\x68\x65\x20\42\x25\163\x22\x20\x61\163\x20\x74\x68\x65\40\42\141\x6d\x71\160\x22\x20\x65\x78\164\x65\156\x73\x69\x6f\156\40\x69\163\40\156\157\x74\x20\x69\x6e\x73\x74\141\x6c\154\145\144\x2e", __CLASS__)); goto rWB2J; AAVIs: $this->HqnaV = $this->BKTGv = $apJsK["\x61\165\164\157\137\163\x65\x74\x75\x70"] ?? true; goto vQiGJ; QoK03: } public static function J6Gjw(#[\SensitiveParameter] string $YJYm5, array $tafGL = [], ?AmqpFactory $SMW_0 = null) : self { goto RfBbI; Aijkn: lsAN2: goto XGp_K; Cm2jx: $FBRGm["\160\141\x73\163\x77\157\x72\x64"] = rawurldecode($jZIYt["\x70\141\x73\x73"]); goto oRwZ3; t1maj: throw new InvalidArgumentException("\124\150\145\x20\x67\151\x76\x65\x6e\40\101\x4d\x51\x50\x20\x44\123\116\40\x69\163\40\151\156\x76\x61\x6c\x69\x64\56"); goto ywf4B; evlkm: throw new InvalidArgumentException("\116\x6f\40\103\101\x20\x63\145\x72\164\151\146\x69\143\x61\x74\145\40\x68\141\163\x20\142\x65\145\156\40\160\x72\157\x76\x69\144\x65\x64\x2e\40\123\x65\x74\x20\x22\x61\155\161\x70\56\x63\x61\143\145\162\164\42\x20\151\156\x20\171\x6f\165\162\x20\x70\150\x70\x2e\x69\156\x69\40\x6f\162\40\160\x61\163\163\40\164\150\x65\40\x22\x63\141\143\x65\162\164\x22\x20\160\141\x72\141\x6d\x65\x74\145\x72\40\151\x6e\40\164\x68\x65\x20\x44\123\116\x20\164\x6f\40\x75\x73\145\40\x53\x53\x4c\56\x20\x41\154\x74\145\x72\x6e\x61\164\x69\166\145\x6c\x79\x2c\40\171\157\x75\40\143\x61\x6e\40\x75\x73\x65\40\141\155\161\x70\x3a\x2f\x2f\x20\x74\x6f\40\x75\163\145\x20\x77\x69\164\150\157\165\x74\x20\x53\x53\114\56"); goto SgRil; oRwZ3: eIXjX: goto OlltW; AqH73: $jZIYt = []; goto lvGpJ; O_xkr: unset($FBRGm["\161\x75\x65\165\145\163"], $FBRGm["\145\x78\143\x68\x61\156\x67\145"]); goto JInv_; UvvGY: return new Br_fb($FBRGm, $pNusd, $YgMwr, $SMW_0); goto j9TG1; SlhZI: BR_fb::EAm3_($FBRGm); goto dfC1u; Xav20: $FBRGm["\141\165\x74\x6f\137\163\145\164\165\x70"] = filter_var($FBRGm["\141\x75\x74\x6f\137\x73\x65\164\165\160"], \FILTER_VALIDATE_BOOL); goto Aijkn; Oay1g: pQwrm: goto ASe2Z; gx47O: $tchlg = $DHf4j ? 5671 : 5672; goto ojSa2; whKQ3: $FBRGm["\154\x6f\147\151\x6e"] = rawurldecode($jZIYt["\x75\163\145\162"]); goto Oay1g; GnOJ2: if ($DHf4j) { goto JKcqs; } goto fj1VO; RfBbI: if (!(false === ($jZIYt = parse_url($YJYm5)))) { goto vUUgQ; } goto mzU8E; EWckY: parse_str($jZIYt["\161\x75\x65\162\x79"] ?? '', $yhxfE); goto gx47O; lvGpJ: vUUgQ: goto r01XA; ojSa2: $FBRGm = array_replace_recursive(["\x68\157\x73\164" => $jZIYt["\x68\157\x73\x74"] ?? "\154\x6f\143\x61\154\x68\157\x73\164", "\160\x6f\162\x74" => $jZIYt["\x70\157\x72\164"] ?? $tchlg, "\x76\x68\x6f\x73\164" => isset($BC0cR[0]) ? urldecode($BC0cR[0]) : "\57", "\x65\170\x63\150\x61\x6e\x67\x65" => ["\156\141\155\145" => $j8txZ]], $tafGL, $yhxfE); goto SlhZI; Wp685: $BC0cR = isset($jZIYt["\x70\141\164\x68"]) ? explode("\57", trim($jZIYt["\x70\x61\164\150"], "\x2f")) : []; goto xdvrY; JInv_: if (!isset($FBRGm["\x61\165\164\x6f\x5f\163\x65\x74\165\x70"])) { goto lsAN2; } goto Xav20; k0lqm: $YgMwr = $FBRGm["\161\165\x65\165\x65\x73"]; goto O_xkr; XGp_K: $YgMwr = array_map(function ($ORjji) { goto dgcpq; D16w1: if (!\is_array($ORjji["\141\x72\147\x75\x6d\145\156\x74\163"] ?? false)) { goto Ohw1L; } goto aMxjv; aMxjv: $ORjji["\x61\162\x67\165\x6d\145\156\x74\163"] = bR_Fb::RGUxi($ORjji["\141\162\x67\x75\155\x65\x6e\x74\x73"]); goto nzmK_; dgcpq: if (\is_array($ORjji)) { goto YTRL5; } goto nO0Z_; gx4ee: YTRL5: goto D16w1; poPcO: return $ORjji; goto trvgK; nzmK_: Ohw1L: goto poPcO; nO0Z_: $ORjji = []; goto gx4ee; trvgK: }, $YgMwr); goto GnOJ2; r01XA: $DHf4j = str_starts_with($YJYm5, "\x61\x6d\161\160\163\72\x2f\x2f"); goto Wp685; dfC1u: if (!isset($jZIYt["\x75\163\x65\162"])) { goto pQwrm; } goto whKQ3; LesXH: eYftd: goto V62yx; mzU8E: if (\in_array($YJYm5, ["\141\155\161\x70\72\x2f\x2f", "\141\x6d\x71\160\x73\72\57\57"])) { goto txGFj; } goto t1maj; fj1VO: unset($FBRGm["\x63\141\x63\x65\162\164"], $FBRGm["\143\145\x72\x74"], $FBRGm["\153\145\171"], $FBRGm["\x76\145\162\151\x66\171"]); goto TLi2m; ywf4B: txGFj: goto AqH73; no_4L: if (!($DHf4j && !Br_FB::Sdu1h($FBRGm))) { goto NchvE; } goto evlkm; xdvrY: $j8txZ = $BC0cR[1] ?? "\155\145\163\163\x61\x67\145\163"; goto EWckY; SgRil: NchvE: goto UvvGY; ASe2Z: if (!isset($jZIYt["\x70\x61\163\x73"])) { goto eIXjX; } goto Cm2jx; OlltW: if (isset($FBRGm["\161\165\x65\165\x65\x73"])) { goto eYftd; } goto yHweM; yHweM: $FBRGm["\161\165\145\x75\145\163"][$j8txZ] = []; goto LesXH; V62yx: $pNusd = $FBRGm["\145\x78\143\150\x61\156\147\x65"]; goto k0lqm; TLi2m: JKcqs: goto no_4L; j9TG1: } private static function eaM3_(array $tafGL) : void { goto sdAkA; jDXdc: throw new LogicException(sprintf("\111\156\x76\141\154\x69\144\x20\x65\170\x63\x68\x61\x6e\147\145\x20\x6f\160\x74\151\157\x6e\50\x73\51\x20\42\x25\163\42\x20\160\141\x73\163\145\x64\x20\x74\157\40\x74\x68\145\x20\x41\115\121\120\x20\115\145\x73\x73\145\x6e\147\x65\x72\40\164\162\x61\x6e\x73\160\x6f\x72\x74\56", implode("\x22\x2c\x20\x22", $O0tBV))); goto n9iuz; FL_vW: RONoF: goto fLjj3; uhafC: if (!\is_array($tafGL["\x71\165\x65\165\x65\x73"] ?? false)) { goto YQ5FO; } goto izB7m; n9iuz: krSx1: goto tbHii; izB7m: foreach ($tafGL["\x71\x75\x65\x75\145\x73"] as $qNJgw) { goto jl4aJ; QqKP1: throw new LogicException(sprintf("\x49\x6e\x76\x61\x6c\151\x64\40\161\165\145\x75\145\40\x6f\x70\164\151\x6f\156\50\x73\x29\x20\42\45\x73\42\40\x70\141\163\x73\145\144\40\x74\x6f\40\x74\x68\145\40\101\115\121\x50\40\115\145\x73\163\145\156\x67\145\162\x20\164\x72\141\x6e\x73\160\x6f\162\164\56", implode("\x22\54\x20\42", $m4SBt))); goto hDMQO; wOsnx: DJq3Z: goto IgA_q; F3Bwj: gn5PJ: goto Q9OAd; IgA_q: if (!(0 < \count($m4SBt = array_diff(array_keys($qNJgw), bR_fb::HZ3Zy)))) { goto TVQWO; } goto QqKP1; jl4aJ: if (\is_array($qNJgw)) { goto DJq3Z; } goto j1Nhs; j1Nhs: goto gn5PJ; goto wOsnx; hDMQO: TVQWO: goto F3Bwj; Q9OAd: } goto FL_vW; OhX71: throw new LogicException(sprintf("\111\x6e\x76\141\x6c\151\144\40\157\x70\164\x69\x6f\156\50\x73\x29\x20\42\45\x73\42\x20\x70\x61\163\163\145\144\40\x74\157\40\164\x68\145\x20\101\x4d\x51\x50\40\115\x65\x73\163\x65\156\x67\x65\162\40\164\x72\141\x6e\163\160\157\x72\x74\x2e", implode("\42\54\40\x22", $F5my1))); goto KR7pp; sdAkA: if (!(0 < \count($F5my1 = array_diff(array_keys($tafGL), bR_fB::xUyeu)))) { goto YDAwv; } goto OhX71; KR7pp: YDAwv: goto uhafC; nEJMC: if (!(\is_array($tafGL["\145\170\x63\x68\141\x6e\x67\x65"] ?? false) && 0 < \count($O0tBV = array_diff(array_keys($tafGL["\x65\x78\143\x68\141\156\147\x65"]), bR_fb::uD2_B)))) { goto krSx1; } goto jDXdc; fLjj3: YQ5FO: goto nEJMC; tbHii: } private static function rGUXI(array $ukf5F) : array { goto jzjoY; jzjoY: foreach (bR_fB::E5l_W as $GuFmK) { goto kISDA; UOK6L: HJ1M3: goto jXrNk; eDS0s: y5l6x: goto kXv6A; hsjbQ: throw new InvalidArgumentException(sprintf("\111\x6e\164\145\x67\145\x72\40\145\x78\x70\x65\x63\164\x65\144\x20\x66\x6f\162\40\x71\165\x65\165\145\x20\x61\x72\x67\165\x6d\x65\156\164\40\x22\x25\x73\42\54\x20\42\45\163\42\x20\x67\x69\166\145\x6e\56", $GuFmK, get_debug_type($ukf5F[$GuFmK]))); goto S3hJD; im8FQ: $ukf5F[$GuFmK] = (int) $ukf5F[$GuFmK]; goto UOK6L; kXv6A: if (is_numeric($ukf5F[$GuFmK])) { goto hSuGj; } goto hsjbQ; S3hJD: hSuGj: goto im8FQ; ELJ7i: goto HJ1M3; goto eDS0s; kISDA: if (\array_key_exists($GuFmK, $ukf5F)) { goto y5l6x; } goto ELJ7i; jXrNk: } goto QVtuI; QVtuI: QjOhR: goto f25Ma; f25Ma: return $ukf5F; goto N0QvI; N0QvI: } private static function sDu1H(array $FBRGm) : bool { return isset($FBRGm["\x63\x61\143\x65\x72\x74"]) && '' !== $FBRGm["\x63\141\143\x65\162\x74"] || '' !== \ini_get("\141\155\161\x70\x2e\143\141\x63\145\x72\x74"); } public function z84u_(string $sLamJ, array $yUNSd = [], int $foDAt = 0, ?AmqpStamp $N2kIq = null) : void { goto x4DNq; PJq2D: rfo9V: goto dQ_A0; x4DNq: $this->gXyYt(); goto Dr5FN; DEIIE: $this->gWPuP(); goto PJq2D; dQ_A0: $this->c0Qte(function () use($sLamJ, $yUNSd, $foDAt, $N2kIq) { goto BzqXk; hKpOo: return; goto tMYK_; tMYK_: Y_2NS: goto mpxks; BzqXk: if (!(0 !== $foDAt)) { goto Y_2NS; } goto lR2OR; lR2OR: $this->kPTTM($sLamJ, $yUNSd, $foDAt, $N2kIq); goto hKpOo; mpxks: $this->GCkQh($this->R0zZc(), $sLamJ, $this->mUgau($N2kIq), $yUNSd, $N2kIq); goto MATw7; MATw7: }); goto nEbpO; Dr5FN: if (!$this->HqnaV) { goto rfo9V; } goto DEIIE; nEbpO: } public function p3uSl() : int { return array_sum(array_map(fn($I1vwJ) => $this->iBNtf($I1vwJ)->dlnnp(), $this->ExExP())); } private function kPtTM(string $sLamJ, array $yUNSd, int $mFEaW, ?AmqpStamp $N2kIq = null) : void { goto fY7Ff; iACa8: $this->Zn_fW($mFEaW, $hSfgq, $j0wVR); goto BGIbJ; fY7Ff: $hSfgq = $this->MUgAU($N2kIq); goto JRENP; BGIbJ: $this->gCKqH($this->caShB(), $sLamJ, $this->Lnnfg($mFEaW, $hSfgq, $j0wVR), $yUNSd, $N2kIq); goto WP3J1; JRENP: $j0wVR = $N2kIq ? $N2kIq->Qm6jM() : false; goto iACa8; WP3J1: } private function gCkqh(\UMD8p $lmlYY, string $sLamJ, ?string $hSfgq = null, array $yUNSd = [], ?AmqpStamp $N2kIq = null) : void { goto l6syv; qOWbL: $nG7Mg["\164\151\x6d\145\x73\x74\x61\x6d\160"] ??= time(); goto NpDIb; aZr_h: $this->dMNAH()->KMQ7a((float) $this->CMea3["\x63\x6f\156\x66\151\x72\x6d\x5f\164\x69\155\x65\x6f\x75\x74"]); goto UfSQg; UfSQg: JHvpb: goto cvWlk; SgR_F: if (!('' !== ($this->CMea3["\x63\x6f\156\x66\151\162\x6d\x5f\x74\151\155\145\157\165\164"] ?? ''))) { goto JHvpb; } goto aZr_h; NpDIb: $this->rURfm = time(); goto oLzDZ; oLzDZ: $lmlYY->Z84U_($sLamJ, $hSfgq, $N2kIq ? $N2kIq->getFlags() : \coUJw, $nG7Mg); goto SgR_F; l6syv: $nG7Mg = $N2kIq ? $N2kIq->getAttributes() : []; goto JUOox; JUOox: $nG7Mg["\x68\x65\141\144\145\162\163"] = array_merge($nG7Mg["\x68\145\141\x64\x65\162\163"] ?? [], $yUNSd); goto C1079; C1079: $nG7Mg["\x64\145\154\x69\x76\x65\162\x79\x5f\155\157\144\x65"] ??= 2; goto qOWbL; cvWlk: } private function Zn_FW(int $mFEaW, ?string $hSfgq, bool $j0wVR) : void { goto FLQ0D; IWKKD: $this->e9NUh(); goto SU87c; Lh14w: $qNJgw->DlNnp(); goto bpw0z; ir3eT: $qNJgw = $this->QQnhD($mFEaW, $hSfgq, $j0wVR); goto Lh14w; SU87c: U1ewP: goto ir3eT; bpw0z: $qNJgw->bind($this->CMea3["\x64\145\154\x61\x79"]["\x65\170\143\150\x61\x6e\x67\145\137\156\x61\155\145"], $this->LNnfG($mFEaW, $hSfgq, $j0wVR)); goto iDxxZ; FLQ0D: if (!$this->BKTGv) { goto U1ewP; } goto IWKKD; iDxxZ: } private function cASHb() : \AMQPExchange { goto j1zwI; Smnwc: $this->CSnXL->setType(\iLFPj); goto s8J1d; s8J1d: $this->CSnXL->setFlags(\JiDE3); goto N4qvI; RkYio: return $this->CSnXL; goto RPt01; j1zwI: if (isset($this->CSnXL)) { goto H2uKX; } goto QxXwL; ZkON6: $this->CSnXL->MvxVE($this->CMea3["\144\x65\x6c\141\x79"]["\x65\170\x63\x68\x61\156\x67\x65\137\x6e\141\x6d\145"]); goto Smnwc; QxXwL: $this->CSnXL = $this->OlSwv->Z82t9($this->dMnAh()); goto ZkON6; N4qvI: H2uKX: goto RkYio; RPt01: } private function qQnHd(int $mFEaW, ?string $hSfgq, bool $j0wVR) : \AMQPQueue { goto Lti3m; Lti3m: $qNJgw = $this->OlSwv->KKWcR($this->DmNAh()); goto in46a; bgOvY: $qNJgw->setFlags(\JiDE3); goto cgcT2; in46a: $qNJgw->MVXve($this->lNnFg($mFEaW, $hSfgq, $j0wVR)); goto bgOvY; jKQLR: return $qNJgw; goto MRm82; cgcT2: $qNJgw->kIvCH(array_merge(["\170\55\155\x65\x73\163\x61\147\145\x2d\x74\164\154" => $mFEaW, "\x78\x2d\x65\x78\x70\151\162\x65\163" => $mFEaW + 10000, "\x78\x2d\144\145\x61\x64\x2d\154\145\x74\164\x65\x72\x2d\x65\x78\x63\150\x61\x6e\x67\145" => $j0wVR ? '' : $this->eN44Y["\156\141\155\145"], "\x78\55\144\145\141\x64\55\154\145\x74\164\x65\162\55\x72\x6f\x75\164\x69\x6e\147\x2d\153\145\x79" => $hSfgq ?? ''], $this->CMea3["\144\145\x6c\141\x79"]["\141\162\147\x75\x6d\x65\x6e\x74\163"] ?? [])); goto jKQLR; MRm82: } private function LnNFG(int $mFEaW, ?string $XjBWY, bool $j0wVR) : string { $PtEx6 = $j0wVR ? "\x5f\x72\145\x74\162\171" : "\x5f\144\x65\154\141\171"; return str_replace(["\x25\144\145\154\x61\171\x25", "\x25\145\x78\x63\150\x61\156\x67\x65\x5f\156\141\x6d\x65\x25", "\x25\x72\157\x75\164\x69\x6e\147\137\153\145\x79\x25"], [$mFEaW, $this->eN44Y["\x6e\141\155\x65"], $XjBWY ?? ''], $this->CMea3["\x64\145\154\141\171"]["\x71\x75\x65\x75\x65\137\156\x61\x6d\145\x5f\160\141\x74\x74\x65\162\x6e"]) . $PtEx6; } public function get(string $I1vwJ) : ?\AMQPEnvelope { goto Jp0pa; rkluK: AgMVm: goto wVVe6; Jp0pa: $this->GxYyt(); goto t716n; R6I8Z: return null; goto Aa53Z; wVVe6: if (!(false !== ($cc2RO = $this->ibNTF($I1vwJ)->get()))) { goto v5hS3; } goto EDTfb; EDTfb: return $cc2RO; goto Y2KDn; t716n: if (!$this->HqnaV) { goto AgMVm; } goto ix5y5; ix5y5: $this->gWPup(); goto rkluK; Y2KDn: v5hS3: goto R6I8Z; Aa53Z: } public function vKhAE(\MZ4fB $cc2RO, string $I1vwJ) : bool { return $this->IBNtf($I1vwJ)->vkhAE($cc2RO->IWki_()) ?? true; } public function jBbI8(\MZ4FB $cc2RO, string $I1vwJ, int $ZzGz6 = \coUJw) : bool { return $this->ibntf($I1vwJ)->jBbi8($cc2RO->IwKi_(), $ZzGz6) ?? true; } public function VIqrQ() : void { $this->GwPUp(); $this->e9NUH(); } private function gWPuP() : void { goto eNQLo; DIoqW: $this->HqnaV = false; goto QUG46; ZIMs8: Q7Pty: goto DIoqW; eNQLo: $this->R0ZzC()->jt4fy(); goto cobkx; cobkx: foreach ($this->mn60e as $I1vwJ => $T2tiy) { goto MSP1o; orfGo: uwLUz: goto N1xgM; iD06M: foreach ($T2tiy["\142\x69\x6e\x64\151\x6e\x67\x5f\153\145\x79\163"] ?? [null] as $PpM0B) { $this->ibNtf($I1vwJ)->bind($this->eN44Y["\x6e\x61\155\x65"], $PpM0B, $T2tiy["\142\151\x6e\144\151\x6e\x67\x5f\x61\x72\147\x75\155\x65\x6e\164\163"] ?? []); KO1rb: } goto n33lj; MSP1o: $this->IbNTF($I1vwJ)->dlNNP(); goto iD06M; n33lj: xSd5R: goto orfGo; N1xgM: } goto ZIMs8; QUG46: } private function e9nuH() : void { $this->CAShb()->jT4fY(); $this->BKTGv = false; } public function exExP() : array { return array_keys($this->mn60e); } public function dMnah() : \AMQPChannel { goto pdrSZ; gQ4f3: $this->ltrrV = $this->OlSwv->j8e4U($J81Xq); goto KezKg; Q_rEO: if (0 < ($this->CMea3["\150\x65\x61\x72\164\x62\145\x61\164"] ?? 0) && time() > $this->rURfm + 2 * $this->CMea3["\150\x65\x61\x72\x74\x62\x65\141\x74"]) { goto sTtBg; } goto gKIRu; gKIRu: goto FCoFs; goto deyP2; pUY_i: try { $J81Xq->{$ThLNy}(); } catch (\HK_qL $eVwLO) { throw new \hn0hT("\103\x6f\x75\154\144\40\156\157\x74\x20\143\x6f\156\156\x65\x63\x74\40\x74\x6f\40\164\150\145\x20\x41\115\x51\x50\40\163\x65\162\166\145\162\56\40\x50\154\x65\x61\163\x65\x20\x76\x65\x72\151\146\171\40\x74\x68\x65\40\x70\162\x6f\166\x69\144\x65\144\40\x44\x53\116\x2e", 0, $eVwLO); } goto gQ4f3; pdrSZ: if (!isset($this->ltrrV)) { goto jo30H; } goto Q_rEO; eS6gJ: $this->ltrrV->WmCKg()->{$Voewm}(); goto vihNP; bPWEY: $this->ltrrV->YC8oW(static fn(): bool => false, static fn() => throw new JYL2W("\115\145\163\x73\x61\147\x65\40\160\x75\142\154\151\x63\x61\164\151\x6f\x6e\40\146\x61\151\x6c\145\144\x20\144\165\145\40\x74\x6f\40\x61\x20\x6e\145\147\x61\x74\x69\166\145\x20\141\x63\x6b\x6e\157\167\154\145\x64\147\155\145\156\164\x20\50\156\141\143\x6b\51\40\x66\x72\157\155\40\x74\x68\x65\x20\142\162\x6f\153\x65\x72\56")); goto uKEj4; tONZD: $J81Xq = $this->OlSwv->AF6Nz($this->CMea3); goto DFL5p; vihNP: FCoFs: goto xp7o4; kJzR8: $this->ltrrV->vkUyF(); goto bPWEY; D4Zsn: goto FCoFs; goto eNLt_; fqtFa: $Voewm = "\164\162\165\145" === ($this->CMea3["\160\x65\162\x73\x69\163\x74\145\156\164"] ?? "\x66\141\x6c\163\x65") ? "\160\x64\151\x73\143\157\x6e\156\145\143\164" : "\144\151\x73\x63\157\156\156\145\x63\164"; goto eS6gJ; uKEj4: f1bQL: goto Tk6CP; deyP2: jo30H: goto tONZD; xp7o4: return $this->ltrrV; goto IPFsS; Tk6CP: $this->rURfm = time(); goto D4Zsn; KezKg: if (!('' !== ($this->CMea3["\143\x6f\156\146\151\x72\x6d\x5f\x74\x69\x6d\x65\157\x75\x74"] ?? ''))) { goto f1bQL; } goto kJzR8; DFL5p: $ThLNy = "\164\x72\165\x65" === ($this->CMea3["\x70\x65\x72\163\x69\163\164\x65\x6e\x74"] ?? "\146\141\154\163\145") ? "\x70\143\x6f\x6e\x6e\145\143\164" : "\143\157\x6e\x6e\145\x63\x74"; goto pUY_i; eNLt_: sTtBg: goto fqtFa; IPFsS: } public function ibnTf(string $I1vwJ) : \AMQPQueue { goto v1pq2; cd9RM: $sguol->mvxVE($I1vwJ); goto iAie4; v1pq2: if (isset($this->dWNnO[$I1vwJ])) { goto RdNFZ; } goto CkdbU; nacWe: p2Y37: goto S3wRd; S3wRd: $this->dWNnO[$I1vwJ] = $sguol; goto wD6A5; hbvYP: return $this->dWNnO[$I1vwJ]; goto bwXlR; wD6A5: RdNFZ: goto hbvYP; pExFh: if (!isset($T2tiy["\141\x72\x67\x75\155\145\156\164\x73"])) { goto p2Y37; } goto gmvpd; MDJoJ: $sguol = $this->OlSwv->kKWcr($this->dmNAH()); goto cd9RM; iAie4: $sguol->setFlags($T2tiy["\x66\x6c\141\147\163"] ?? \JiDE3); goto pExFh; gmvpd: $sguol->KIVCh($T2tiy["\x61\162\147\x75\155\145\x6e\164\163"]); goto nacWe; CkdbU: $T2tiy = $this->mn60e[$I1vwJ] ?? []; goto MDJoJ; bwXlR: } public function r0Zzc() : \AMQPExchange { goto iWWk6; oU2qV: DnJ2I: goto OHELJ; ZfGj8: if (!isset($this->eN44Y["\x61\162\x67\x75\x6d\145\156\x74\x73"])) { goto tdtMB; } goto T0kn4; rlSs8: $this->NwGSo->setType($this->eN44Y["\x74\x79\x70\145"] ?? \fdp_k); goto bgcCk; YU2fA: $this->NwGSo = $this->OlSwv->Z82t9($this->DMNAh()); goto fGPx2; OHELJ: return $this->NwGSo; goto UKniX; iWWk6: if (isset($this->NwGSo)) { goto DnJ2I; } goto YU2fA; fGPx2: $this->NwGSo->mvxvE($this->eN44Y["\x6e\141\x6d\x65"]); goto rlSs8; T0kn4: $this->NwGSo->KIvcH($this->eN44Y["\141\162\x67\x75\x6d\x65\x6e\x74\x73"]); goto uKCzT; bgcCk: $this->NwGSo->setFlags($this->eN44Y["\146\154\141\147\163"] ?? \JiDE3); goto ZfGj8; uKCzT: tdtMB: goto oU2qV; UKniX: } private function GXyyt() : void { goto UxaEJ; LP8pB: $this->UtZ8S(); goto rq1gN; UxaEJ: if ($this->dMNAh()->Lzh47()) { goto eM0m3; } goto LP8pB; rq1gN: eM0m3: goto D2KZQ; D2KZQ: } private function UTZ8s() : void { unset($this->ltrrV, $this->NwGSo, $this->CSnXL); $this->dWNnO = []; } private function srInY() : ?string { return $this->eN44Y["\144\145\146\141\x75\154\164\137\x70\165\x62\154\151\163\150\137\x72\157\165\164\151\156\x67\x5f\153\145\171"] ?? null; } public function AoC8b() : void { foreach ($this->exeXP() as $I1vwJ) { $this->IbnTf($I1vwJ)->BqJyl(); jCmZd: } SlKwe: } private function MUgAU(?AmqpStamp $N2kIq) : ?string { return $N2kIq?->getRoutingKey() ?? $this->SrinY(); } private function C0Qte(callable $UHshO) : void { goto CG_mY; jHmgC: retry: goto vgbtI; Xe6a2: $O2ktm = 0; goto jHmgC; CG_mY: $Z14TX = 3; goto Xe6a2; vgbtI: try { $UHshO(); } catch (\hK_ql $eVwLO) { goto WX1Zt; Um2ks: PnCCz: goto ddpHf; ddpHf: throw $eVwLO; goto B_kBu; WX1Zt: if (!(++$O2ktm <= $Z14TX)) { goto PnCCz; } goto qnfs0; dCpX3: goto retry; goto Um2ks; qnfs0: $this->utz8S(); goto dCpX3; B_kBu: } goto Cpolv; Cpolv: } }

Function Calls

None

Variables

None

Stats

MD5 8802dd2c822e1ba033d9e5c94d031e93
Eval Count 0
Decode Time 105 ms