Source of file AmqpAgentParameters.php

<?php

/**

 * @author Marwan Al-Soltany <MarwanAlsoltany@gmail.com>

 * @copyright Marwan Al-Soltany 2020

 * For the full copyright and license information, please view

 * the LICENSE file that was distributed with this source code.

 */

declare(strict_types=1);

namespace MAKS\AmqpAgent\Config;

use PhpAmqpLib\Message\AMQPMessage;

use PhpAmqpLib\Exchange\AMQPExchangeType;

use MAKS\AmqpAgent\Config\AbstractParameters;

/**

 * A class that contains all AMQP Agent parameters as constants.

 * @since 1.2.0

 */

final class AmqpAgentParameters extends AbstractParameters

{

    public const PREFIX = 'maks.amqp.agent.';

    public const COMMAND_PREFIX = '__COMMAND__';

    public const COMMAND_SYNTAX = [

        self::COMMAND_PREFIX => [

            'ACTION' => 'OBJECT',

            'PARAMS' => [

                'NAME'    => 'VALUE'

            ]

        ]

    ];

    public const CONNECTION_OPTIONS = [

        'host'                => 'localhost',

        'port'                => 5672,

        'user'                => 'guest',

        'password'            => 'guest',

        'vhost'               => '/',

        'insist'              => false,

        'login_method'        => 'AMQPLAIN',

        'login_response'      => null,

        'locale'              => 'en_US',

        'connection_timeout'  => 120,

        'read_write_timeout'  => 120,

        'context'             => null,

        'keepalive'           => true,

        'heartbeat'           => 60,

        'channel_rpc_timeout' => 120,

        'ssl_protocol'        => null

    ];

    public const CHANNEL_OPTIONS = [

        'channel_id' => null

    ];

    public const QUEUE_OPTIONS = [

        'queue'       => self::PREFIX . 'queue',

        'passive'     => false,

        'durable'     => true,

        'exclusive'   => false,

        'auto_delete' => false,

        'nowait'      => false,

        'arguments'   => [],

        'ticket'      => null

    ];

    public const EXCHANGE_OPTIONS = [

        'exchange'    => self::PREFIX . 'exchange',

        'type'        => AMQPExchangeType::HEADERS,

        'passive'     => false,

        'durable'     => true,

        'auto_delete' => false,

        'internal'    => false,

        'nowait'      => false,

        'arguments'   => [],

        'ticket'      => null

    ];

    public const BIND_OPTIONS = [

        'queue'       => self::PREFIX . 'queue',

        'exchange'    => self::PREFIX . 'exchange',

        'routing_key' => self::PREFIX . 'routing',

        'nowait'      => false,

        'arguments'   => [],

        'ticket'      => null

    ];

    public const MESSAGE_OPTIONS = [

        'body'       => '{}',

        'properties' => [

            'content_type'     => 'application/json',

            'content_encoding' => 'UTF-8',

            'delivery_mode'    => AMQPMessage::DELIVERY_MODE_PERSISTENT

        ]

    ];

    public const PUBLISH_OPTIONS = [

        'msg'         => null,

        'exchange'    => self::PREFIX . 'exchange',

        'routing_key' => self::PREFIX . 'routing',

        'mandatory'   => false,

        'immediate'   => false,

        'ticket'      => null

    ];

    public const QOS_OPTIONS = [

        'prefetch_size'  => null,

        'prefetch_count' => 5,

        'a_global'       => null

    ];

    public const WAIT_OPTIONS = [

        'allowed_methods' => null,

        'non_blocking'    => true,

        'timeout'         => 3600

    ];

    public const CONSUME_OPTIONS = [

        'queue'        => self::PREFIX . 'queue',

        'consumer_tag' => self::PREFIX . 'consumer',

        'no_local'     => false,

        'no_ack'       => false,

        'exclusive'    => false,

        'nowait'       => false,

        'callback'     => 'MAKS\AmqpAgent\Helper\Example::callback',

        'ticket'       => null,

        'arguments'    => []

    ];

    public const ACK_OPTIONS = [

        'multiple' => false

    ];

    public const NACK_OPTIONS = [

        'multiple' => false,

        'requeue'  => true

    ];

    public const GET_OPTIONS = [

        'queue'  => self::PREFIX . 'queue',

        'no_ack' => false,

        'ticket' => null

    ];

    public const CANCEL_OPTIONS = [

        'consumer_tag'    =>    self::PREFIX . 'consumer',

        'nowait'          =>    false,

        'noreturn'        =>    false

    ];

    public const RECOVER_OPTIONS = [

        'requeue' => true,

    ];

    public const REJECT_OPTIONS = [

        'requeue' => true,

    ];

    public const RPC_CONNECTION_OPTIONS = self::CONNECTION_OPTIONS;

    public const RPC_QUEUE_NAME = self::PREFIX . 'maks.amqp.agent.rpc.queue';

}