teamones/stomp-queue

There is no license information available for the latest version (0.1.5) of this package.

Stomp client written in PHP for webman.

Maintainers

Details

github.com/teamones-open/stomp-queue

Source

Issues

Installs: 6 605

Dependents: 0

Suggesters: 0

Security: 0

Stars: 6

Watchers: 1

Forks: 1

Open Issues: 0

0.1.5 2022-06-13 09:32 UTC

Requires

Unknown License 25deabc1bc8a5e38fc7c3504b17b6d047e33350f

This package is auto-updated.

Last update: 2025-03-13 15:15:52 UTC

README

Asynchronous STOMP client for webman.

Features

  1. Create exchange and queues with php-amqplib/php-amqplib component.
  2. Using /amq/queue/[queuename] mode to subscribe.
  3. Using /exchange/[exchangename]/[routing_key] mode to send message.
  4. Support delayed message by rabbitmq_delayed_message_exchange plugin.

Document

https://www.workerman.net/doc/webman#/queue/stomp

Install

composer require teamones/stomp-queue

config

return [
    'default' => [
        'host' => 'stomp://' . env("rabbitmq_host", '127.0.0.1') . ':' . env("rabbitmq_stomp_port", 61613),
        'options' => [
            'vhost' => env("rabbitmq_vhost", '/'),
            'login' => env("rabbitmq_user", 'guest'),
            'passcode' => env("rabbitmq_password", 'guest'),
            'debug' => (bool)env("app_debug", false),
        ],
        'amqp' => [
            'host' => env("rabbitmq_host", '127.0.0.1'),
            'port' => env("rabbitmq_amqp_port", 5672),
            'namespace' => env("belong_system", ''),
            'exchange_name' => env("rabbitmq_exchange_name", 'exchange'),
            'exchange_delay' => (bool)env("rabbitmq_exchange_delay", true)
        ]
    ]
]