examples/rabbitmq/vendor/php-amqplib/php-amqplib/PhpAmqpLib/Connection/Heartbeat/AbstractSignalHeartbeatSender.php

+<?php
+
+namespace PhpAmqpLib\Connection\Heartbeat;
+
+use PhpAmqpLib\Connection\AbstractConnection;
+use PhpAmqpLib\Exception\AMQPRuntimeException;
+
+/**
+ * Manages pcntl-based heartbeat sending for a {@link AbstractConnection}.
+ */
+abstract class AbstractSignalHeartbeatSender
+{
+    /**
+     * @var AbstractConnection|null
+     */
+    protected $connection;
+
+    /**
+     * @param AbstractConnection $connection
+     * @throws AMQPRuntimeException
+     */
+    public function __construct(AbstractConnection $connection)
+    {
+        if (!$this->isSupported()) {
+            throw new AMQPRuntimeException('Signal-based heartbeat sender is unsupported');
+        }
+
+        $this->connection = $connection;
+    }
+
+    public function __destruct()
+    {
+        $this->unregister();
+    }
+
+    /**
+     * @return bool
+     */
+    protected function isSupported(): bool
+    {
+        return extension_loaded('pcntl')
+               && function_exists('pcntl_async_signals')
+               && (defined('AMQP_WITHOUT_SIGNALS') ? !AMQP_WITHOUT_SIGNALS : true);
+    }
+
+    /**
+     * Starts the heartbeats
+     */
+    abstract public function register(): void;
+
+    /**
+     * Stops the heartbeats.
+     */
+    abstract public function unregister(): void;
+
+    /**
+     * Handles the heartbeat when a signal interrupt is received
+     *
+     * @param int $interval
+     */
+    protected function handleSignal(int $interval): void
+    {
+        if (!$this->connection) {
+            return;
+        }
+
+        if (!$this->connection->isConnected()) {
+            $this->unregister();
+            return;
+        }
+
+        if ($this->connection->isWriting()) {
+            return;
+        }
+
+        if (time() > ($this->connection->getLastActivity() + $interval)) {
+            $this->connection->checkHeartBeat();
+        }
+    }
+}

examples/rabbitmq/vendor/php-amqplib/php-amqplib/PhpAmqpLib/Connection/Heartbeat/PCNTLHeartbeatSender.php

+<?php
+
+namespace PhpAmqpLib\Connection\Heartbeat;
+
+use PhpAmqpLib\Exception\AMQPRuntimeException;
+
+/**
+ * @see AbstractSignalHeartbeatSender
+ *
+ * This version of a signal based heartbeat sendler relies on using SIGALRM and uses the OS to trigger an alarm
+ * after a given time.
+ */
+final class PCNTLHeartbeatSender extends AbstractSignalHeartbeatSender
+{
+    public function register(): void
+    {
+        if (!$this->connection) {
+            throw new AMQPRuntimeException('Unable to re-register heartbeat sender');
+        }
+
+        if (!$this->connection->isConnected()) {
+            throw new AMQPRuntimeException('Unable to register heartbeat sender, connection is not active');
+        }
+
+        $timeout = $this->connection->getHeartbeat();
+
+        if ($timeout > 0) {
+            $interval = (int)ceil($timeout / 2);
+            pcntl_async_signals(true);
+            $this->registerListener($interval);
+            pcntl_alarm($interval);
+        }
+    }
+
+    public function unregister(): void
+    {
+        $this->connection = null;
+        // restore default signal handler
+        pcntl_signal(SIGALRM, SIG_IGN);
+    }
+
+    private function registerListener(int $interval): void
+    {
+        pcntl_signal(SIGALRM, function () use ($interval) {
+            $this->handleSignal($interval);
+            if ($this->connection) {
+                pcntl_alarm($interval);
+            }
+        }, true);
+    }
+}

examples/rabbitmq/vendor/php-amqplib/php-amqplib/PhpAmqpLib/Connection/Heartbeat/SIGHeartbeatSender.php

