vyuldashev / laravel-queue-rabbitmq

RabbitMQ driver for Laravel Queue. Supports Laravel Horizon.
MIT License
1.91k stars 377 forks source link

[Invalid Frame 21] #595

Open Duy221995 opened 3 months ago

Duy221995 commented 3 months ago

When i change 'network_protocol' => 'tls', in config rabbitmq in queue.php 'rabbitmq' => [ 'driver' => 'rabbitmq', 'network_protocol' => 'tls', ..... ] 'options' => [ ..... ] ]

I caught this issue " Invalid frame type 21 {"exception":"[object] (PhpAmqpLib\Exception\AMQPInvalidFrameException" How can i resolve this error? Thanks!

AlexZodov commented 1 month ago

Hi

Having same problem when trying to connect to amazon mq via amqps://

Is there any progress with this issue?

aalda-eishia commented 2 weeks ago

Hi, I'm having same problem connecting to Amazon MQ via SSL. I guess same as @AlexZodov Any help will be appreciated

AlexZodov commented 1 week ago

@aalda-eishia solved it by changing queue config (queue.php file) to


        'rabbitmq'                              => [
            'driver'      => env('DEFAULT_QUEUE_CONNECTION', 'rabbitmq'),
            'queue'       => env('DEFAULT_RABBITMQ_QUEUE', 'default'),
            'factory'     => \PhpAmqpLib\Connection\AMQPConnectionFactory::class,
            'hosts'       => [
                [
                    'host'     => env('DEFAULT_RABBITMQ_HOST', '127.0.0.1'),
                    'port'     => env('DEFAULT_RABBITMQ_PORT', 5672),
                    'user'     => env('DEFAULT_RABBITMQ_USER', 'guest'),
                    'password' => env('DEFAULT_RABBITMQ_PASSWORD', 'guest'),
                    'vhost'    => env('DEFAULT_RABBITMQ_VHOST', '/'),
                ],
            ],
            'options'     => [
                'queue' => [
                    'quorum' => env('DEFAULT_RABBITMQ_QUEUE_TYPE', 'classic') === 'quorum',
                ],
            ],
            'secure'      => env('DEFAULT_RABBITMQ_SECURE', 'no'), // here should be provided 'yes' or 'no'
            'ssl_options' => [
                'cafile'      => env('DEFAULT_RABBITMQ_SSL_CAFILE', null),
                'local_cert'  => env('DEFAULT_RABBITMQ_SSL_LOCALCERT', null),
                'local_key'   => env('DEFAULT_RABBITMQ_SSL_LOCALKEY', null),
                'verify_peer' => env('DEFAULT_RABBITMQ_SSL_VERIFY_PEER', false),
                'passphrase'  => env('DEFAULT_RABBITMQ_SSL_PASSPHRASE', null),
            ],
        ],