xezzus/amqp-im

Send and take message to AMQP protocol

dev-master / 1.0.x-dev 2015-04-15 14:46 UTC

Requires

• php: >=5.6.0

BSD-3-Clause

• Buturlakin Andrey

• AMQP
• im

README

Установка

Для работы с компонентом требуется установить библиотеку AMQP через PECL

pecl amqp

Использование

// подклimючение к точке обмена сообщениями
$im = Yii::$app->exchange('globalChat');

// Отправить сообщение в точку обмена
$im->send('Text message');

// Получить сообщение
$take = $im->take();

// Получить тело сообщения
$take->msg();

// Сообщение серверу, что сообщение обработано и его можно удалить из очереди
$take->ack();

Конфигурация

"components"=>[
  "im"=>[
    'class' => 'common\components\im\Connection',
    'host'=>'127.0.0.1',
    'login'=>'guest',
    'password'=>'guest',
    'port'=>'5672'
  ]
]