+<?php
+namespace PhpAmqpLib\Connection\Heartbeat;
+
+use PhpAmqpLib\Connection\AbstractConnection;
+use PhpAmqpLib\Exception\AMQPRuntimeException;
+
+/**
+ * @see AbstractSignalHeartbeatSender
+ * @since 3.2.0
+ *
+ * This version of a signal based heartbeat sender allows using any signal number. It forks the current process
+ * to create a child process that periodically sends a signal to the parent process.
+ * The default signal used is SIGUSR1
+ */
+final class SIGHeartbeatSender extends AbstractSignalHeartbeatSender
+{
+    /**
+     * @var int the UNIX signal to be used for managing heartbeats
+     */
+    private $signal;
+
+    /**
+     * @var int|null the PID (process ID) of the child process sending regular signals to manage heartbeats
+     */
+    private $childPid;
+
+    /**
+     * @param AbstractConnection $connection
+     * @param int $signal
+     * @throws AMQPRuntimeException
+     */
+    public function __construct(AbstractConnection $connection, int $signal = SIGUSR1)
+    {
+        parent::__construct($connection);
+        $this->signal = $signal;
+    }
+
+    public function register(): void
+    {
+        if (!$this->connection) {
+            throw new AMQPRuntimeException('Unable to re-register heartbeat sender');
+        }
+
+        if (!$this->connection->isConnected()) {
+            throw new AMQPRuntimeException('Unable to register heartbeat sender, connection is not active');
+        }
+        $timeout = $this->connection->getHeartbeat();
+
+        if ($timeout > 0) {
+            $interval = (int)ceil($timeout / 2);
+            $this->registerListener($interval);
+        }
+    }
+
+    public function unregister(): void
+    {
+        $this->connection = null;
+        // restore default signal handler
+        pcntl_signal($this->signal, SIG_IGN);
+        if ($this->childPid > 0) {
+            posix_kill($this->childPid, SIGKILL);
+        }
+        $this->childPid = null;
+    }
+
+    private function registerListener(int $interval): void
+    {
+        pcntl_async_signals(true);
+        $this->periodicAlarm($interval);
+        pcntl_signal($this->signal, function () use ($interval) {
+            $this->handleSignal($interval);
+        });
+    }
+
+    /**
+     * Forks the current process to create a child process that will send periodic signals to the parent
+     *
+     * @param int $interval
+     */
+    private function periodicAlarm(int $interval): void
+    {
+        $parent = getmypid();
+        $pid = pcntl_fork();
+        if(!$pid) {
+            while (true){
+                sleep($interval);
+                posix_kill($parent, $this->signal);
+            }
+        } else {
+            $this->childPid = $pid;
+        }
+    }
+}

examples/rabbitmq/vendor/php-amqplib/php-amqplib/PhpAmqpLib/Exception/AMQPBasicCancelException.php

+<?php
+
+namespace PhpAmqpLib\Exception;
+
+class AMQPBasicCancelException extends \Exception implements AMQPExceptionInterface
+{
+    /**
+     * @var string
+     * @internal Use getter getConsumerTag()
+     */
+    public $consumerTag;
+
+    /**
+     * @param string $consumerTag
+     */
+    public function __construct($consumerTag)
+    {
+        parent::__construct('Channel was canceled');
+        $this->consumerTag = $consumerTag;
+    }
+
+    /**
+     * @return string
+     */
+    public function getConsumerTag()
+    {
+        return $this->consumerTag;
+    }
+}

examples/rabbitmq/vendor/php-amqplib/php-amqplib/PhpAmqpLib/Exception/AMQPChannelClosedException.php

+<?php
+
+namespace PhpAmqpLib\Exception;
+
+class AMQPChannelClosedException extends AMQPRuntimeException
+{
+}

examples/rabbitmq/vendor/php-amqplib/php-amqplib/PhpAmqpLib/Exception/AMQPConnectionBlockedException.php

+<?php
+
+namespace PhpAmqpLib\Exception;
+
+class AMQPConnectionBlockedException extends AMQPRuntimeException
+{
+    public function __construct($message = '', $code = 0, $previous = null)
+    {
+        if (empty($message)) {
+            $message = 'Connection is blocked due to low resources';
+        }
+        parent::__construct($message, $code, $previous);
+    }
+}

examples/rabbitmq/vendor/php-amqplib/php-amqplib/PhpAmqpLib/Exception/AMQPConnectionClosedException.php

