Как использовать php-amqplib для подключения к образу ActiveMQ Classic Docker ⇐ Php

[Anonymous]

Я пытаюсь создать специальную команду, которая должна получать сообщения из очереди ActiveMQ Classic. Я использую php-amqplib и создал собственный соединитель и ActiveMQServiceProvider. Я получаю эту ошибку при запуске Sail Artisan Horizon:consume-activemq

Код: Выделить всё

PhpAmqpLib\Exception\AMQPInvalidFrameException

Invalid frame type 65

...

7   app/Queue/Connectors/ActiveMQConnector.php:15
PhpAmqpLib\Connection\AMQPStreamConnection::__construct()

8   app/Console/Commands/ConsumeActiveMQMessages.php:29
App\Queue\Connectors\ActiveMQConnector::connect()

Я проверил журнал Docker и обнаружил, что php-amqplib не поддерживает AMQP v1.0:

Код: Выделить всё

Connection attempt from non AMQP v1.0 client.  AMQP,0,0,9,1
2024-02-22 13:24:44  WARN | Transport Connection to: tcp://192.168.65.1:32999 failed: org.apache.activemq.transport.amqp.AmqpProtocolException: Connection from the client using unsupported AMQP attempted

Я что-то неправильно понял или неправильно настроил?
Вот мои конфигурации:

Код: Выделить всё

queue.php

Код: Выделить всё

    'connections' => [

...
'activemq' => [
'driver' => 'activemq',
'host' => env('ACTIVEMQ_HOST', 'localhost'),
'port' => env('ACTIVEMQ_PORT', 61613),
'username' => env('ACTIVEMQ_USERNAME', 'guest'),
'password' => env('ACTIVEMQ_PASSWORD', 'guest'),
'queue' => env('ACTIVEMQ_QUEUE', ''),
'exchange_name' => env('ACTIVEMQ_EXCHANGE_NAME', ''),
],

mylocal.env

Код: Выделить всё

ACTIVEMQ_HOST=host.docker.internal
ACTIVEMQ_PORT=5672
ACTIVEMQ_USER=admin
ACTIVEMQ_PASSWORD=admin
ACTIVEMQ_QUEUE=activemqTest

Код: Выделить всё

ActiveMQServiceProvider.php

Код: Выделить всё

Подробнее здесь: [url]https://stackoverflow.com/questions/78039935/how-to-use-php-amqplib-to-connect-to-activemq-classic-docker-image[/url]