+<?php
+
+namespace PhpAmqpLib\Exception;
+
+/**
+ * When connection was closed by server, proxy or some tunnel due to timeout or network issue.
+ */
+class AMQPConnectionClosedException extends AMQPRuntimeException
+{
+}

examples/rabbitmq/vendor/php-amqplib/php-amqplib/PhpAmqpLib/Exception/AMQPDataReadException.php

+<?php
+
+namespace PhpAmqpLib\Exception;
+
+class AMQPDataReadException extends AMQPRuntimeException
+{
+}

examples/rabbitmq/vendor/php-amqplib/php-amqplib/PhpAmqpLib/Exception/AMQPEmptyDeliveryTagException.php

+<?php
+
+namespace PhpAmqpLib\Exception;
+
+class AMQPEmptyDeliveryTagException extends AMQPRuntimeException
+{
+}

examples/rabbitmq/vendor/php-amqplib/php-amqplib/PhpAmqpLib/Exception/AMQPExceptionInterface.php

+<?php
+
+namespace PhpAmqpLib\Exception;
+
+interface AMQPExceptionInterface
+{
+}

examples/rabbitmq/vendor/php-amqplib/php-amqplib/PhpAmqpLib/Exception/AMQPHeartbeatMissedException.php

+<?php
+
+namespace PhpAmqpLib\Exception;
+
+class AMQPHeartbeatMissedException extends AMQPConnectionClosedException
+{
+}

examples/rabbitmq/vendor/php-amqplib/php-amqplib/PhpAmqpLib/Exception/AMQPIOException.php

+<?php
+
+namespace PhpAmqpLib\Exception;
+
+class AMQPIOException extends \Exception implements AMQPExceptionInterface
+{
+}

examples/rabbitmq/vendor/php-amqplib/php-amqplib/PhpAmqpLib/Exception/AMQPIOWaitException.php

+<?php
+
+namespace PhpAmqpLib\Exception;
+
+class AMQPIOWaitException extends AMQPRuntimeException
+{
+}

examples/rabbitmq/vendor/php-amqplib/php-amqplib/PhpAmqpLib/Exception/AMQPInvalidArgumentException.php

+<?php
+
+namespace PhpAmqpLib\Exception;
+
+class AMQPInvalidArgumentException extends \RuntimeException implements AMQPExceptionInterface
+{
+}

examples/rabbitmq/vendor/php-amqplib/php-amqplib/PhpAmqpLib/Exception/AMQPInvalidFrameException.php

+<?php
+
+namespace PhpAmqpLib\Exception;
+
+class AMQPInvalidFrameException extends AMQPRuntimeException
+{
+}

examples/rabbitmq/vendor/php-amqplib/php-amqplib/PhpAmqpLib/Exception/AMQPLogicException.php

+<?php
+
+namespace PhpAmqpLib\Exception;
+
+class AMQPLogicException extends \LogicException implements AMQPExceptionInterface
+{
+
+}

examples/rabbitmq/vendor/php-amqplib/php-amqplib/PhpAmqpLib/Exception/AMQPNoDataException.php

+<?php
+
+namespace PhpAmqpLib\Exception;
+
+/**
+ * Used mostly in non-blocking methods when no data is ready for processing.
+ */
+class AMQPNoDataException extends AMQPRuntimeException
+{
+}

examples/rabbitmq/vendor/php-amqplib/php-amqplib/PhpAmqpLib/Exception/AMQPNotImplementedException.php

+<?php
+
+namespace PhpAmqpLib\Exception;
+
+class AMQPNotImplementedException extends AMQPRuntimeException
+{
+}

examples/rabbitmq/vendor/php-amqplib/php-amqplib/PhpAmqpLib/Exception/AMQPOutOfBoundsException.php

+<?php
+
+namespace PhpAmqpLib\Exception;
+
+class AMQPOutOfBoundsException extends \OutOfBoundsException implements AMQPExceptionInterface
+{
+}

examples/rabbitmq/vendor/php-amqplib/php-amqplib/PhpAmqpLib/Exception/AMQPOutOfRangeException.php

+<?php
+
+namespace PhpAmqpLib\Exception;
+
+class AMQPOutOfRangeException extends \OutOfRangeException implements AMQPExceptionInterface
+{
+
+}